【SpringBoot】14.整合Mybatis

MyBatis前身是apache的一个开源项目iBatis&＃xff0c;2010年这个项目由apache software foundation 迁移到了google code&＃xff0c;并且改名为MyBatis2013年11月迁移到Github。

他是一个支持普通SQL查询&＃xff0c;存储过程和高级映射的优秀持久层框架。他消除了几乎所有的JDBC代码和参数的手工设置以及对结果集的检索封装&＃xff0c;支持简单的XML或注解用于配置和原始映射&＃xff0c;将接口和Java的POJO&＃xff08;Plain Old Java Objects&＃xff0c;普通的Java对象&＃xff09;映射成数据库中的记录。

这一节&＃xff0c;我们将学习如何将mybatis整合到我们的项目中&＃xff0c;辅助数据库操作。

创建项目

同样采用SpringInitializer创建项目&＃xff0c;选择如下模块&＃xff1a;

• web 作为web启动
• MySQL 作为数据库驱动
• JDBC 为我们自动配置数据源(可不选择&＃xff0c;mybatis会依赖)
• MyBatis 数据访问框架

引入mybatis只需引入依赖

pom.xml

org.mybatis.spring.bootmybatis-spring-boot-starter1.3.2


从其artifactId我们可以了解到&＃xff0c;这不是官方包。

配置基本环境信息

我们按整合jdbc与数据源那一章节配置的方式将基础环境配置好。

application.yml

server:port: 8086
spring:datasource:username: rootpassword: 123456url: jdbc:mysql://10.21.1.47:3306/joyblack?characterEncoding&＃61;utf8&serverTimezone&＃61;GMTdriver-class-name: com.mysql.cj.jdbc.Driverinitialization-mode: alwayssql-script-encoding: utf-8schema:- classpath:sql/joyblack.sql


然后倒入我们创建数据库以及倒入数据的sql文件&＃xff0c;为了偷懒&＃xff0c;我们统一将其放在schema逻辑中。该脚本创建了两张表user以及department&＃xff0c;分别代表用户信息以及用户所在的部门信息&＃xff0c;并导入了3个冒险者用户以及2个工会部门。

sql/joyblack.sql

/*
Navicat MySQL Data TransferSource Server : docker
Source Server Version : 50505
Source Host : 10.21.1.47:3306
Source Database : joyblackTarget Server Type : MYSQL
Target Server Version : 50505
File Encoding : 65001Date: 2018-12-20 09:45:44
*/SET FOREIGN_KEY_CHECKS&＃61;0;-- ----------------------------
-- Table structure for &＃96;department&＃96;
-- ----------------------------
DROP TABLE IF EXISTS &＃96;department&＃96;;
CREATE TABLE &＃96;department&＃96; (&＃96;id&＃96; int(11) NOT NULL,&＃96;department_name&＃96; varchar(30) NOT NULL,PRIMARY KEY (&＃96;id&＃96;)
) ENGINE&＃61;InnoDB DEFAULT CHARSET&＃61;utf8;-- ----------------------------
-- Records of department
-- ----------------------------
INSERT INTO &＃96;department&＃96; VALUES (&＃39;1&＃39;, &＃39;乡下冒险者公会&＃39;);
INSERT INTO &＃96;department&＃96; VALUES (&＃39;2&＃39;, &＃39;城市冒险者公会&＃39;);-- ----------------------------
-- Table structure for &＃96;user&＃96;
-- ----------------------------
DROP TABLE IF EXISTS &＃96;user&＃96;;
CREATE TABLE &＃96;user&＃96; (&＃96;id&＃96; int(11) NOT NULL,&＃96;user_name&＃96; varchar(20) NOT NULL,&＃96;login_name&＃96; varchar(20) NOT NULL,&＃96;deparment_id&＃96; int(11) NOT NULL DEFAULT 1,PRIMARY KEY (&＃96;id&＃96;)
) ENGINE&＃61;InnoDB DEFAULT CHARSET&＃61;utf8;-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO &＃96;user&＃96; VALUES (&＃39;1&＃39;, &＃39;阿库娅&＃39;, &＃39;akuya&＃39;, &＃39;1&＃39;);
INSERT INTO &＃96;user&＃96; VALUES (&＃39;2&＃39;, &＃39;克里斯汀娜&＃39;, &＃39;crustina&＃39;, &＃39;1&＃39;);
INSERT INTO &＃96;user&＃96; VALUES (&＃39;3&＃39;, &＃39;惠惠&＃39;, &＃39;huihui&＃39;, &＃39;1&＃39;);


