在Spring Boot中使用MyBatis访问数据库

MyBatis，这个对各位使用Java开发的开发者来说还是蛮重要的，我相信诸位在企业开发项目的时候，大多数采用的是Mybatis。使用MyBatis帮助我们解决各种问题，实际上这篇文章，基本上默认为可以跳过的一篇，但是为了Spring Boot的系列，我还是写了这篇文章。

MyBatis

作为一个在Hibernate之后出现的持久层框架，因为他支持自定义SQL,存储过程以及高级映射，MyBatis免除了几乎所有的JDBC代码，以及设置参数和获取结果集的工作。MyBatis可以通过简单的XML或者注解来配置和映射原始类型，接口，和Java POJO为数据库中记录。

MyBatis官网： https://mybatis.org/mybatis-3/zh/index.html

引入依赖

		
		<dependency>
			<groupId>org.mybatis.spring.bootgroupId>
			<artifactId>mybatis-spring-boot-starterartifactId>
			<version>2.1.1version>
		dependency>

		<dependency>
			<groupId>mysqlgroupId>
			<artifactId>mysql-connector-javaartifactId>
		dependency>

		<dependency>
			<groupId>org.projectlombokgroupId>
			<artifactId>lombokartifactId>
			<scope>providedscope>
		dependency>

		<dependency>
			<groupId>org.springframework.bootgroupId>
			<artifactId>spring-boot-starter-testartifactId>
			<scope>testscope>
		dependency>
        <dependency>
            <groupId>com.oracle.ojdbcgroupId>
            <artifactId>ojdbc8artifactId>
            <version>19.3.0.0version>
            <scope>compilescope>
        dependency>
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

这里说明一下，MyBatis的版本和Java JDK和Spring Boot的版本是有要求的：
2.1.x版本适用于：MyBatis 3.5+、Java 8+、Spring Boot 2.1+
2.0.x版本适用于：MyBatis 3.5+、Java 8+、Spring Boot 2.0/2.1
1.3.x版本适用于：MyBatis 3.4+、Java 6+、Spring Boot 1.5

配置Application文件

接下来，我们配置Spring Boot的自带的application配置文件：

# MySQL
#spring.datasource.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
#spring.datasource.username=root
#spring.datasource.password=123456
#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

server.port=1001
# Oracle
spring.datasource.url=jdbc:oracle:thin:@localhost:1521/orcl
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver
1
2
3
4
5
6
7
8
9
10
11
12

这是我的Oracle表结构：

MySQL表结构：

CREATE TABLE `User` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `name` varchar(100) COLLATE utf8mb4_general_ci DEFAULT NULL,
  `age` int DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci
1
2
3
4
5
6

接下来创建User表的映射对象，也是我们通用的实体类对象：

public class User {
    private Long id;
    private String name;
    private Integer age;
    
    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", age=" + age +
                '}';
    }

    public User(String name, Integer age) {
        this.name = name;
        this.age = age;
    }

    public User() {
    }
}
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

在有了实体类对象，并且和数据库的字段一一对应后，就可以在接口红定义相关对数据库表的操作了，这里举例，一个是查询，一个是插入，用于后续单元测试的验证。

@Mapper
public interface UserMapper {

    @Select("SELECT * FROM USER WHERE NAME = #{name}")
    User findByName(@Param("name") String name);

    @Insert("INSERT INTO USER(NAME, AGE) VALUES(#{name}, #{age})")
    int insert(@Param("name") String name, @Param("age") Integer age);

}
1
2
3
4
5
6
7
8
9
10

接下来创建一个单元测试类，插入一条数据，然后利用这条数据的相关属性进行查询，并且判断相关属性是否满足。
注意，测试结束后，对数据进行回滚操作，保证单元测试每次运行的数据环境独立。

@RunWith(SpringRunner.class)
@SpringBootTest
@Transactional
public class ApplicationTests {

    @Autowired
    private UserMapper userMapper;

