> 文章列表 > Spring事务及传播机制

Spring事务及传播机制

Spring事务及传播机制

概念

在MySQL中介绍过,当同一时间出现一起读写数据的情况,可能会导致最终的结果出错,因此可以使用事务来提高隔离级别
而Spring中也可以实现事务

手动添加事务

使用SpringBoot中的DataSourceTransactionManager对象可以获取事务,提交事务,回滚事务

TransactionDefinition是事务的属性,在获取事务时需要传入这个参数

而TransactionStatus则是在获取事务时获取的对象,最终回滚时使用

@RestController
@RequestMapping("url")
public class 实现类 {@Autowiredprivate DataSourceTransactionManager transactionManager;@Autowiredprivate TransactionDefinition transactionDefinition;@RequestMapping("url")public 相关方法() {//开启事务TransactionStatus transactionStatus =transactionManager.getTransaction(transactionDefinition);//处理事务//回滚事务transactionManager.rollback(transactionStatus);}

例如:

@RestController
@RequestMapping("/user")
public class UserController {@Autowiredprivate UserService userService;@Autowiredprivate DataSourceTransactionManager transactionManager;@Autowiredprivate TransactionDefinition transactionDefinition;@RequestMapping("/add")public int add(UserInfo userInfo) {if (userInfo == null || !StringUtils.hasLength(userInfo.getUsername()) ||!StringUtils.hasLength(userInfo.getPassword())) {return 0;}//开启事务TransactionStatus transactionStatus =transactionManager.getTransaction(transactionDefinition);int result = userService.add(userInfo);//回滚事务transactionManager.rollback(transactionStatus);return result;}
}

在页面中,传输了参数username = 1, password = 1
但是在数据库中,并没有出现这行数据
Spring事务及传播机制

自动添加事务

使用@Transactional注解可以快速添加事务

@Transactional
@RequestMapping("/insert")
public Integer insert(UserInfo userInfo) {if (userInfo == null || !StringUtils.hasLength(userInfo.getUsername()) ||!StringUtils.hasLength(userInfo.getPassword())) {return 0;}int result = userService.add(userInfo);}return result;
}

如果没有异常,那么会自动提交事务,如果有异常,事务会进行回滚

例如:在类中添加空指针异常
如果没有添加@Transactional那么在异常出现前数据已经上传到数据库

@RequestMapping("/insert")
public Integer insert(UserInfo userInfo) {if (userInfo == null || !StringUtils.hasLength(userInfo.getUsername()) ||!StringUtils.hasLength(userInfo.getPassword())) {return 0;}int result = userService.add(userInfo);int num = 1 / 0;return result;
}

Spring事务及传播机制
Spring事务及传播机制
而加了@Transactional注解,就可以自动回滚事务,数据库中就没有这行数据了
Spring事务及传播机制
Spring事务及传播机制
而如果我们添加了try,catch语句,spring就不会感知到异常的存在了,也就不会进行事务的回滚了

@Transactional //声明式事务(没有错误自动提交)
@RequestMapping("/insert")
public Integer insert(UserInfo userInfo) {if (userInfo == null || !StringUtils.hasLength(userInfo.getUsername()) ||!StringUtils.hasLength(userInfo.getPassword())) {return 0;}int result = userService.add(userInfo);try{int num = 1 / 0;} catch (Exception e){e.printStackTrace()}return result;
}

Spring事务及传播机制
Spring事务及传播机制
如果我们还想要事务进行自动回滚,那么可以使用throw将异常抛出,这样spring就能再次感知到异常的存在了

@Transactional //声明式事务(没有错误自动提交)
@RequestMapping("/insert")
public Integer insert(UserInfo userInfo) {if (userInfo == null || !StringUtils.hasLength(userInfo.getUsername()) ||!StringUtils.hasLength(userInfo.getPassword())) {return 0;}int result = userService.add(userInfo);try{int num = 10 / 0;} catch (Exception e){e.printStackTrace();throw e;}return result;
}

Spring事务及传播机制
Spring事务及传播机制

如果不想要页面出现报错信息,那么可以不添加throw语句,而是手动回滚事务

@Transactional //声明式事务(没有错误自动提交)
@RequestMapping("/insert")
public Integer insert(UserInfo userInfo) {if (userInfo == null || !StringUtils.hasLength(userInfo.getUsername()) ||!StringUtils.hasLength(userInfo.getPassword())) {return 0;}int result = userService.add(userInfo);try{int num = 10 / 0;} catch (Exception e){e.printStackTrace();TransactionAspectSupport.currentTransactionStatus().setRollbackOnly()}return result;
}

Spring事务及传播机制
Spring事务及传播机制

事务隔离级别设置

当不同事务同时对数据库进行数据操作,就会出现问题,因此可以针对不同的情景设置不同的隔离级别
Spring事务及传播机制

在@Transactional注解中可以设置事务的隔离级别
Spring事务及传播机制

代码 含义 问题
Isolation.DEFAULT 默认级别 以数据库隔离级别执行
Isolation.READ_UNCOMMITTED 读未提交 可以读未提交数据 存在脏读问题
Isolation.READ_COMMITED 读已提交 只能读到已经提交事务 存在不可重复读问题
Isolation.REPEATABLE_READ 可重复读 存在幻读问题
Isolation.SERIALIZABLE 串行化 性能低

事务传播机制

在项目中会存在多个方法链式调用,而每一个方法都有可能存在事务,因此存在不同的事物传播机制
Spring事务及传播机制
分别有如下几种事物传播级别:

代码 说明
Propagation.REQUIRED (默认)如果当前存在事务则加入事务,都则创建一个事务
Propagation.SUPPORTS 如果当前存在事务就加入事务,否则就以非事务方式运行
Propagation.MANDATORY 如果当前存在事务就加入事务,否则抛出异常
Propagation.REQUIRES_NEW 不管当前有没有事务,都创建并使用新事务
Propagation.NOT_SUPPORTED 不管当前有没有事务,都以非事务方式运行
Propagation.NEVER 以非事务形式运行,如果当前存在事务就抛出异常
Propagation.NESTED 如果当前存在事务,则创建一个事务作为当前事务的嵌套事务运行,当作REQUIRED