SpringTX的介绍

问题：

在学习了Spring整合mybatis后，我们可以直接从Spring容器中获取mapper层的实例化对象完成数据库操作。而在业务层方法中很多时候因为业务逻辑的复杂性，会出现在业务层方法中调用多个数据库操作。而之前我们学习过事务的管理，在同一个业务中只要有一个数据库操作执行失败，其他的就算执行成功也会一并回滚。但是在Spring整合Mybatis后，我们获取的直接是Mapper接口的实例化对象，而事务的管理需要使用connection对象来完成或者SqlSession对象来完成，那么在Spring整合Mybatis后如何声明事务管理代码呢?

解决:

假如我们能够从Spring容器中获取SqlSession对象，那么在业务方法A中调用了多次的数据库操作，我们就需要在A业务方法中的业务逻辑代码之前开启事务管理，在逻辑代码之后进行提交或者回滚。假如有10个业务方法需要声明事务管理，则需要声明10次，过于麻烦，而且需要修改业务方法的源码。基于以上的流程我们发现，该扩展流程完全符合AOP的基本规范，考虑使用SpringAOP的方式来对业务方法进行扩展，声明环绕通知，在环绕通知中声明事务管理代码，切点为要进行事务管理的业务方法。
但是我们又无法直接获取到SqlSession对象，造成无法在环绕通 知中声明事务管理代码，又发现事务管理的代码是重复的代码， 那么能不能让Spring官方给我们直接提供一个和Spring容器直 接整合好的事务管理类。答案是可以的。

理论图:

实现:

Spring的TX

概念:

编程式事务: 事务管理代码由程序员自己编写。
声明式事务: 事务管理代码由第三方直接提供，程序员直接将其组装到功能中即可。

[2] SpringTX的使用流程
① 导入相关jar包
i. SpringIOC的jar
ii. SpringAOP的jar
iii. SpringTX的jar
iv. Spring整合Mybatis的jar
v. Mybatis的jar
vi. 数据库的驱动的jar
② 搭建Spring整合Mybatis的项目
③ 在applicationcontext.xml文件中配置事务管理bean
④ 在applicationcontext.xml文件中配置业务层bean
⑤ 在applicationcontext.xml文件中配置事务管理切面
⑥ 正常编写代码完成功能开发。

SpringTX的使用代码示例

[1] 在数据库中创建账户信息表(银行转账)

[2] 在web项目中导入相关的jar文件

[3] 搭建Spring整合Mybatis开发基板
① 在src下创建MVC包结构
② 在src下创建并配置applicationcontext.xml
③ 在web.xml文件中配置Spring的资源

[4] 声明mapper层完成银行转账的数据库操作
① 在mapper包下创建AccountMapper接口并声明转账方法

② 在AccountMapper的数据库操作方法上使用注解声明SQL语句

[5] 声明业务层方法完成银行转账
① 在service层中声明接口AccountService，并声明转账方 法。

② 在service层下创建包impl,并声明接口的实现类AccountServiceImpl,并完成转账业务方法功能。

[6] 在controller层声明类TestAccount测试银行转账功能

[7] 在applicationcontext.xml文件中配置Spring的事务管理(重点掌握)

声明式事务中属性解释

1. name=”” 哪些方法需要有事务控制
   1.1 支持*通配符

2. readonly=”boolean” 是否是只读事务.
   2.1 如果为true,告诉数据库此事务为只读事务.数据化优化,会对性能有一定提升,所以只要是查询的方法,建议使用此数据.
   2.2 如果为false(默认值),事务需要提交的事务.建议新增,删除,修改.

3. propagation 控制事务传播行为.
   3.1 当一个具有事务控制的方法被另一个有事务控制的方法调用后,需要如何管理事务(新建事务?在事务中执行?把事务挂起?报异常?)
   3.2 REQUIRED (默认值): 如果当前有事务,就在事务中执行,如果当前没有事务,新建一个事务.
   3.3 SUPPORTS:如果当前有事务就在事务中执行,如果当前没有事务,就在非事务状态下执行.
   3.4 MANDATORY:必须在事务内部执行,如果当前有事务,就在事务中执行,如果没有事务,报错.
   3.5 REQUIRES_NEW:必须在事务中执行,如果当前没有事务,新建事务,如果当前有事务,把当前事务挂起.
   3.6 NOT_SUPPORTED:必须在非事务下执行,如果当前没有事务,正常执行,如果当前有事务,把当前事务挂起.
   3.7 NEVER:必须在非事务状态下执行,如果当前没有事务,正常执行,如果当前有事务,报错.
   3.8 NESTED:必须在事务状态下执行.如果没有事务,新建事务,如果当前有事务,创建一个嵌套事务.

4.isolation=”” 事务隔离级别
4.1 在多线程或并发访问下如何保证访问到的数据具有完整性的.
4.2 脏读:
4.2.1 一个事务(A)读取到另一个事务(B)中未提交的数据,另一个事务中数据可能进行了改变,此时A事务读取的数据可能和数据库中数据是不一致的,此时认为数据是脏数据,读取脏数据过程叫做脏读.
4.3 不可重复读:
4.3.1 主要针对的是某行数据.(或行中某列)
4.3.2 主要针对的操作是修改操作.
4.3.3 两次读取在同一个事务内
4.3.4 当事务A第一次读取事务后,事务B对事务A读取的数据进行修改,事务A中再次读取的数据和之前读取的数据不一致,过程不可重复读.
4.4 幻读:
4.4.1 主要针对的操作是新增或删除
4.4.2 两次事务的结果.
4.4.3 事务A按照特定条件查询出结果,事务B新增了一条符合条件的数据.事务A中查询的数据和数据库中的数据不一致的,事务A好像出现了幻觉,这种情况称为幻读.
4.5 DEFAULT: 默认值,由底层数据库自动判断应该使用什么隔离界别
4.6 READ_UNCOMMITTED: 可以读取未提交数据,可能出现脏读,不重复读,幻读.
4.6.1 效率最高.
4.7 READ_COMMITTED:只能读取其他事务已提交数据.可以防止脏读,可能出现不可重复读和幻读.
4.8 REPEATABLE_READ: 读取的数据被添加锁,防止其他事务修改此数据,可以防止不可重复读.脏读,可能出现幻读.
4.9 SERIALIZABLE: 排队操作,对整个表添加锁.一个事务在操作数据时,另一个事务等待事务操作完成后才能操作这个表.
4.9.1 最安全的
4.9.2 效率最低的.

