• Spring 事务和事务传播机制


    目录

    🐇今日良言:生命只有一次,你要活的畅快淋漓

    🐇一、Sping 事务

    1.Spring 中事务的实现

    2.Spring 中事务隔离级别

    🐇二、Spring 事务传播机制

    1.基本概念

    2.详细介绍


    🐇今日良言:生命只有一次,你要活的畅快淋漓

    🐇一、Sping 事务

    1.Spring 中事务的实现

    在MySQL中也有事务,如下链接是博主之前写的关于MySQL事务的博客:

    如何理解数据库事务?_程序猿小马的博客-CSDN博客

    事务就是逻辑上的一组操作,组成这组操作的各个单元,要么全部成功,要么全部失败。

    Spring 中的事务分为两类:

    1).编程式事务(手动写代码)

    代码如下:

    1. @RestController
    2. @RequestMapping("/user")
    3. public class UserController {
    4. // 编程式事务
    5. @Autowired
    6. private UserService userService;
    7. @Autowired
    8. private DataSourceTransactionManager transactionManager;
    9. @Autowired
    10. private TransactionDefinition definition;
    11. @RequestMapping("/del")
    12. public int del(Integer id) {
    13. if (id == null || id <= 0) {
    14. return 0;
    15. }
    16. // 开启事务
    17. TransactionStatus status = transactionManager.getTransaction(definition);
    18. // 业务操作 删除用户
    19. int result = userService.del(id);
    20. System.out.println("删除ID 操作已经执行成功");
    21. // 2.提交事务
    22. transactionManager.commit(status);
    23. return result;
    24. }
    25. }

    Spring 手动操作事务和MySQL 操作事务类似,有三个重要操作:

    开启事务     提交事务   回滚事务

    SpringBoot  内置了两个对象,DataSourceTransactionManager 用来开启事务(获取事务)、提交或者回滚事务,TransactionDefinition 是事务的属性,在获取事务的时候需要将 TransactionDefinition 传递进去,从而获得一个事务 TransactionStatus。

     UserService 中代码:

    1. @Service
    2. public class UserService {
    3. @Autowired
    4. private UserMapper userMapper;
    5. public int del(Integer id) {
    6. return userMapper.del(id);
    7. }
    8. }

    UserMapper 中代码:

    1. @Mapper
    2. public interface UserMapper {
    3. int del(@Param("id")Integer id);
    4. }

    UserMapper.xml 中的代码:

    1. "1.0" encoding="UTF-8"?>
    2. mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    3. <mapper namespace="com.example.demo.mapper.UserMapper">
    4. <delete id="del">
    5. delete from user where id = #{id}
    6. delete>
    7. mapper>

    目录结构如下:

    在进行操作之前,先查看数据库user表中的数据:

     启动项目:

    输入URL:

     此时再次查看user表中数据,会发现 id为3的数据被删除了。

    上述是提交事务,接下来查看回滚事务。

    代码如下:

    1. @RestController
    2. @RequestMapping("/user")
    3. public class UserController {
    4. // 编程式事务
    5. @Autowired
    6. private UserService userService;
    7. @Autowired
    8. private DataSourceTransactionManager transactionManager;
    9. @Autowired
    10. private TransactionDefinition definition;
    11. @RequestMapping("/del")
    12. public int del(Integer id) {
    13. if (id == null || id <= 0) {
    14. return 0;
    15. }
    16. // 开启事务
    17. TransactionStatus status = transactionManager.getTransaction(definition);
    18. // 业务操作 删除用户
    19. int result = userService.del(id);
    20. System.out.println("删除ID 操作已经执行成功");
    21. // 2.提交事务
    22. // transactionManager.commit(status);
    23. // 回滚事务
    24. transactionManager.rollback(status);
    25. return result;
    26. }
    27. }

    启动项目:

    输入URL:

     此时查看user表中记录数据,会发现id为2的数据没有被删除:

     查看IDEA控制台打印的信息:

     数据已经被删除了,但是事务回滚了,所以删除的数据被恢复成初始状态。

    2).声明式事务(使用注解)

    声明式事务的实现很简单,只需要在需要的⽅法上添加 @Transactional 注解就可以实现了,⽆需⼿动 开启事务和提交事务,进⼊⽅法时⾃动开启事务,⽅法执⾏完会⾃动提交事务,如果中途发⽣了没有处 理的异常会⾃动回滚事务

    代码如下:

    1. @RestController
    2. @RequestMapping("/user")
    3. public class UserController {
    4. @Autowired
    5. private UserService userService;
    6. @Transactional
    7. @RequestMapping("/del")
    8. public int del(Integer id) {
    9. if (id == null || id <= 0) {
    10. return 0;
    11. }
    12. int result = userService.del(id);
    13. return result;
    14. }
    15. }

    进行操作之前,先查看User表中数据:

    此时启动项目,输入URL:

    查看 user 表中数据:  

    id 为2 的数据被删除。

    当加了 Transactional 注解以后,程序执行正常情况下,是不会回滚事务的,只有当发生异常以后才会回滚事务。

    添加一行会发生异常的代码:

    此时启动项目,输入URL:

    状态码500表示 服务器内部出现错误,查看IDEA控制台打印的信息:

     删除操作执行了,但是这里发生了除0的异常,此时查看user表中数据,会发现:

    id 为1的数据并没有被删除,事务发生了回滚。

    Transactional 注解的作用范围:

    @Transactional 可以用来修饰方法或类

    修饰方法时:需要注意只能应用到public方法上,否则不生效。

    修饰类时,表明该注解对该类中所有的public 方法都生效。

    Transactional 参数如下:

    需要注意的是:@Transactional 在异常被捕获的情况下,不会进行事务回滚。

    修改Usercontroller代码如下:

    1. @RestController
    2. @RequestMapping("/user")
    3. public class UserController {
    4. @Autowired
    5. private UserService userService;
    6. @Transactional
    7. @RequestMapping("/del")
    8. public int del(Integer id) {
    9. if (id == null || id <= 0) {
    10. return 0;
    11. }
    12. int result = 0;
    13. try {
    14. result = userService.del(id);
    15. int num = 10 / 0;
    16. } catch (Exception e) {
    17. e.printStackTrace();
    18. }
    19. return result;
    20. }
    21. }

    启动项目,输入URL:

    此时查看 user 表中数据:

     id 为1的数据被删除了。

    查看IDEA控制台信息:

    对于上述这种情况(try catch 捕获了异常,事务不会自动回滚),有两种方案可以解决:

    1).将异常抛出去,让spring感知到异常,此时就会自动回滚异常

    代码如下:

    1. @RestController
    2. @RequestMapping("/user")
    3. public class UserController {
    4. @Autowired
    5. private UserService userService;
    6. @Transactional
    7. @RequestMapping("/del")
    8. public int del(Integer id) {
    9. if (id == null || id <= 0) {
    10. return 0;
    11. }
    12. int result = 0;
    13. try {
    14. result = userService.del(id);
    15. int num = 10 / 0;
    16. } catch (Exception e) {
    17. throw e;
    18. }
    19. return result;
    20. }
    21. }

    查看user表中数据:

    启动项目,输入URL:

     服务器内部出现错误。

    查看IDEA控制台打印信息:

    查看user表中数据:

     id 为5的数据并未被删除。

    2).通过代码的方式手动回滚事务。

    代码如下:

    1. @RestController
    2. @RequestMapping("/user")
    3. public class UserController {
    4. @Autowired
    5. private UserService userService;
    6. @Transactional
    7. @RequestMapping("/del")
    8. public int del(Integer id) {
    9. if (id == null || id <= 0) {
    10. return 0;
    11. }
    12. int result = 0;
    13. try {
    14. result = userService.del(id);
    15. int num = 10 / 0;
    16. } catch (Exception e) {
    17. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
    18. }
    19. return result;
    20. }
    21. }

    此时查看最终效果也是id为5的数据未被删除。

    2.Spring 中事务隔离级别

    在MySQL 中事务的隔离级别有四个,但是在Spring 中事务的隔离级别有五个:

    1). Isolation.DEFAULT:以连接的数据库的事务隔离级别为主。

    2). Isolation.READ_UNCOMMITTED:读未提交,可以读取到未提交的事务,存在脏读。

    3). Isolation.READ_COMMITTED:读已提交,只能读取到已经提交的事务,解决了脏读,存在不可重复读。

    4). Isolation.REPEATABLE_READ:可重复读,解决了不可重复读,但存在幻读(MySQL默认级别)。

    5). Isolation.SERIALIZABLE:串⾏化,可以解决所有并发问题,但性能太低。

    可以在添加@Transactional 注解的时候设置 参数,不同的参数对应不同的Spring 隔离级别:


    🐇二、Spring 事务传播机制

    1.基本概念

    Spring 事务传播机制定义了多个包含事务的方法相互调用时,事务是如何在这些方法间进行传播的。

    事务隔离级别是保证多个事务并发执行的可控性的(稳定性的),而事务传播机制是保证一个事务在多个调用方法间的可控性的(稳定性的)。

    2.详细介绍

    Spring 事务传播机制包含以下7种:

    1).Propagation.REQUIRED:

       默认的事务传播机制,表示如果当前存在事务,则加入当前事务;如果当前没有事务,就新建一个事务。

    2).Propagation.SUPPORTS:表示如果当前存在事务,则加入当前事务;如果当前没有事务,就以非事务的方式继续运行。

    3).Propagation.MANDATORY:表示如果当前存在事务,则加入当前事务;如果当前没有事务,就抛出异常。

    4).Propagation.REQUIRES_NEW:表示创建一个新的事务,如果当前存在事务,则把当前事务挂起。

    5).Propagation.NOT_SUPPORTED:表示当前方法以非事务方式执行,如果当前存在事务,则挂起该事务。

    6).Propagation.NEVER:表示当前方法以非事务方式执行,如果当前存在事务,就抛出异常。

    7).Propagation.NESTED:如果当前存在事务,则创建一个新的事务作为当前事务的嵌套事务来执行,如果当前没有事务,效果相当于REQUIRED.

    可以根据是否支持当前事务将以上7种分为以下3类:

     

     嵌套事务(NESTED)和 加入事务(REQUIRED) 的区别:

    1).整个事务如果全部执行成功,二者的结果是一样的。

    2).如果事务执行到一半失败了,那么加入事务整个事务会全部回滚;而嵌套事务会局部回滚,不会影响上一个方法中执行的结果。

    嵌套事务之所以能够实现局部回滚,是因为事务中有一个保存点(savepoint)的概念,嵌套事务进入之后相当于新建了一个保存点,而回滚时只回滚到当前保存点,因此之前的事务是不会受到影响的。


  • 相关阅读:
    RabbitMQ详细使用
    HTML5七夕情人节表白网页制作【爱心雨(满屏爱心飘落)】HTML+CSS+JavaScript
    Flink1.14新特性介绍及尝鲜
    linux之网络配置
    CSAPP深入理解计算机系统-笔记1
    java计算机毕业设计惠购网站MyBatis+系统+LW文档+源码+调试部署
    Linux系统设置防火墙
    储能领域 / 通讯协议 / 技术栈 等专有名字集锦——主要收集一些储能领域的专有名词,以及相关的名词
    svn项目同步到gitLab
    第 45 届国际大学生程序设计竞赛(ICPC)亚洲区域赛(银川),签到题5题
  • 原文地址:https://blog.csdn.net/qq_54469537/article/details/130762822