之前学习MyBatis的时候开发了一个名为MyBatisUtils的工具类,它的主要作用就是通过代码方式来实例化MyBatis最核心的对象sqlSessionFactory。因为它是通过程序来创建,则对此Spring没办法进行管理,这样带来的缺点就是MyBatis无法享受到Spring底层的IoC和AOP技术提供的扩展功能(如日志管理、任务调度、声明式事务等)。

因此,MyBatis提供了一个组件名为mybatis-spring,这个组件个主要功能为,不再需要手动初始化SqlSessionFactory对象,取而代之的通过Spring IoC容器中进行简单的配置,就可以让Spring IoC容器在初始化的时候自动的创建SqlSessionFactory对象,同时该对象被IoC容器进行管理,这样基于Spring AOP很多扩展的功能都可以应用在MyBatis的这些组件之上了。同时,这是因为加入了mybatis-spring,把程序创建的权利交给了Spring IoC容器,我们系统中分散的每个技术形成了一个有机的整体,让我们程序更容易被维护,更容易被管理。
所谓整合,其核心的目的就是通过Spring去管理其他组件或框架的核心对象,让这些组件之前形成一个整体。
创建数据库
首先打开Navicat创建新的数据库

然后新建一个测试表

依赖mybatis-spring及驱动
打开pom.xml添加mybatis相关依赖
<dependency>
<groupId>org.springframeworkgroupId>
<artifactId>spring-jdbcartifactId>
<version>5.2.6.RELEASEversion>
dependency>
<dependency>
<groupId>org.mybatisgroupId>
<artifactId>mybatisartifactId>
<version>3.5.4version>
dependency>
<dependency>
<groupId>org.mybatisgroupId>
<artifactId>mybatis-springartifactId>
<version>2.0.3version>
dependency>
<dependency>
<groupId>mysqlgroupId>
<artifactId>mysql-connector-javaartifactId>
<version>8.0.29version>
dependency>
<dependency>
<groupId>com.alibabagroupId>
<artifactId>druidartifactId>
<version>1.1.14version>
dependency>
添加MyBatis相关配置
打开applicationContext.xml添加mybatis配置
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
<property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/ssm-reader?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
<property name="initialSize" value="5"/>
<property name="maxActive" value="20"/>
bean>
<bean id="sessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource"/>
<property name="mapperLocations" value="classpath:mappers/*.xml"/>
<property name="configLocation" value="classpath:mybatis-config.xml"/>
bean>
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.ql.reader.mapper"/>
bean>
然后在src/main/resources目录下创建配置文件mybatis-config.xml
DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<settings>
<setting name="mapUnderscoreToCamelCase" value="true"/>
settings>
configuration>
整合JUnit单元测试
打开pom.xml添加单元测试依赖
<dependency>
<groupId>org.springframeworkgroupId>
<artifactId>spring-testartifactId>
<version>5.2.6.RELEASEversion>
dependency>
<dependency>
<groupId>junitgroupId>
<artifactId>junitartifactId>
<version>4.12version>
<scope>testscope>
dependency>
<dependency>
<groupId>javax.servletgroupId>
<artifactId>javax.servlet-apiartifactId>
<version>3.1.0version>
<scope>providedscope>
dependency>
在com.ql.reader.mapper包下创建TestMapper接口
package com.ql.reader.mapper;
public interface TestMapper {
public void insert();
}
然后在src/main/resources/mappers目录下创建test.xml文件
DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ql.reader.mapper.TestMapper">
<insert id="insert">
insert into test(content) values ('测试内容')
insert>
mapper>
在com.ql.reader.service包下创建TestService类
package com.ql.reader.service;
import com.ql.reader.mapper.TestMapper;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
public class TestService {
@Resource
private TestMapper testMapper;
public void batchImport(){
for (int i = 0; i < 5; i++) {
testMapper.insert();
}
}
}
针对TestService类的batchImport方法生成测试用例,鼠标选中方法,按下快捷键Alt+Insert,面板中选择Test…

然后在面板中选择JUnit版本,选中方法,点击OK即可。

在生成的测试用例编辑内容
package com.ql.reader.service;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import javax.annotation.Resource;
import static org.junit.Assert.*;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext.xml"})
public class TestServiceTest {
@Resource
private TestService testService;
@Test
public void batchImport() {
testService.batchImport();
System.out.println("批量导入成功");
}
}
然后运行测试方法,执行成功。


配置logback日志输出
打开pom.xml添加logback依赖
<dependency>
<groupId>ch.qos.logbackgroupId>
<artifactId>logback-classicartifactId>
<version>1.2.3version>
dependency>
然后在src/main/resources目录下创建logback.xml日志配置文件
<configuration>
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
<pattern>%d{HH:mm:ss} %-5level [%thread] %logger{30} - %msg%npattern>
<charset>UTF-8charset>
encoder>
appender>
<root level="debug">
<appender-ref ref="console"/>
root>
configuration>
重新运行测试方法后可看到响应的日志输出了

声明式事务配置
打开applicationContext.xml首先添加事务相关命名空间,然后添加事务配置
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc.xsd
http://www.springframework.org/schema/context
https://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/tx
https://www.springframework.org/schema/tx/spring-tx.xsd">
...
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
bean>
<tx:annotation-driven transaction-manager="transactionManager"/>
...
beans>
然后打开TestService.java给方法添加事务
package com.ql.reader.service;
import com.ql.reader.mapper.TestMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
@Service
public class TestService {
@Resource
private TestMapper testMapper;
@Transactional
public void batchImport(){
for (int i = 0; i < 5; i++) {
if (i==3){
throw new RuntimeException("预期外异常");
}
testMapper.insert();
}
}
}
清空数据库表数据,重新运行TestServiceTest的测试方法,测试按预期报异常,数据库也并没有新增数据。


然后把batchImport方法里的异常注释掉,重新运行,运行成功。