我们接下来跑一下应用程序&＃xff0c;初始化数据库信息。为了运行快速一点&＃xff0c;之后我们应该把配置文件中的schema:- classpath:sql/joyblack.sql给注释掉&＃xff0c;下次就不要在初始化了。

创建实体Bean

接下来我们创建对应的Bean&＃xff0c;关联数据库表实体。

bean/User.class

package com.zhaoyi.mbweb.bean;public class User {private Integer id;private String loginName;private String userName;private Integer departmentId;public Integer getId() {return id;}public void setId(Integer id) {this.id &＃61; id;}public String getLoginName() {return loginName;}public void setLoginName(String loginName) {this.loginName &＃61; loginName;}public String getUserName() {return userName;}public void setUserName(String userName) {this.userName &＃61; userName;}public Integer getDepartmentId() {return departmentId;}public void setDepartmentId(Integer departmentId) {this.departmentId &＃61; departmentId;}
}

bean/Department.class

package com.zhaoyi.mbweb.bean;public class Department {private Integer id;private String departmentName;public Integer getId() {return id;}public void setId(Integer id) {this.id &＃61; id;}public String getDepartmentName() {return departmentName;}public void setDepartmentName(String departmentName) {this.departmentName &＃61; departmentName;}
}

准备工作完成了&＃xff0c;我们可以准备使用mybatis了。

接下来我们就可以使用mybatis提供的便利操作数据库了&＃xff0c;不过也有不同的操作方式&＃xff0c;我们先一个一个的来。

基于注解的方式无需指明任何配置&＃xff0c;直接编写相关的注解语句即可&＃xff0c;我们只专注自己的Mapper就可以了。

接下来我们测试一下怎么使用基于注解的方式操作数据库。我们新建一个Mapper接口&＃xff0c;里面包括了基本的增删查改操作&＃xff1a;

mapper/DepartMentMapper.class

package com.zhaoyi.mbweb.mapper;import com.zhaoyi.mbweb.bean.Department;
import org.apache.ibatis.annotations.*;&＃64;Mapper
public interface DepartmentMapper {// insert a derpartment.// &＃64;Options(useGeneratedKeys &＃61; true, keyProperty &＃61; "id") may you want get insert data generated id.&＃64;Insert("insert into department(id,department_name) values(#{id}, #{departmentName})")int insertDepartment(Department department);// delete a department by id.&＃64;Insert("delete from department where id &＃61; #{id}")int deleteDepartment(Integer id);// query a department by id.&＃64;Select("select * from department where id &＃61; #{id}")Department getDepartmentById(Integer id);// update a department information.&＃64;Update("update department set department_name&＃61;#{departmentName} where id&＃61;#{id}")int updateDepartment(Department department);
}


其中&＃xff1a;

• &＃64;Mapper 指定这是一个操作数据库的Mapper&＃xff1b;
• 如果你的表是自增类型的&＃xff0c;想要获得返回id的信息&＃xff0c;可以在插入语句上方加入注解&＃64;Options(useGeneratedKeys &＃61; true, keyProperty &＃61; "id")&＃xff0c;这样&＃xff0c;在插入后mybatis就会自动的将id属性回写到你的插入对象中了&＃xff1b;
• 可以通过#{xxx}语法提取参数中传递的值&＃xff1b;

然后&＃xff0c;编写一个controller来测试这些操作&＃xff0c;为了方便&＃xff0c;我们就只测试查询和插入操作即可&＃xff1a;

controller/DepartmentController.class

