目录
事务
回顾: 什么是事务
为什么需要事务
事务的操作
Spring事务的实现
Spring编程式事务(简单了解即可, 问就是基本不用)
观察事务提交
观察事务回滚
Spring声明式事务 @Transactional
@Transactional作用
事务
回顾: 什么是事务
定义: 事务是指逻辑上的一组操作, 构成这组操作的各个单元, 要么全部执行, 要么全部不执行.
为什么需要事务
一般在进行程序设计中, 我们一般都会用到事务.
比如当家人给我们转账(2000元)时, 共有两个操作: 家人扣款2000, 我们的账户增加2000元.
但在家人扣款之后, 出现了一个问题: 此时一位自信的挖掘机操作员把光缆给"不小心"挖断了.
然后这就导致我们账户增加余额的操作得不到落实 .
因此这里引入事务: 使得家人扣款和我们账户到账是同一个事务, 这时如果中间执行这个事务时,就会发生异常, 然后就会回滚, 恢复数据: 家人账户+2000.
事务的操作
事务的操作主要有三步:
1.开启事务start transaction(在一组操作之前开启事务).
2.提交事务: commit.(这组操作全部执行成功, 就会全部落实)
3.回滚: rollback(这中间任意一个操作出现异常, 就会回滚事务, 即恢复初始状态)
Spring事务的实现
Spring中的事务操作分为两类:
1.编程式事务(手动写代码操作事务)
2.声明式事务(利用注解操作事务)
我们通过一个简单的小项目来说明这个事务:
Spring编程式事务(简单了解即可, 问就是基本不用)
Spring手动操作事务和之前mysql操作事务类似.,有三个重要的操作步骤:
开启事务(获取事务)
提交事务
回滚事务
SpringBoot内置了两个对象:
1. DataSourceTransactionManager 事务管理器. 用来获取事务(开启事务), 提交或回滚事务.
2.TransactionDefinition是事务的属性, 在获取事务时需要将TransactionDefinition传递进去获取一个TransactionStatus.
还是通过代码练习(就以一个简单的注册提交为示例, 很简单, 自行编写即可(作者懒得粘)):
@RestController
@RequestMapping("/user")
public class UserController {
//JDBC事务管理器
@Autowired
private DataSourceTransactionManager dataSourceTransactionManager;
//定义事务属性
@Autowired
private TransactionDefinition transactionDefinition;
@Autowired
private UserService userService;
@RequestMapping("/registry")
public String registry(String name, String password) {
//开启事务
TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
//用户这侧
userService.registryUser(name, password);
//提交事务
dataSourceTransactionManager.commit(transactionStatus);
//回滚事务
//dataSourceTransactionManager.rollback(transactionStatus);
return "注册成功";
}
}观察事务提交
运行程序: http://127.0.0.1:8080/user/registry?name=admin&password=admin
观察数据库的结果, 数据插入成功.
观察事务回滚
运行程序:
虽然这里显示"注册成功", 但是数据库中并没有新增数据.
以上通过编程方法确实能够实现事务, 但是有没有什么更简单的方法呢?
Spring声明式事务 @Transactional
声明式事务很简单, 只需要在事务的方法上添加@Transactional注解就可以实现了. 无需手动开启事务和提交事务, 进入方法时自动开启事务, 方法执行完会自动提交事务, 如果中途发生了没有处理的异常会自动回滚事务.
我们来看代码实现:
@RestController
@RequestMapping("/user")
public class UserController1 {
@Autowired
private UserService1 userService;
@Transactional
@RequestMapping("/registry")
public String registry(String name, String password) {
//用户注册
userService.registryUser(name, password);
return "注册成功";
}
}
运行程序, 发现数据插入成功(通过这个id情况我们也可以知道之前那个事务中的内容确实是执行了, 但是回滚了):
修改程序, 使之出现异常:
@Slf4j
@RestController
@RequestMapping("/user")
public class UserController1 {
@Autowired
private UserService1 userService;
@Transactional
@RequestMapping("/registry")
public String registry(String name, String password) {
//用户注册
userService.registryUser(name, password);
log.info("用户数据插入成功");
//强制程序发生异常
int a = 10 / 0;
return "注册成功";
}
}
观察:
观察后端: 虽然日志显示数据插入成功, 但是数据库却没有新增数据, 这证明了事务进行了回滚.
@Transactional作用
@Transactional 可以用来修饰方法或类:
修饰方法(推荐)时: 只有修饰public方法时才生效(修饰其它方法时不报错, 也不生效).
修饰类时: 对@Transactional修饰类中所有的public方法都生效.
方法/类被@Transactional修饰时, 在目标方法执行开始之前, 会自动开启事务, 方法执行结束之后, 自动提交事务(即程序运行成功时, 自动提交).
那么在程序出现异常时什么时候会进行事务回滚, 什么时候不进行事务回滚呢? 这就比较复杂了.
让我们通过一张图看一下:
我们对之前的代码进行异常捕获再试一下:
我们发现: 虽然程序出错了, 但是由于异常被捕获了, 所以事务依然得到了提交.
1.重新抛出异常以进行事务回滚:
//对异常进行捕获
try {
//强制程序发生异常
int a = 10 / 0;
} catch (Exception e) {
//再次抛出异常
throw e;
}2.手动回滚事务
//对异常进行捕获
try {
//强制程序发生异常
int a = 10 / 0;
} catch (Exception e) {
//手动进行回滚
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
}
