轻松学习 Spring 事务

文章目录

• 一. Spring事务简介
• 二. Spring事务使用
• • 1. 编程式事务
  • 2. 声明式事务
  • 三. @Transactional的使用
  • • 1. 参数作用
    • 2. 事务失效的场景
    • 3. @Transactional工作原理
    • 四. Spring 事务的隔离级别
    • 五. Spring事务��播机制

      一. Spring事务简介

      在之前的博客已经介绍了在 Spring 环境中整合 mybatis 完成数据库的增删查改操作，在正常情况下，操作数据库是没有问题的，但是当一个业务需要并发式的操作数据库，并且需要涉及到修改，插入，删除操作就可能会有问题，如转账业务，其实是有两个步骤，第一步从 A 账户扣钱，第二步在 B 账户中加钱。

      如果第一步顺利执行的，在执行完成第二步前，程序发生了异常， 此时第二个操作就不能够正常执行了，这就会是很严重的事故了，致使 A 的钱少了，但 B 的钱没有增多，无论是用户还是我们都是不能容忍这样的 bug 的。

      为了解决这个问题，Spring 引入了事务管理的机制，事务的作用是保证执行一组数据库操作的时候，要么全部失败，要不全部成功，即同成功或同失败。

      那也就是在程序发生异常的时候，回滚所有已经成功数据库操作，这样就算这一次转账失败了，也不会给客户和商家带来损失。

      Spring 中事务的作用是保证在数据层或业务层执行的一系列数据库操作同成功或同失败。

      二. Spring事务使用

      Spring 中的事务分为两类：

      1. 编程式事务（手动操作）。
      2. 声明式事务（自动提交事务）。

      1. 编程式事务

      SpringBoot 内置了两个对象，DataSourceTransactionManager用来获取事务（开启事务、提交事务、回滚事务）；ransactionDefinition是事务的属性，在获取事务时，需要将TransactionDefinition传递进去获取一个TransactionStatus。

      Controller，Service，Mapper 各层演示代码如下：

      package com.example.demo.controller;import com.example.demo.model.UserInfo;import com.example.demo.service.UserService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.jdbc.datasource.DataSourceTransactionManager;import org.springframework.transaction.TransactionDefinition;import org.springframework.transaction.TransactionStatus;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;@RestController@RequestMapping("/user")public class UserController {    @Autowired    private UserService userService;    // JDBC 事务管理器    @Autowired    private DataSourceTransactionManager transactionManager;    // 定义事务属性    @Autowired    private TransactionDefinition transactionDefinition;    @RequestMapping("/add")    public int del(Integer id) {        UserInfo userinfo = new UserInfo();        userinfo.setUsername("zhaoliu");        userinfo.setPassword("123");        if(userinfo != null) {            //开启事务            TransactionStatus transactionStatus =                    transactionManager.getTransaction(transactionDefinition);            //删除用户业务操作            int result = userService.add(userinfo);            System.out.println("受影响行数: " + result);            // 提交事务/回滚事务           //  transactionManager.commit(transactionStatus); //提交事务            transactionManager.rollback(transactionStatus); //回滚事务        }        return 0;    }}

      数据库 userinfo 表中现有数据如下：

      启动程序，在浏览器地址栏中进行 url 的访问，结果如下：

      控制台显示的结果是插入成功的，此时再看数据库数据是否有变化。

      我们可以发现，数据库中数据是没有变化的，说明在插入数据后，事务成功的进行了回滚操作，但是这样的方式是比较繁琐的，下面介绍更简单的声明式事务。

      2. 声明式事务

      声明式事务我们只需要在方法上加上@Transactional注解就可以实现，此时无需我们手动进行开启事务和提交事务，进入方法就会自动开启事务，执行完毕自动提交，发生异常后会自动回滚事务。

      package com.example.demo.controller;import com.example.demo.model.UserInfo;import com.example.demo.service.UserService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.transaction.annotation.Transactional;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;@RequestMapping("/user")@RestControllerpublic class UserController2 {    @Autowired    private UserService userService;    @Transactional    @RequestMapping("/add")    public int add() {        UserInfo userinfo = new UserInfo();        userinfo.setUsername("zhaoliu");        userinfo.setPassword("123");        // 非空判断        if (userinfo == null) {            return 0;        }        // 调用 service 执行添加        int result = userService.add(userinfo);        System.out.println("受影响行数: " + result);        // 将结果返回给前端        return result;    }}

      目前数据库数据：

      访问结果：

      此时数据库中就成功插入了一条数据，这种情况是没有异常的情况下，代码执行成功后自动进行了commit。

      我们来在业务中加上一段异常代码：

      @RestController@RequestMapping("/user2")public class UserController2 {    @Autowired    private UserService userService;    @Transactional    @RequestMapping("/del")    public int del(Integer id) {        if(id == null || id             return 0;        }        int result = userService.del(id);        int n = 1 / 0; //异常业务        return result;    }}    @Autowired    private UserService userService;    @Transactional(propagation = Propagation.REQUIRED)    @RequestMapping("/add")    public int add() {        UserInfo userinfo = new UserInfo();        userinfo.setUsername("zhaoliu");        userinfo.setPassword("123");        // 非空判断        if (userinfo == null) {            return 0;        }        int result = userService.add(userinfo);        result +=userService.insert(userinfo);        System.out.println("受影响行数: " + result);        return result;    }}@Servicepublic class UserService {    @Autowired    private UserMapper userMapper;    @Transactional(propagation = Propagation.NESTED)    public int add(UserInfo userinfo) {        int result = userMapper.add(userinfo);        System.out.println("add result - " + result);        return result;    }    @Transactional(propagation = Propagation.NESTED)    public int insert(UserInfo userInfo) {        int result = userMapper.add(userInfo);        System.out.println("insert result ->" + result);        try {            int num = 10 / 0;        } catch (Exception e) {            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();        }        return result;    }}

      访问结果：

      此时执行到Controller中的add会开启一个事务，其中调用的add和insert开始的是嵌套事务，嵌套事务如果发生了回滚，只会影响它自己的局部逻辑，而不影响全局。

      控制台显示的是成功插入了两条记录的，

      查看数据库只是成功插入了一条记录，这是因为insert逻辑中发生了回滚，但它不会影响其他部分的逻辑。

      要注意在嵌套事务中可能出现异常的部分要手动处理进行回滚，不能让异常抛出，否则会被全局代理感知到造成全局事务的整体回滚。

      嵌套事务之所以能够实现部分事务的回滚，是因为事务中有⼀个保存点（savepoint）的概念，嵌套事务进入之后相当于新建了⼀个保存点，而滚回时只回滚到当前保存点，因此之前的事务是不受影响的，这一点可以在 MySQL 的官方文档汇总找到相应的资料：网页链接 。

      嵌套事务（NESTED）和加入事务（REQUIRED ）的区别：

      • 整个事务如果全部执行成功，二者的结果是⼀样的。
      • 如果事务执行到⼀半失败了，那么加入事务整个事务会全部回滚；而嵌套事务会局部回滚，不会影响上⼀个方法中执行的结果。