package com.zhaoyi.mbweb.controller;import com.zhaoyi.mbweb.bean.Department;
import com.zhaoyi.mbweb.mapper.DepartmentMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;&＃64;RestController
public class DepartmentController {&＃64;Autowiredprivate DepartmentMapper departmentMapper;&＃64;GetMapping("/department/{id}")public Department getDepartment(&＃64;PathVariable("id") Integer id){return departmentMapper.getDepartmentById(id);}&＃64;GetMapping("/department")public Department insertDepartment(Department department){departmentMapper.insertDepartment(department);return department;}}

其中&＃xff1a;

• getDepartment映射/department/{id}的请求&＃xff0c;用于处理查询某个id的部门信息&＃xff0c;id写在路径参数中&＃xff1b;
• insertDepartment映射/department?xxx&＃61;xxx的请求&＃xff0c;用于插入get传递的参数中指定的部门信息&＃xff1b;

一切完毕&＃xff0c;运行项目后&＃xff0c;我们分别测试两个操作的结果&＃xff1a;

1. 访问: http://localhost:8086/department/2&＃xff0c;我们可以得到以下的输出&＃xff1a;

{"id":2,"departmentName":null}


2. 访问&＃xff1a;http://localhost:8086/department?id&＃61;3&name&＃61;广州冒险者公会&＃xff0c;我们得到以下的输出:

{"id":3,"departmentName":"广州冒险者公会"}


并可以在数据库中看到该条数据。这就是基于注解的方式来使用mybatis操作数据库。

开启驼峰映射规则

细心的朋友应该会发现&＃xff0c;查询的部门信息的时候返回的数据的departmentName的值为空。这显然是不对的&＃xff0c;我们可以留意到在数据库中我们的命名方式是下划线的department_name&＃xff0c;而bean中则是departmentName。这就需要我们开启驼峰映射规则&＃xff0c;来提醒mybatis将数据库的下划线字段和bean的驼峰变量关联起来。

如何修改呢&＃xff1f;

我们观察mybatis的自动配置类

