MyBatis之动态代理实现增删改查以及MyBatis-config.xml中读取DB信息文件和SQL中JavaBean别名配置

前言

上一篇文章，我们使用MyBatis传统的方式（namespace+id，非接口式编程），完成了数据库的增删改查操作，今天我们学习动态代理的方式（面向接口编程），简单的说，就是将Mapper.xml（定义数据库增删改查SQL文的文件）中定义的SQLID以方法的形式定义在Interface中，调用其方法，完成数据的增删改查，这种方法，也是大部分项目中使用的方法，环境的搭建和准备工作，还是参看我的上一篇文章。
MyBatis之环境搭建以及实现增删改查

---

实现步骤

1. 编写MyBatis-config.xml配置文件

编写配置文件，上一篇文章也有介绍，
今天学习两个新功能，第一个就是编写单独的数据库信息文件，在配置文件中读取后，使用${}方式，读取文件中的内容，配置数据库信息，防止硬编码，完成数据库信息统一管理。
首先编写db.properties，将数据库信息定义在此文件中，通常该文件放在classpath下。
示例代码，如下:

my.driver=com.mysql.cj.jdbc.Driver
my.url=jdbc:mysql://192.168.56.88:3306/mysql
my.username=root
my.password=root
1
2
3
4

在使用< properties>标签，引入到MyBatis-config.xml配置文件中

第二个就是简化参数的写法，上一篇文章，我们看到Mapper.xml文件中，定义SQL的id时，如果输入参数是JavaBean，都是以全类名的形式配置的，这样代码比较冗余，我们使用< typeAliases>< package>标签，批量引用JavaBean，SQL输入输出参数时，可以省略包名的形式，直接使用JavaBean的类名。

MyBatis-config.xml代码如下

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
  PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>

	<!-- 读取外部数据库信息文件 -->
	<properties resource="db.properties" />

	<!-- 设置JavaBean类型的参数别名 -->
	<typeAliases>
		<package name="xxx.xxx.pojo"/>
	</typeAliases>

  <environments default="development">
    <environment id="development">
      <transactionManager type="JDBC"/>
      <dataSource type="POOLED">
        <property name="driver" value="${my.driver}"/>
        <property name="url" value="${my.url}"/>
        <property name="username" value="${my.username}"/>
        <property name="password" value="${my.password}"/>
      </dataSource>
    </environment>
  </environments>
  <mappers>
    <mapper resource="xxx/xxx/mapper/PersonMapper.xml"/>
  </mappers>
</configuration>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

2. 编写Mapper.xml文件（增删改查SQL文）

