Spring 事务注解 @Transactional 本来可以保证原子性,如果事务内有报错的话,整个事务可以保证回滚,但是加上 try catch 或者事务嵌套,可能会导致事务回滚失败。测试一波。

线上结论

  • 结论一:对于 @Transactional 可以保证 RuntimeException 错误的回滚,如果想保证非 RuntimeException 错误的回滚,需要加上 rollbackFor = Exception.class 参数。
  • 结论二:try catch 只是对异常是否可以被 @Transactional 感知 到有影响。如果错误抛到切面可以感知到的地步,那就可以起作用。
  • 结论三:由于REQUIRED 属性,「两个事务」其实是一个事务,处理能力看报错时刻,是否添加了处理非 RuntimeException 的能力。


准备

建两张表,模拟两个数据操作

  1. CREATE TABLE `user` (
  2. `id` int(11) NOT NULL AUTO_INCREMENT,
  3. `name` varchar(20) DEFAULT NULL,
  4. `age` smallint(3) DEFAULT NULL,
  5. PRIMARY KEY (`id`)
  6. ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
  7. CREATE TABLE `role` (
  8. `id` int(11) NOT NULL AUTO_INCREMENT,
  9. `role_name` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL,
  10. PRIMARY KEY (`id`)
  11. ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

测试

根据排列组合原理,我们进行四种测试:

  • try catch、无嵌套
  • try catch、无嵌套
  • try catch、有嵌套
  • try catch、有嵌套

最简单测试

如果我们单纯 @Transactional,事务可以正常回滚吗?

  1. @GetMapping("/saveNormal0")
  2. @Transactional
  3. public void saveNormal0() throws Exception {
  4. int age = random.nextInt(100);
  5. User user = new User().setAge(age).setName("name:"+age);
  6. userService.save(user);
  7. throw new RuntimeException();
  8. }

如果事务内报了 RuntimeException 错误,事务可以回滚。

  1. @GetMapping("/saveNormal0")
  2. @Transactional
  3. public void saveNormal0() throws Exception {
  4. int age = random.nextInt(100);
  5. User user = new User().setAge(age).setName("name:"+age);
  6. userService.save(user);
  7. throw new Exception();
  8. }

如果事务内报了 Exception 错误(非 RuntimeException 错误),事务不可以回滚。

  1. @GetMapping("/saveNormal0")
  2. @Transactional( rollbackFor = Exception.class)
  3. public void saveNormal0() throws Exception {
  4. int age = random.nextInt(100);
  5. User user = new User().setAge(age).setName("name:"+age);
  6. userService.save(user);
  7. throw new Exception();
  8. }

如果是 Exception 错误(非 RuntimeException),加上 rollbackFor = Exception.class 参数也可以实现回滚。 :::info 结论一:对于 @Transactional 可以保证 RuntimeException 错误的回滚,如果想保证 非 RuntimeException 错误的回滚,需要加上 rollbackFor = Exception.class 参数。 :::

try catch 影响

经过博主多种情况测试,发现 try catch 对回滚这个事本身没有什么影响,结论一照样成立。try catch 只是对异常是否可以被 @Transactional 感知 到有影响。如果错误抛到切面可以感知到的地步,那就可以起作用。

  1. @GetMapping("/saveTryCatch")
  2. @Transactional( rollbackFor = Exception.class)
  3. public void saveTryCatch() throws Exception{
  4. try{
  5. int age = random.nextInt(100);
  6. User user = new User().setAge(age).setName("name:"+age);
  7. userService.save(user);
  8. throw new Exception();
  9. }catch (Exception e){
  10. throw e;
  11. }
  12. }

比如上面一段代码就回滚了。

  1. @GetMapping("/saveTryCatch")
  2. @Transactional( rollbackFor = Exception.class)
  3. public void saveTryCatch() throws Exception{
  4. try{
  5. int age = random.nextInt(100);
  6. User user = new User().setAge(age).setName("name:"+age);
  7. userService.save(user);
  8. throw new Exception();
  9. }catch (Exception e){
  10. }
  11. }

然而,将 catch 中的错误不继续网上抛,切面无法感知到错误,无法进行处理,那么事务就无法回滚了。

:::info 结论二try catch 只是对异常是否可以被 @Transactional 感知到有影响。如果错误抛到切面可以感知到的地步,那就可以起作用。 :::

事务嵌套 影响

首先经过实验,结论一仍然成立,即,当不加上 rollbackFor = Exception.class 的时候,无论内外报 RuntimeException,都会回滚;无论内外报 非RuntimeException 错误,都不会回滚。如果加上 rollbackFor = Exception.class,无论内外怎么报错,都会回滚。这些代码就不给出了。接下来,试下下面两种情况:

  1. @GetMapping("/out")
  2. @Transactional( rollbackFor = Exception.class)
  3. public void out() throws Exception{
  4. innerService.inner();
  5. int age = random.nextInt(100);
  6. User user = new User().setAge(age).setName("name:" + age);
  7. userService.save(user);
  8. throw new Exception();
  9. }
  10. @Transactional
  11. public void inner() throws Exception{
  12. Role role = new Role();
  13. role.setRoleName("roleName:"+new Random().nextInt(100));
  14. roleService.save(role);
  15. // throw new Exception();
  16. }

情况一:外面事务加上 rollbackFor = Exception.class,里面事务不加,测试内外分别报错的情况(为了简化代码量,只给出了外面报错的代码),都可以回滚。因为,无论如何,错误都抛给了外面那个事务进行处理,而外面那个加上了 rollbackFor = Exception.class,具备处理非 RuntimeException 错误的能力,所以都可以让事务进行正常回滚。

情况二:里面的事务加上 rollbackFor = Exception.class,外面不加,外面报错。

  1. @GetMapping("/out")
  2. @Transactional
  3. public void out() throws Exception{
  4. innerService.inner();
  5. int age = random.nextInt(100);
  6. User user = new User().setAge(age).setName("name:" + age);
  7. userService.save(user);
  8. throw new Exception();
  9. }
  10. @Transactional( rollbackFor = Exception.class)
  11. public void inner() throws Exception{
  12. Role role = new Role();
  13. role.setRoleName("roleName:"+new Random().nextInt(100));
  14. roleService.save(role);
  15. }

事务都无法回滚,这是我们有个疑问,里面的事务明明有很强的处理能力啊,为什么和外面一起回滚失败呢,别着急,等等聊这个。

然后试下里面报错:

  1. @GetMapping("/out")
  2. @Transactional
  3. public void out() throws Exception{
  4. innerService.inner();
  5. int age = random.nextInt(100);
  6. User user = new User().setAge(age).setName("name:" + age);
  7. userService.save(user);
  8. }
  9. @Transactional( rollbackFor = Exception.class)
  10. public void inner() throws Exception{
  11. Role role = new Role();
  12. role.setRoleName("roleName:"+new Random().nextInt(100));
  13. roleService.save(role);
  14. throw new Exception();
  15. }

咦,这回都进行了正常的回滚。我的天,这回外面没有处理能力,为什么接受里面抛出来的错误,也进行了回滚!!!看上去,就好像里外事务总是同生共死的对不对?原来,@Transactional还 有个参数,看下源码,这个注解还有默认值:
**Propagation propagation() default Propagation.REQUIRED;**

REQUIRED 的意思是说,事务嵌套的时候,如果发现已经有事务存在了,就加入这个事务,而不是新建一个事务,所以根本就不存在两个事务,一直只有一个!

至于,此参数其他值,本文不进行测试。回到上面的问题,当外面报错的时候,此时查看事务,没有增加 rollbackFor = Exception.class 参数,即没有处理非 RuntimeException 能力,所以代码走完,貌似“两个事务”,都回滚失败了。当里面报错的时候,事务已经添加上了处理非 RuntimeException 能力,所以,代码走完就回滚成功了。 :::info 结论三:由于 REQUIRED 属性,“两个事务”其实是一个事务,处理能力看报错时刻,是否添加了处理非 RuntimeException 的能力。 :::