&＃64;EnableConfigurationProperties({MybatisProperties.class})
&＃64;AutoConfigureAfter({DataSourceAutoConfiguration.class})
public class MybatisAutoConfiguration {...&＃64;Bean&＃64;ConditionalOnMissingBeanpublic SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {SqlSessionFactoryBean factory &＃61; new SqlSessionFactoryBean();factory.setDataSource(dataSource);factory.setVfs(SpringBootVFS.class);if (StringUtils.hasText(this.properties.getConfigLocation())) {factory.setConfigLocation(this.resourceLoader.getResource(this.properties.getConfigLocation()));}org.apache.ibatis.session.Configuration configuration &＃61; this.properties.getConfiguration();if (configuration &＃61;&＃61; null && !StringUtils.hasText(this.properties.getConfigLocation())) {configuration &＃61; new org.apache.ibatis.session.Configuration();}// 从这里可以知道可以通过配置ConfigurationCustomizer来操作mybatis的配置if (configuration !&＃61; null && !CollectionUtils.isEmpty(this.configurationCustomizers)) {Iterator var4 &＃61; this.configurationCustomizers.iterator();while(var4.hasNext()) {ConfigurationCustomizer customizer &＃61; (ConfigurationCustomizer)var4.next();customizer.customize(configuration);}}factory.setConfiguration(configuration);if (this.properties.getConfigurationProperties() !&＃61; null) {factory.setConfigurationProperties(this.properties.getConfigurationProperties());}if (!ObjectUtils.isEmpty(this.interceptors)) {factory.setPlugins(this.interceptors);}if (this.databaseIdProvider !&＃61; null) {factory.setDatabaseIdProvider(this.databaseIdProvider);}if (StringUtils.hasLength(this.properties.getTypeAliasesPackage())) {factory.setTypeAliasesPackage(this.properties.getTypeAliasesPackage());}if (StringUtils.hasLength(this.properties.getTypeHandlersPackage())) {factory.setTypeHandlersPackage(this.properties.getTypeHandlersPackage());}if (!ObjectUtils.isEmpty(this.properties.resolveMapperLocations())) {factory.setMapperLocations(this.properties.resolveMapperLocations());}return factory.getObject();}...
}


可以发现&＃xff0c;我们可以通过增加ConfigurationCustomizer类型的Bean&＃xff0c;就可以修改mybatis的配置信息了。添加配置&＃xff1a;

config/MyBatisConfig.class

package com.zhaoyi.mbweb.config;import org.apache.ibatis.session.Configuration;
import org.mybatis.spring.boot.autoconfigure.ConfigurationCustomizer;
import org.springframework.context.annotation.Bean;&＃64;org.springframework.context.annotation.Configuration
public class MyBatisConfig {&＃64;Beanpublic ConfigurationCustomizer configurationCustomizer(){return new ConfigurationCustomizer(){&＃64;Overridepublic void customize(Configuration configuration) {// 开启驼峰映射规则configuration.setMapUnderscoreToCamelCase(true);}};}
}


接下来&＃xff0c;我们重启项目&＃xff0c;就可以发现&＃xff0c;可以正常的获得部门信息了&＃xff0c;继续访问刚才的地址http://localhost:8086/department/2&＃xff0c;获取id为2的部门信息&＃xff1a;

{"id":2,"departmentName":"城市冒险者公会"}


批量扫描Mapper接口

通过前面的介绍&＃xff0c;我们需要留意一点&＃xff0c;就是编写Mapper的时候要为其添加&＃64;Mapper注解&＃xff0c;这样才能让mybatis识别这些mapper。但是在实际的开发过程中&＃xff0c;Mapper肯定是一个不少的量的&＃xff0c;至少&＃xff0c;为了简洁考虑&＃xff0c;您需要为每个数据表映射一个Mapper&＃xff0c;有没有一种一劳永逸的方法呢&＃xff1f;

有&＃xff01;

我们只需在MyBaticConfig加上扫描注解或者SpringBoot的启动类上添加&＃64;MapperScan(value&＃61;"your mapper packagePath")&＃xff0c;例如&＃xff0c;我们可以在上面的mybatis配置类这样写&＃xff1a;

config/MybatisConfig.class

// batch scan all mapper class.
&＃64;MapperScan(value &＃61; "com.zhaoyi.mbweb.mapper")
&＃64;org.springframework.context.annotation.Configuration
public class MyBatisConfig {


com.zhaoyi.mbweb.mapper 是我的mapper所在的包名&＃xff0c;请按您自己的包名进行填写。

更多信息请参考: 官方文档

前面我们使用了基于注解的方式对数据库进行了操作&＃xff0c;现在&＃xff0c;我们试试另外一种方式&＃xff0c;通过配置文件的方式来使用mybatis操作数据库。为了方便&＃xff0c;我们接下来的这种方式就来操作user表进行演示即可。

编写Mapper

首先&＃xff0c;编写一个user的mapper

mapper/UserMapper.class

package com.zhaoyi.mbweb.mapper;import com.zhaoyi.mbweb.bean.User;public interface UserMapper {int insertUser(User user);int deleteUser(Integer id);User getUserById(Integer id);int updateUser(User user);
}


和之前的DepartmentMapper不同的是&＃xff0c;我们这里并没有添加注解&＃xff0c;因为&＃xff0c;我们将会把他们写在对应的mybatis SQL映射文件中。

设置应用程序全局配置文件

接下来我们要指定Mybatis配置文件以及Mybatis SQL映射文件的路径&＃xff0c;在配置文件中添加如下配置

application.yml

server:port: 8086
spring:datasource:username: rootpassword: 123456url: jdbc:mysql://10.21.1.47:3306/joyblack?characterEncoding&＃61;utf8&serverTimezone&＃61;GMTdriver-class-name: com.mysql.cj.jdbc.Driverinitialization-mode: alwayssql-script-encoding: utf-8#schema:# - classpath:sql/joyblack.sql
mybatis:# mybatis配置文件config-location: classpath:mybatis/mybatis-config.xml# SQL映射文件路径&＃xff0c;查看源码他是一个String数组&＃xff0c;不过我们直接配置"*"通配符即可&＃xff0c;代表所有的xml文件mapper-locations: classpath:mybatis/mapper/*.xml


配置Mybatis配置文件

在资源文件夹下创建mybatis文件夹&＃xff0c;并放入mybatis-config.xml&＃xff08;和全局配置指定的路径一致&＃xff09;配置文件

resources/mybatis/mybatis-config.xml

里面配置一些相关配置&＃xff0c;例如数据库连接信息等&＃xff0c;但这些我们已经在数据源配置了&＃xff0c;这里就无需配置。

如果我们没有在mybatis的主配置文件中配置mapUnderscoreToCamelCase&＃xff0c;这时候我们去查询部门相关的信息&＃xff0c;发现名字又为空了。因为当使用配置文件之后&＃xff0c;我们的自定义配置中设置的驼峰式映射逻辑已经被配置文件的默认配置覆盖掉了。因此&＃xff0c;我们需要在配置文件中指定驼峰时映射规则&＃xff1a;

resources/mybatis/mybatis-config.xml

可以发现&＃xff0c;配置项mapUnderscoreToCamelCase和我们使用配置文件的属性名是一模一样的。

从这里可以看出&＃xff0c;两种方式混用也是可以的&＃xff0c;但是问题很明显&＃xff0c;配置会冲突。所以大家在开发的时候最好还是选择其中一种方式&＃xff0c;从始至终进行&＃xff0c;避免管理上的复杂以及逻辑的混乱。

配置Mybatis SQL映射文件

对应配置文件创建一个mapper文件夹&＃xff0c;用于放我们的SQL映射文件&＃xff0c;在这里我们创建一个UserMapper.xml即可.

resources/mybatis/mapper/UserMapper.xml



insert into user(id, login_name, user_name, department_id) values (#{id}, #{loginName}, #{userName}, #{departmentId})delete from user where id &＃61; #{id}select * from user where id &＃61; #{id}update user set user_name &＃61; #{userName} where id &＃61; #{id}



接下来就是编写controller测试curd4个操作了。

controller/UserController.class

package com.zhaoyi.mbweb.controller;import com.zhaoyi.mbweb.bean.User;
import com.zhaoyi.mbweb.mapper.UserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;&＃64;RestController
public class UserController {&＃64;Autowiredprivate UserMapper userMapper;&＃64;RequestMapping("/user/insert")public User insertUser(User user){userMapper.insertUser(user);return user;}&＃64;RequestMapping("/user/delete/{id}")public Integer insertUser(&＃64;PathVariable("id") Integer id){return userMapper.deleteUser(id);}&＃64;RequestMapping("/user/select/{id}")public User getUser(&＃64;PathVariable("id") Integer id){return userMapper.getUserById(id);}&＃64;RequestMapping("/user/update")public User updateUser(User user){userMapper.updateUser(user);return user;}
}


测试&＃xff1a;

1. 访问:http://localhost:8086/user/insert?id&＃61;4&loginName&＃61;youyou&userName&＃61;悠悠&departmentId&＃61;2&＃xff0c;插入第4个主角的名字&＃xff1a;

{"id":4,"loginName":"youyou","userName":"悠悠","departmentId":2}


这时候查看数据库&＃xff0c;记录已经增加。 2. 访问:http://localhost:8086/user/update?id&＃61;4&userName&＃61;悠悠改&＃xff0c;修改新增加的悠悠的信息 {"id":4,"loginName":null,"userName":"悠悠","departmentId":null} 因为我们返回的是传入的参数&＃xff0c;所以其他两个字段的空值是正常的。

3. 访问:http://localhost:8086/user/delete/4&＃xff0c;将新增加的主角悠悠记录删除&＃xff1a;

1


返回的是操作影响的记录条数&＃xff0c;显然是1条&＃xff0c;并且数据库中记录已经被删除。

4. 访问http://localhost:8086/user/select/2&＃xff0c;查询id为2的主角信息

{"id":2,"loginName":"crustina","userName":"克里斯汀娜","departmentId":1}


以上就是基于配置方式整合mybatis了&＃xff0c;可以根据自己的需要&＃xff0c;选择自己喜欢的开发方式。之前开发的项目差不多也是两种方式的混合体&＃xff0c;但是时代在进步&＃xff0c;既然用了springboot就不能少了JPA相关的理念&＃xff0c;接下来&＃xff0c;我们就学习JPA相关的东西&＃xff0c;看看spring data还有什么有趣的内容。