编写增删改查的SQL文，这里就不做展开了，需要注意的是，我们已经在配置文件中批量引入JavaBean，我们只需使用类名（person）即可，通常类名开头小写。

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="xxx.xxx.entry.personMapper">
  <select id="queryAllPerson" resultType="person">
    select * from person
  </select>
  <select id="queryPersonById" resultType="person" parameterType="int">
    select * from person where id = #{id}
  </select>
  <insert id="addPerson" parameterType="person">
    insert into person values(#{id}, #{name}, #{age}, #{sex})
  </insert>
  <update id="updatePersonById" parameterType="person">
    update person set name = #{name}, age = #{age}, sex = #{sex} where id = #{id}
  </update>
  <delete id="deletePersonById" parameterType="int">
    delete from  person where id = #{id}
  </delete>
</mapper>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

3. 定义PeronMapper接口

将Mapper.xml中SQL的id定义到PeronMapper接口中，输入参数和输出参数与SQL的id中的保持一致。
这里需要注意的是，接口文件和Mapper.xml放到同一个文件中，文件名保持一致。

package xxx.xxx.mapper;

import java.util.List;

import xxx.xxx.pojo.Person;

public interface PersonMapper {

	public List<Person> queryAllPerson();

	public Person queryPersonById(int id);

	public int addPerson(Person person);

	public int updatePersonById(Person person);

	public int deletePersonById(int id);
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

4. 编写测试类

1. 执行步骤

1. 读取MyBatis配置文件
2. 实例化SqlSessionFactory
3. 实例化SqlSession
4. 获取PersonMapper接口
   通过session.getMapper(PersonMapper.class)的方式，获取接口
5. 执行SQL
6. 增删改的场合，完成数据提交

2. 代码实例

完成对Person表的增删改查

package xxx.xxx.test;

import java.io.IOException;
import java.io.Reader;
import java.util.List;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import xxx.xxx.mapper.PersonMapper;
import xxx.xxx.pojo.Person;

public class TestMyBatis {

	public static void main(String[] args) throws IOException {

		Person person = new Person(1, "zs", 23, true);
		System.err.println("登录前");
		queryPersonById(1);
		addPerson(person);
		System.err.println("登录后");
		queryPersonById(1);

		person = new Person(1, "ls", 24, true);
		System.err.println("更新前");
		queryAllPerson();
		updatePersonById(person);
		System.err.println("更新后");
		queryPersonById(1);

		System.err.println("删除前");
		queryPersonById(1);
		deletePersonById(1);
		System.err.println("删除后");
		queryPersonById(1);

	}

	public static void queryAllPersonUsePersonMapping() throws IOException {

		// 1.读取MyBatis配置文件
		Reader reader = Resources.getResourceAsReader("mybatis-config.xml");

		// 2.实例化SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);

		// 3.实例化SqlSession
		try (SqlSession session = sqlSessionFactory.openSession()) {

			// 4.获取PersonMapper接口
			PersonMapper personMapper = session.getMapper(PersonMapper.class);

			// 5.执行SQL
			List<Person> persons = personMapper.queryAllPerson();
			persons.forEach(System.err::println);
		}

	}

	public static void queryAllPerson() throws IOException {

		// 1.读取MyBatis配置文件
		Reader reader = Resources.getResourceAsReader("mybatis-config.xml");

		// 2.实例化SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);

		// 3.实例化SqlSession
		try (SqlSession session = sqlSessionFactory.openSession()) {

			// 4.获取PersonMapper接口
			PersonMapper personMapper = session.getMapper(PersonMapper.class);

			// 5.执行SQL
			List<Person> persons = personMapper.queryAllPerson();
			persons.forEach(System.err::println);
		}

	}

	public static void queryPersonById(int id) throws IOException {

		// 1.读取MyBatis配置文件
		Reader reader = Resources.getResourceAsReader("mybatis-config.xml");

		// 2.实例化SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);

		// 3.实例化SqlSession
		try (SqlSession session = sqlSessionFactory.openSession()) {

			// 4.获取PersonMapper接口
			PersonMapper personMapper = session.getMapper(PersonMapper.class);

			// 5.执行SQL
			Person person = personMapper.queryPersonById(1);
			System.err.println(person);
		}
	}

	public static void addPerson(Person person) throws IOException {

		// 1.读取MyBatis配置文件
		Reader reader = Resources.getResourceAsReader("mybatis-config.xml");

		// 2.实例化SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);

		// 3.实例化SqlSession
		try (SqlSession session = sqlSessionFactory.openSession()) {

			// 4.获取PersonMapper接口
			PersonMapper personMapper = session.getMapper(PersonMapper.class);

			// 5.执行SQL
			int count = personMapper.addPerson(person);
			System.err.println("登陆件数：" + count);

			// 6.增删改的场合，完成数据提交
			session.commit();
		}
	}

	public static void updatePersonById(Person person) throws IOException {

		// 1.读取MyBatis配置文件
		Reader reader = Resources.getResourceAsReader("mybatis-config.xml");

		// 2.实例化SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);

		// 3.实例化SqlSession
		try (SqlSession session = sqlSessionFactory.openSession()) {

			// 4.获取PersonMapper接口
			PersonMapper personMapper = session.getMapper(PersonMapper.class);

			// 5.执行SQL
			int count = personMapper.updatePersonById(person);
			System.err.println("更新件数：" + count);
			// 6.增删改的场合，完成数据提交
			session.commit();
		}
	}

	public static void deletePersonById(int id) throws IOException {

		// 1.读取MyBatis配置文件
		Reader reader = Resources.getResourceAsReader("mybatis-config.xml");

		// 2.实例化SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);

		// 3.实例化SqlSession
		try (SqlSession session = sqlSessionFactory.openSession()) {

			// 4.获取PersonMapper接口
			PersonMapper personMapper = session.getMapper(PersonMapper.class);

			// 5.执行SQL
			int count = personMapper.deletePersonById(id);
			System.err.println("删除件数：" + count);

			// 6.增删改的场合，完成数据提交
			session.commit();
		}
	}

}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172

3. 运行log

通过下边的运行log可以看出，完成对Person表的增删改查

登录前
null
登陆件数：1
登录后
Person [id=1, name=zs, age=23]
更新前
Person [id=1, name=zs, age=23]
更新件数：1
更新后
Person [id=1, name=ls, age=24]
删除前
Person [id=1, name=ls, age=24]
删除件数：1
删除后
null
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

开发环境构造图

总结

到这里，我们就完成了MyBatis的传统方式和面向接口编程方式完成数据库的增删改查，大家可以动手试试，欢迎留言交流，下篇见。