@TOC

回顾事务

事务的本质就是某个操作要么都成功, 要么都失败
事务在项目开发中十分重要, 涉及到数据一致性和完整性问题, 不能马虎
事务的ACID原则

原子性
一致性
隔离性, 多个业务可能操作同一个资源, 防止数据损坏
持久性, 事务一旦发生, 无论系统发生什么问题, 结果都不会再被影响, 被持久的写到存储器中

Spring 中事务的实现

Spring 中的事务操作分为两类：

⼿动操作事务
声明式⾃动提交事务

在开始讲解它们之前，咱们先来回顾事务在 MySQL 中是如何使⽤的？

MySQL 中的事务使⽤（回顾）

事务在 MySQL 有 3 个重要的操作：

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

它们对应的操作命令如下：

-- 开启事务
start transaction;
-- 业务执⾏

-- 提交事务
commit;

-- 回滚事务
rollback;

Spring 编程式事务(手动操作)

Spring ⼿动操作事务和上⾯ MySQL 操作事务类似，它也是有 3 个重要操作步骤：

开启事务（获取事务）getTransaction
提交事务 commit
回滚事务 rollback

SpringBoot 内置了两个对象：

DataSourceTransactionManager ⽤来 获取事务（开启事务）、提交或回滚事务

TransactionDefinition 是 事务的属性

获取事务的时候需要将 TransactionDefinition 传递进去从⽽获得⼀个事务 TransactionStatus

实现代码如下：

@RestController
public class UserController {

    @Resource
    private UserService userService;

    // 注入 JDBC 事务管理器
    @Resource
    private DataSourceTransactionManager dataSourceTransactionManager;

    // 注入 定义事务属性
    @Resource
    private TransactionDefinition transactionDefinition;

    @RequestMapping("/sava")
    public Object save(User user) {
        // 开启事务
        TransactionStatus transactionStatus =
dataSourceTransactionManager
               .getTransaction(transactionDefinition);

        // 插⼊数据库
        int result = userService.save(user);

        // 提交事务
        dataSourceTransactionManager.commit(transactionStatus);

        // 回滚事务
        dataSourceTransactionManager.rollback(transactionStatus);

        return result;
   }

}

从上述代码可以看出，以上代码虽然可以实现事务，但操作也很繁琐，有没有更简单的实现⽅法呢？请 看下⾯声明式事务。

Spring 声明式事务（自动事务）

声明式事务的实现很简单，只需要在需要的⽅法上添加 @Transactional 注解就可以实现了

⽆需⼿动开启事务和提交事务，进⼊⽅法时⾃动开启事务，⽅法执⾏完会⾃动提交事务，如果中途发⽣了没有处理的异常会⾃动回滚事务

具体实现代码如下：

@RequestMapping("/save")
@Transactional //开启事务
public Object save(User user) {

  int result = userService.save(user);

  return result;

}

接下⾥使⽤以下代码，分别设置 @Transactional 注解和不设置 @Transactional

观察它们的执⾏区别：

开启事务时，如果代码运行时发生异常会会进行回滚
没有开启事务时，如果代码运行时发生异常不会进行回滚，代码依然会进行操作

@Transactional 作⽤范围

@Transactional 可以⽤来修饰⽅法或类：

修饰⽅法时：需要注意只能应⽤到 public ⽅法上，否则不⽣效。推荐此种⽤法。
修饰类时：表明该注解对该类中所有的 public ⽅法都⽣效。

@Transactional 参数说明

注意事项

@Transactional 在异常被捕获的情况下，不会进⾏事务⾃动回滚。

验证以下代码是否会发⽣事务回滚：

@RestController
public class UserController {
    @Resource
    private UserService userService;
    @RequestMapping("/save")
    @Transactional
    public Object save(User user) {
        // 插⼊数据库
        int result = userService.save(user);
        try {
            // 执⾏了异常代码(0不能做除数)
            int i = 10 / 0;
       } catch (Exception e) {
            System.out.println(e.getMessage());
       }
        return result;
   }
}

事务不会自动回滚解决⽅案

解决⽅案1：将捕获异常重新抛出

对于捕获的异常，事务是会⾃动回滚的

因此解决⽅案1就是可以将异常重新抛出，具体实现如下：

@RequestMapping("/save")
@Transactional(isolation = Isolation.SERIALIZABLE)
public Object save(User user) {
    // 插⼊数据库
    int result = userService.save(user);
    try {
        // 执⾏了异常代码(0不能做除数)
        int i = 10 / 0;
   } catch (Exception e) {
        System.out.println(e.getMessage());
        throw e; // 将异常重新抛出去

   }
    return result;
}

解决⽅案2：手动回滚事务

在⽅法中使⽤ TransactionAspectSupport.currentTransactionStatus( ) 可以得到当前的事务

设置回滚⽅法 setRollbackOnly 就可以实现回滚了

具体实现代码如下：

@RequestMapping("/save")
@Transactional(isolation = Isolation.SERIALIZABLE)
public Object save(User user) {
    // 插⼊数据库
    int result = userService.save(user);
    try {
        // 执⾏了异常代码(0不能做除数)
        int i = 10 / 0;
   } catch (Exception e) {
        System.out.println(e.getMessage());
        // ⼿动回滚事务
        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
   }
    return result;
}