Spring 事务注解 @Transactional 本来可以保证原子性,如果事务内有报错的话,整个事务可以保证回滚,但是加上try catch或者事务嵌套,可能会导致事务回滚失败。
测试一@Transactional public void test() throws Exception { ProductCategoryJd model = new ProductCategoryJd(); model.setCatId((long) 100); model.setName("test"); model.setState(1); model.setParentId(22); productCategoryJdRepository.saveAndFlush(model); throw new RuntimeException(); }
报了RuntimeException错误,事务可以正常回滚。
@Transactional public void test() throws Exception { ProductCategoryJd model = new ProductCategoryJd(); model.setCatId((long) 100); model.setName("test"); model.setState(1); model.setParentId(22); productCategoryJdRepository.saveAndFlush(model); throw new Exception(); }
报了Exception错误,事务可以无法回滚。
@Transactional(rollbackFor = Exception.class) public void test() throws Exception { ProductCategoryJd model = new ProductCategoryJd(); model.setCatId((long) 100); model.setName("test"); model.setState(1); model.setParentId(22); productCategoryJdRepository.saveAndFlush(model); throw new Exception(); }
报了Exception错误,但是注解上面加上了rollbackFor = Exception.class,事务就可以正常回滚。
测试二@Transactional(rollbackFor = Exception.class) public void test() throws Exception { try{ ProductCategoryJd model = new ProductCategoryJd(); model.setCatId((long) 100); model.setName("test"); model.setState(1); model.setParentId(22); productCategoryJdRepository.saveAndFlush(model); throw new Exception(); }catch (Exception e){ throw e; } }
这种情况下,事务可以正常回滚。
@Transactional(rollbackFor = Exception.class) public void test() throws Exception { try{ ProductCategoryJd model = new ProductCategoryJd(); model.setCatId((long) 100); model.setName("test"); model.setState(1); model.setParentId(22); productCategoryJdRepository.saveAndFlush(model); throw new Exception(); }catch (Exception e){ e.printStackTrace(); } }
这种情况下,我们没有将异常继续向上抛出,切面无法感知异常,那么事务就无法正常回滚。
测试三@Transactional(rollbackFor = Exception.class) public void test() throws Exception { test2(); ProductCategoryJd model = new ProductCategoryJd(); model.setCatId((long) 100); model.setName("test"); model.setState(1); model.setParentId(22); productCategoryJdRepository.saveAndFlush(model); throw new Exception(); } @Transactional public void test2() throws Exception { ProductCategoryJd model = new ProductCategoryJd(); model.setCatId((long) 100); model.setName("test"); model.setState(1); model.setParentId(22); productCategoryJdRepository.saveAndFlush(model); }
我们在外面事务加上rollbackFor = Exception.class,里面事务不加,会发现可以正常回滚。
原因是里面的异常错误和外面的异常错误,都抛给了外面那个事务进行处理,外面那个加上了rollbackFor = Exception.class,所以都可以让事务进行正常回滚。
对于@Transactional可以保证RuntimeException错误的回滚,如果想保证非RuntimeException错误的回滚,需要加上rollbackFor = Exception.class 参数。
2.结论二:try catch只是对异常是否可以被@Transactional 感知 到有影响。如果错误抛到切面可以感知到的地步,那就可以起作用。
3.结论三:由于REQUIRED属性,“两个事务”其实是一个事务,处理能力看报错时刻,是否添加了处理非RuntimeException的能力。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)