泉州建设系统培训中心网站,微信公众号运营推广方案,吃什么补肾最快,安徽智能网站建设推荐前言#x1f36d; ❤️❤️❤️SSM专栏更新中#xff0c;各位大佬觉得写得不错#xff0c;支持一下#xff0c;感谢了#xff01;❤️❤️❤️ Spring Spring MVC MyBatis_冷兮雪的博客-CSDN博客 在Spring框架中#xff0c;事务管理是一种用于维护数据库操作的一致性和…前言 ❤️❤️❤️SSM专栏更新中各位大佬觉得写得不错支持一下感谢了❤️❤️❤️ Spring Spring MVC MyBatis_冷兮雪的博客-CSDN博客 在Spring框架中事务管理是一种用于维护数据库操作的一致性和完整性的机制。Spring事务管理提供了灵活的方式来处理事务包括事务的创建、提交、回滚以及事务的传播行为。
书接上回Spring事务和事务传播机制1_热爱编程的林兮的博客-CSDN博客
2、Spring 中设置事务隔离级别
Spring 中事务隔离级别可以通过 Transactional 中的 isolation 属性进行设置具体操作如下图所示 Ⅰ、MySQL 事务隔离级别有 4 种
1、READ UNCOMMITTED: 读未提交也叫未提交读该隔离级别的事务可以看到其他事务中未提交的数据。该隔离级别因为可以读取到其他事务中未提交的数据而未提交的数据可能会发生回滚因此我们把该级别读取到的数据称之为脏数据把这个问题称之为脏读
2、READ COMMITTED: 读已提交也叫提交读该隔离级别的事务能读取到已经提交事务的数据因此它不会有脏读问题。但由于在事务的执行中可以读取到其他事务提交的结果所以在不同时间的相同 SQL查询中可能会得到不同的结果这种现象叫做不可重复读。3、REPEATABLE READ:可重复读是MySQL 的默认事务隔离级别它能确保同一事务多次查询的结果一致。但也会有新的问题比如此级别的事务正在执行时另一个事务成功的插入了某条数据但因为它每次查询的结果都是一样的所以会导致查询不到这条数据自己重复插入时又失败(因为唯一约束的原因)。明明在事务中查询不到这条信息但自己就是插入不进去这就叫幻读(Phantom Read)。4、SERIALIZABLE: 序列化事务最高隔离级别它会强制事务排序使之不会发生冲突从而解决了脏读、不可重复读和幻读问题但因为执行效率低所以真正使用的场景并不多。
事务隔离级别脏读不可重复读幻读读未提交(READ UNCOMMITTED) √√√读已提交(READ COMMITTED)×√√可重复读(REPEATABLE READ)××√串行化(SERIALIZABLE)××× 脏读:一个事务读取到了另一个事务修改的数据之后后一个事务又进行了回滚操作从而导致第一个事务读取的数据是错误的。不可重复读:一个事务两次查询得到的结果不同因为在两次查询中间有另一个事务把数据修0改了。幻读:一个事务两次查询中得到的结果集不同因为在两次查询中另一个事务有新增了一部分数据。 在数据库中通过以下 SQL 查询全局事务隔离级别和当前连接的事务隔离级别
select global.tx_isolation,tx_isolation; 以上 SQL 的执⾏结果如下 Ⅱ、Spring 事务隔离级别有 5 种
而Spring 中事务隔离级别包含以下 5 种
Isolation.DEFAULT以连接的数据库的事务隔离级别为主。 Isolation.READ_UNCOMMITTED读未提交可以读取到未提交的事务存在脏读。 Isolation.READ_COMMITTED读已提交只能读取到已经提交的事务解决了脏读存在不可重复读。 Isolation.REPEATABLE_READ可重复读解决了不可重复读但存在幻读MySQL默认级别。 Isolation.SERIALIZABLE串行化可以解决所有并发问题但性能太低。
从上述介绍可以看出相⽐于 MySQL 的事务隔离级别Spring 的事务隔离级别只是多了一个
Isolation.DEFAULT以数据库的全局事务隔离级别为主。
Spring 中事务隔离级别只需要设置 Transactional ⾥的 isolation 属性即可具体实现代码如下
RequestMapping(/save)Transactional(isolation Isolation.SERIALIZABLE)public Object save(UserInfo user) {// 业务实现}
四、Spring 事务传播机制
1、事务传播机制是什么
Spring 事务传播机制定义了多个包含了事务的方法相互调用时事务是如何在这些方法间进行传递的。
2、为什么需要事务传播机制
事务隔离级别是保证多个并发事务执行的可控性的稳定性的而事务传播机制是保证⼀个事务在多个调用方法间的可控性的稳定性的。 例子像新冠病毒⼀样它有不同的隔离方式酒店隔离还是居家隔离是为了保证疫情可控然而在每个人的隔离过程中会有很多个执行的环节比如酒店隔离需要负责人员运送、物品运送、消杀原生活区域、定时核算检查和定时送餐等很多环节而事务传播机制就是保证⼀个事务在传递过程中是可靠性的回到本身案例中就是保证每个人在隔离的过程中可控的。 事务隔离级别解决的是多个事务同时调用⼀个数据库的问题如下图所示 而事务传播机制解决的是⼀个事务在多个节点方法中传递的问题如下图所示 3、事务传播机制有哪些
Spring 事务传播机制包含以下 7 种 Propagation.REQUIRED默认的事务传播级别它表示如果当前存在事务则加入该事务如果当前没有事务则创建⼀个新的事务。 Propagation.SUPPORTS如果当前存在事务则加入该事务如果当前没有事务则以非事务的方式继续运行。 Propagation.MANDATORYmandatory强制性如果当前存在事务则加入该事务如果当前没有事务则抛出异常。 Propagation.REQUIRES_NEW表示创建⼀个新的事务如果当前存在事务则把当前事务挂起。也就是说不管外部方法是否开启事务Propagation.REQUIRES_NEW 修饰的内部⽅法会新开启自己的事务且开启的事务相互独立互不干扰。 Propagation.NOT_SUPPORTED以非事务方式运行如果当前存在事务则把当前事务挂起。 Propagation.NEVER以非事务方式运行如果当前存在事务则抛出异常。 Propagation.NESTED如果当前存在事务则创建⼀个事务作为当前事务的嵌套事务来运行如果当前没有事务则该取值等价于 PROPAGATION_REQUIRED。 以上 7 种传播行为可以根据是否支持当前事务分为以下 3 类 以情侣关系为例来理解以上分类 4、Spring 事务传播机制使用和各种场景演示 Ⅰ、支持当前事务REQUIRED 以下代码实现中先开启事务先成功插入一条用户数据然后再执行日志报错而在日志报错是发生了异常观察 propagation Propagation.REQUIRED 的执行结果。 Autowiredprivate UserService userService;
Autowiredprivate LogService logService;Transactional// 声明式事务自动提交RequestMapping(/insert)public Integer insert(UserInfo userInfo) {// 非空效验if (userInfo null || !StringUtils.hasLength(userInfo.getUsername()) ||!StringUtils.hasLength(userInfo.getPassword())) {return 0;}// 添加用户int result userService.add(userInfo);if (result0){//日志logService.add();}/*try {int num 10 / 0;} catch (Exception e) {System.out.println(e.getMessage());*//*throw e;*//*TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();}*/return result;}UserService 实现代码如下 Service
public class UserService {Autowiredprivate UserMapper userMapper;Transactional(propagation Propagation.REQUIRED)public Integer add(UserInfo userInfo) {int result userMapper.add(userInfo);System.out.println(用户添加 result);return result;}} LogService 实现代码如下 RestController
public class LogService {//捣乱设置一个算数异常Transactional(propagation Propagation.REQUIRED)public int add() {int num 10 / 0;return 1;}
}执行结果程序报错数据库没有插入任何数据。 执行了SQL语句都是数据库中没有添加新用户事务回滚了 执行流程描述 UserService 中的保存方法正常执行完成。LogService 保存日志程序报错因为使用的是 Controller 中的事务所以整个事务回滚。数据库中没有插入任何数据也就是步骤1中的用户插入方法也回滚了。 Ⅱ、不支持当前事务REQUIRES_NEW
UserController 类中的代码不变将添加用户和添加日志的方法修改为 REQUIRES_NEW 不支持当前事务重新创建事务观察执行结果
RestControllerpublic class UserController {Resourceprivate UserService userService;Resourceprivate LogService logService;RequestMapping(/save)Transactional(propagation Propagation.REQUIRED)public Object save(UserInfo userInfo) {// 插⼊⽤户操作userService.save(userInfo);// 插⼊⽇志logService.saveLog(⽤户插⼊ userInfo.getName());return true;}}
UserService 实现代码如下
Servicepublic class UserService {Resourceprivate UserMapper userMapper;Transactional(propagation Propagation.REQUIRED)public int save(UserInfo userInfo) {System.out.println(执⾏ save ⽅法.);return userMapper.save(userInfo);}}
LogService 实现代码如下
Servicepublic class LogService {Transactional(propagation Propagation.REQUIRED)public int saveLog(String content) {// 出现异常int i 10 / 0;return 1;}} 程序执行结果User 表中成功插入了数据LogService 保存日志程序报错但没影响 UserController 中的事务。 Ⅲ、不支持当前事务NEVER 抛异常 UserController 实现代码 RequestMapping(/save)Transactionalpublic Object save(UserInfo userInfo) {// 插⼊⽤户操作userService.save(userInfo);return true;} UserService 实现代码 Transactional(propagation Propagation.NEVER)public int save(UserInfo userInfo) {System.out.println(执⾏ save ⽅法.);return userMapper.save(userInfo);} 程序执行报错用户表未添加任何数据。 Ⅳ、NESTED 嵌套事务 UserController 实现代码如下 RequestMapping(/save)Transactionalpublic Object save(UserInfo userInfo) {// 插⼊⽤户操作userService.save(userInfo);return true} UserService 实现代码如下 Transactional(propagation Propagation.NESTED)public int save(UserInfo userInfo) {int result userMapper.save(userInfo);System.out.println(执⾏ save ⽅法.);// 插⼊⽇志logService.saveLog(⽤户插⼊ userInfo.getName());return result;} LogService 实现代码如下 Transactional(propagation Propagation.NESTED)public int saveLog(String content) {// 出现异常int i 10 / 0;return 1;} 最终执行结果用户表和日志表都没有添加任何数据。 嵌套事务和加入事务有什么区别 整个事务如果全部执行成功二者的结果是⼀样的。 如果事务执行到一半失败了那么加入事务整个事务会全部回滚而嵌套事务会局部回滚不会影响上一个方法中执行的结果
