【Spring】事务和事务传播机制

2022-07-16 07:09 浏览：153

为什么需要事务
Spring 声明事务
- Transactional参数说明
- - propagation
  - isolation
  - timeout
- 事务回滚失效解决方案
- @Transactional工作原理
Spring 事务的传播机制
- 为什么需要事务传播机制？
- 传播机制的类型
- - 嵌套事务和加入事务的区别

为什么需要事务

事务是将一组操作封装成一个执行单元，要么全部成功，要么全部失败。如果没有事务，转账操作就会出现异常，因此需要保证原子性。

Spring 声明事务

只需要在方法上添加@Transactional注解就可以实现，无需手动开启和提交事务，如果中途发生异常就会自动回滚事务。
@Transactional既可以修饰方法也可以修饰类，修饰方法只能修饰public方法
注意：@Transactional在异常被捕获的情况下，事务就不会自动回滚

@Transactional(isolation = Isolation.READ_COMMITTED) // 开启事务    @RequestMapping("/insert")    public int insert(){        UserInfo userInfo = new UserInfo();        userInfo.setName("AOP");        userInfo.setPassword("123456");        return userService.add(userInfo);    }    @Transactional(isolation = Isolation.READ_COMMITTED) // 开启事务    @RequestMapping("/insert2")    public int insert2(){        UserInfo userInfo = new UserInfo();        userInfo.setName("AOP");        userInfo.setPassword("123456");        int result = userService.add(userInfo);        System.out.println("MySQL影响的行数："+result);        int num = 10/0;        return result;    }

Transactional参数说明

在这里插入图片描述

propagation

事务的传播行为，默认为Propagation.REQUIRED

isolation

Spring有5种隔离级别，MySQL有四种隔离级别，Spring多了一个DEFAULT，以连接的数据库的事务隔离级别为主

在这里插入图片描述

timeout

表示事务的超时时间，默认值为-1，如果事务执行时间超过超时时间，就会自动回滚

事务回滚失效解决方案

直接抛出异常

    @Transactional(propagation = Propagation.REQUIRED) // 开启事务    @RequestMapping("/insert2")    public int insert2(){        UserInfo userInfo = new UserInfo();        userInfo.setName("AOP");        userInfo.setPassword("123456");        int result = userService.add(userInfo);        System.out.println("MySQL影响的行数："+result);        try {            int num = 10/0;        }catch (Exception e){            result = 0;            e.printStackTrace();            throw e;//解决事务失效的问题           // TransactionAspectSupport.currentTransactionStatus().setRollbackonly();        }        return result;    }

在catch中使用代码手动进行事务的回滚操作

      @Transactional(propagation = Propagation.REQUIRED) // 开启事务    @RequestMapping("/insert2")    public int insert2(){        UserInfo userInfo = new UserInfo();        userInfo.setName("AOP");        userInfo.setPassword("123456");        int result = userService.add(userInfo);        System.out.println("MySQL影响的行数："+result);        try {            int num = 10/0;        }catch (Exception e){            result = 0;            e.printStackTrace();            //throw e;//解决事务失效的问题            TransactionAspectSupport.currentTransactionStatus().setRollbackonly();        }        return result;    }

@Transactional工作原理

@Transactional是基于AOP实现的，AOP又是使用动态代理实现的。如果目标对象实现了接口，默认情况下会采用JDK的动态代理，如果目标对象没有实现了接口，会使用CGLIB动态代理。@Transactional在开始执行业务之前，通过代理先开启事务，在执行成功之后再提交事务。如果中途遇到了异常，则回滚事务。