Spring使用事务的两种方式

1. 为什么需要事务？

前面的博客对MySQL事务作讲解，事务就是将⼀组操作封装成⼀个执⾏单元（封装到⼀起），要么全部成功，要么全部失败。

比如，现在要实现转账操作：

第一步：张三账户 -500

第二步：李四账户+500

如果没有事务，第一步执行成功，然而第二步执行失败，那么张三的账户的500元就凭空消失了。而事务的引入就可以解决这个问题，让这一组操作要么一起成功，要么一起失败。

2.Spring中事务的实现

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

编程式事务（⼿动写代码操作事务）。
声明式事务（利⽤注解⾃动开启和提交事务)。

之前MySQL博客中，使用事务可以分为3个重要的操作：开启事务、提交事务、回滚事务，它们对应的操作命令如下：

-- 开启业务  (⼀组操作前开启事务)
start transaction;
-- 相关业务执行-- 提交事务  (这组操作全部成功, 提交事务)
commit;-- 回滚事务 (这组操作中间任何⼀个操作出现异常, 回滚事务)
rollback;

2.1 Spring编程式事务(手动)

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

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

SpringBoot 内置了两个对象，DataSourceTransactionManager ⽤来获取事务（开启事务）、提交或回滚事务的，⽽ TransactionDefinition 是事务的属性，在获取事务的时候需要将TransactionDefinition 传递进去从⽽获得⼀个事务 TransactionStatus。如图所示：

使用编程式事务代码如下：
代码结构：

controller：

@RestController
@RequestMapping("user")
public class UserController {@Autowiredprivate UserService userService;// JDBC 事务管理器@Resourceprivate DataSourceTransactionManager dataSourceTransactionManager;// 定义事务属性@Resourceprivate TransactionDefinition transactionDefinition;@PostMapping("/add")public String addUser(@RequestBody Userinfo user) {// 开启事务TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);userService.addUser(user);//提交事务dataSourceTransactionManager.commit(transactionStatus);//回滚事务//dataSourceTransactionManager.rollback(transactionStatus);return "User added successfully!";}
}

当执行提交事务，观察结果：

数据库：

发现我们程序执行成功并且事务提交完成，持久化到数据库中。

那么如果我们使用的是回滚代码，来添加用户tom，再来观察执行结果：

然而，数据却没有同步到数据库中，因为事务被我们回滚了：

以上代码虽然可以实现事务, 但操作也很繁琐, 有没有更简单的实现⽅法呢? --- 声明式事务

2.2 声明式事务@Transactional

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

代码实现：

注意：
我们⼀般会在业务逻辑层当中来控制事务, 因为在业务逻辑层当中, ⼀个业务功能可能会包含多个数据访问的操作. 在业务逻辑层来控制事务, 我们就可以将多个数据访问操作控制在⼀个事务范围内. 下面代码在Controller中书写, 只是为了⽅便演示学习.

@Transactional
@RestController
@RequestMapping("user")
public class UserController {@Autowiredprivate UserService userService;@PostMapping("/add")public String addUser(@RequestBody Userinfo user) {userService.addUser(user);return "User added successfully!";}
}

现在代码中是没有异常的，也就是实行玩添加业务后就提交了。添加 tom，观察执行结果：