5.rollback-for=”异常类型全限定路径”
5.1 当出现什么异常时需要进行回滚
5.2 建议:给定该属性值.
5.2.1 手动抛异常一定要给该属性值.

6.no-rollback-for=””
6.1 当出现什么异常时不滚回事务.

SpringBoot中AOP事务配置

在SpringBoot里面可以直接导入 Spring 的配置文件，同时大部分的开发者都是基于配置文件的形式进行事务定义的,但是如果真的要做一个符合于 SpringBoot应用开发,那么就需要考虑避免XML配置文件的出现，所以直接基于Bean的模式来实现AOP事务配置。
1、【microboot-database子模块】编写一个事务配置类

package com.yootk.config;import org.aspectj.weaver.patterns.HasThisTypePatternTriedToSneakInSomeGenericOrParameterizedTypePatternMatchingStuffAnywhereVisitor;
import org.springframework.aop.Advisor;
import org.springframework.aop.aspectj.AspectJExpressionPointcut;
import org.springframework.aop.support.DefaultPointcutAdvisor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionManager;
import org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource;
import org.springframework.transaction.interceptor.RuleBasedTransactionAttribute;
import org.springframework.transaction.interceptor.TransactionAttribute;
import org.springframework.transaction.interceptor.TransactionInterceptor;import java.util.HashMap;
import java.util.Map;public class TransactionConfig { // 事务配置类private static final int TRANSACTION_METHOD_TIMEOUT = 5; // 事务处理的超时时间private static final String AOP_POINTCUT_EXPRESSION = "execution (* com.yootk..service.*.*(..))";@Autowiredprivate TransactionManager transactionManager; // 事务管理器@Bean("txAdvice")public TransactionInterceptor transactionInterceptorConfig() {// 配置数据读取事务规则RuleBasedTransactionAttribute readOnlyAttribute = new RuleBasedTransactionAttribute();readOnlyAttribute.setReadOnly(true); // 只读事务readOnlyAttribute.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED); // 非事务运行// 配置了数据更新事务规则RuleBasedTransactionAttribute requiredAttribute = new RuleBasedTransactionAttribute();requiredAttribute.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); // 事务开启requiredAttribute.setTimeout(TRANSACTION_METHOD_TIMEOUT); // 事务处理超时时间// 配置所有要进行事务处理的方法名称定义Map<String, TransactionAttribute> transactionAttributeMap = new HashMap<>();transactionAttributeMap.put("add*", requiredAttribute);transactionAttributeMap.put("edit*", requiredAttribute);transactionAttributeMap.put("delete*", requiredAttribute);transactionAttributeMap.put("list*", readOnlyAttribute);transactionAttributeMap.put("get*", readOnlyAttribute);NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();source.setNameMap(transactionAttributeMap); // 配置方法名称的映射TransactionInterceptor interceptor = new TransactionInterceptor(transactionManager, source);return interceptor;}@Bean("txAdvisor")public Advisor transactionAdvisor(@Autowired TransactionInterceptor interceptor) {AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();pointcut.setExpression(AOP_POINTCUT_EXPRESSION);return new DefaultPointcutAdvisor(pointcut, interceptor);}
}

2、【microboot-database子模块】既然已经创建好了事务相关处理类，那么下面就在IMemberService 业务接口里面扩充一个方法。这个方法有可能会产生异常。

package com.yootk.service;public interface IMemberService {public boolean addBatch(String ... mid); // 批量数据增加
}

package com.yootk.service.impl.impl;import com.yootk.dao.IMemberDAO;
import com.yootk.service.IMemberService;
import com.yootk.vo.Member;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class MemberServiceImpl implements IMemberService {@Autowiredprivate IMemberDAO memberDAO;@Overridepublic boolean addBatch(String... mid) {for (String id : mid) {Member vo = new Member();vo.setMid(id); // 如果id重复则会出现更新异常vo.setName("老李");this.memberDAO.insert(vo);}return true;}
}

3、【microboot-database子模块】在实现类中进行数据的增加:

package com.yootk.test;import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yootk.StartSpringBootDatabaseApplication;
import com.yootk.service.IMemberService;
import com.yootk.vo.Member;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import org.springframework.test.context.web.WebAppConfiguration;import java.util.Date;
import java.util.Set;@ExtendWith(SpringExtension.class) // 使用JUnit5测试工具
@WebAppConfiguration // 启动WEB运行环境
@SpringBootTest(classes = StartSpringBootDatabaseApplication.class) // 配置程序启动类
public class TestMemberService { // 编写测试类@Autowiredprivate IMemberService memberService;@Testpublic void testAddBatchRepeatID() { //传递数据库中已有的idthis.memberService.addBatch("muyan", "yootk", "lixinghua");}@Testpublic void testAddBatchNoRepeatID() {  //传递数据库中没有有的idthis.memberService.addBatch("muyan-happy", "yootk-happy", "lixinghua-happy"");}
}

4、【程序执行结果】

testAddBatchRepeatID

testAddBatchNoRepeatID
加入成功