Spring 事务不生效总览
简单来说,Spring 事务会在几种特定的场景下失效,如下图所示。
Spring 事务生效的前提是所连接的数据库要支持事务,如果底层的数据库都不支持事务,则 Spring 的事务肯定会失效。例如,如果使用的数据库为 MySQL,并且选用了 MyISAM 存储引擎,则 Spring 的事务就会失效。
2、事务方法未被 Spring 管理
如果事务方法所在的类没有加载到 Spring IOC 容器中,也就是说,事务方法所在的类没有被 Spring 管理,则 Spring 事务会失效,示例如下。
public class ProductService {
@Autowired
private ProductDao productDao;
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void updateProductStockCountById(Integer stockCount, Long id) {
productDao.updateProductStockCountById(stockCount, id);
}
}
ProductService 类上没有标注 @Service 注解,Product 的实例没有加载到 Spring IOC 容器中,就会造成 updateProductStockCountById() 方法的事务在 Spring 中失效。
3、方法没有被 public 修饰
如果事务所在的方法没有被 public 修饰,此时 Spring 的事务会失效,例如,如下代码所示。
@Service
public class ProductService {
@Autowired
private ProductDao productDao;
@Transactional(propagation = Propagation.REQUIRES_NEW)
private void updateProductStockCountById(Integer stockCount, Long id) {
productDao.updateProductStockCountById(stockCount, id);
}
}
@Service
public class OrderService {
@Autowired
private OrderDao orderDao;
@Autowired
private ProductDao productDao;
public void submitOrder() {
//生成订单
Order order = new Order();
long number = Math.abs(new Random().nextInt(500));
order.setId(number);
order.setOrderNo("order_" + number);
orderDao.saveOrder(order);
//减库存
this.updateProductStockCountById(1, 1 L);
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void updateProductStockCountById(Integer stockCount, Long id) {
productDao.updateProductStockCountById(stockCount, id);
}
}
@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Service
public class OrderService {
@Autowired
private OrderDao orderDao;
@Autowired
private ProductDao productDao;
@Transactional(propagation = Propagation.REQUIRED)
public void submitOrder() {
//生成订单
Order order = new Order();
long number = Math.abs(new Random().nextInt(500));
order.setId(number);
order.setOrderNo("order_" + number);
orderDao.saveOrder(order);
//减库存
this.updateProductStockCountById(1, 1 L);
}
@Transactional(propagation = Propagation.NOT_SUPPORTED)
public void updateProductStockCountById(Integer stockCount, Long id) {
productDao.updateProductStockCountById(stockCount, id);
}
}
@Service
public class OrderService {
@Autowired
private OrderDao orderDao;
@Autowired
private ProductDao productDao;
@Transactional(propagation = Propagation.REQUIRED)
public void submitOrder() {
//生成订单
Order order = new Order();
long number = Math.abs(new Random().nextInt(500));
order.setId(number);
order.setOrderNo("order_" + number);
orderDao.saveOrder(order);
//减库存
this.updateProductStockCountById(1, 1 L);
}
@Transactional(propagation = Propagation.REQUIRED)
public void updateProductStockCountById(Integer stockCount, Long id) {
try {
productDao.updateProductStockCountById(stockCount, id);
int i = 1 / 0;
} catch (Exception e) {
logger.error("扣减库存异常:", e.getMesaage());
}
}
}
updateProductStockCountById() 方法中使用 try-catch 代码块捕获了异常,即使 updateProductStockCountById() 方法内部会抛出异常,但也会被 catch 代码块捕获到,此时 updateProductStockCountById() 方法的事务会提交而不会回滚,并且 submitOrder() 方法的事务会提交而不会回滚,这就造成了 Spring 事务的回滚失效问题。
8、错误的标注异常类型
如果在 @Transactional 注解中标注了错误的异常类型,则 Spring 事务的回滚会失效,示例如下。
@Transactional(propagation = Propagation.REQUIRED)
public void updateProductStockCountById(Integer stockCount, Long id) {
try {
productDao.updateProductStockCountById(stockCount, id);
} catch (Exception e) {
logger.error("扣减库存异常:", e.getMesaage());
throw new Exception("扣减库存异常");
}
}
在 updateProductStockCountById() 方法中捕获了异常,并且在异常中抛出了 Exception 类型的异常,此时,updateProductStockCountById() 方法事务的回滚会失效。
为何会失效呢?这是因为 Spring 中对于默认回滚的事务异常类型为 RuntimeException,上述代码抛出的是 Exception 异常。
默认情况下,Spring 事务中无法捕获到 Exception 异常,所以此时 updateProductStockCountById() 方法事务的回滚会失效。
此时可以手动指定 updateProductStockCountById() 方法标注的事务异常类型,如下所示。
@Transactional(propagation = Propagation.REQUIRED,rollbackFor = Exception.class)
- EOF -
推荐阅读 点击标题可跳转看完本文有收获?请转发分享给更多人
关注「ImportNew」,提升Java技能
点赞和在看就是最大的支持❤️