    @Test
    @Rollback
    public void test() throws Exception {
        userMapper.insert("AAA", 20);
        User u = userMapper.findByName("AAA");
        Assert.assertEquals(20, u.getAge().intValue());
    }

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

对于注解配置进行说明介绍

@Mapper：用于标注Mapper接口，表示该接口是MyBatis的Mapper映射接口。在Spring Boot项目中，可以使用@MapperScan注解扫描指定包下的Mapper接口，并将其注册为Bean。

@Select：用于标注查询语句，指定SQL语句或调用Mapper XML文件中的对应SQL语句。可以通过value属性指定SQL语句，也可以通过provider属性指定动态SQL提供者类。

@Insert、@Update、@Delete：分别用于标注插入、更新和删除语句，使用方式与@Select类似。

@Result、@Results：用于标注结果集映射关系。@Result用于标注单个字段或属性与结果集列的映射关系，@Results用于标注多个@Result。

@Param：用于标注方法参数，指定参数在SQL语句中的名称。在SQL语句中可以通过#{参数名}的方式引用该参数。

@Options：用于配置一些选项，例如设置主键生成策略、返回自增主键等。

@ResultMap：用于标注结果集映射配置的ID，可以在其他地方通过@ResultMap引用该结果集映射。

@One、@Many：用于标注一对一和一对多的关联关系。

@CacheNamespace：用于开启二级缓存，将Mapper的查询结果缓存到内存中，提高查询性能。

这里就围绕@Param,Map聊聊。

@Param

我们在实际开发过程中，如果将SQL语句嵌套在接口的时候，我们经常使用的方式就是这种：

@Insert("INSERT INTO USER(NAME, AGE) VALUES(#{name}, #{age})")
int insert(@Param("name") String name, @Param("age") Integer age);
1
2

这种方式，我们都很少理解，@Param中定义的name对应了SQL中的#{name}，age对应了SQL中的#{age}。

Map

除了以@Param注入，我们也可以通过Map 对象作为传递参数的容器:

@Insert("INSERT INTO USER(NAME, AGE) VALUES(#{name,jdbcType=VARCHAR}, #{age,jdbcType=INTEGER})")
int insertByMap(Map<String, Object> map);
1
2

得到如上代码，那么我们应该如何注入呢?

Map<String, Object> map = new HashMap<>();
map.put("name", "CCC");
map.put("age", 40);
userMapper.insertByMap(map);
1
2
3
4

如上，我们通过对map中填入同名的内容就可以实现了。

使用对象注入

除去Map方式注入值外，我们也可以直接java对象直接作为查询条件的传参，比如我们可以直接使用User对象：

@Insert("INSERT INTO USER(NAME, AGE) VALUES(#{name}, #{age})")
int insertByUser(User user);
1
2

利用MyBatis实现增删改查

MyBatis针对不同的数据库操作，分别提供了不同的注解进行配置：

public interface UserMapper {

    @Select("SELECT * FROM user WHERE name = #{name}")
    User findByName(@Param("name") String name);

    @Insert("INSERT INTO user(name, age) VALUES(#{name}, #{age})")
    int insert(@Param("name") String name, @Param("age") Integer age);

    @Update("UPDATE user SET age=#{age} WHERE name=#{name}")
    void update(User user);

    @Delete("DELETE FROM user WHERE id =#{id}")
    void delete(Long id);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14

之后我们可以利用创建一个Test测试类，来实现我们的功能是否正常实现：

@Transactional
@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTests {

	@Autowired
	private UserMapper userMapper;

	@Test
	@Rollback
	public void testUserMapper() throws Exception {
		// insert一条数据，并select出来验证
		userMapper.insert("AAA", 20);
		User u = userMapper.findByName("AAA");
		Assert.assertEquals(20, u.getAge().intValue());
		// update一条数据，并select出来验证
		u.setAge(30);
		userMapper.update(u);
		u = userMapper.findByName("AAA");
		Assert.assertEquals(30, u.getAge().intValue());
		// 删除这条数据，并select验证
		userMapper.delete(u.getId());
		u = userMapper.findByName("AAA");
		Assert.assertEquals(null, u);
	}
}
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

返回结果绑定

对于增、删、改操作相对的数据也就变化较小，但是对于查我们就需要考虑的比较多了，怎么查，多表查，子查，并且查询的结果也不在是我们经常碰到的实体类对象了，往往需要返回一个与数据库实体不同的包装类，那么对于这样的情况，我们可以通过@Result和@Result注解进行绑定。

@Results({
    @Result(property = "name", column = "name"),
    @Result(property = "age", column = "age")
})
@Select("SELECT name, age FROM user")
List<User> findAll();

1
2
3
4
5
6
7

@Result中的property属性对应User对象中的成员名，column对应SELECT出的字段名。在该配置中故意没有查出id属性，只对User对应中的name和age对象做了映射配置，这样可以通过下面的单元测试来验证查出的id为null，而其他属性不为null：

@Test
@Rollback
public void testUserMapper() throws Exception {
	List<User> userList = userMapper.findAll();
	for(User user : userList) {
		Assert.assertEquals(null, user.getId());
		Assert.assertNotEquals(null, user.getName());
	}
}

1
2
3
4
5
6
7
8
9
10