赞
踩
使用@Transaction注解报错
Cause: com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException: Lock wait timeout exceeded; try restarting transaction;
Lock wait timeout exceeded; try restarting transaction; nested exception is com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException: Lock wait timeout exceeded; try restarting transaction
事务锁从开始直到提交或回滚,中间等待的时间太长,超时了==
手动控制事务,把比较耗时的代码放在事务之外处理
1、以下业务耗时较长,可能会导致超时
@Override @Transactional public Integer method1(JSONObject json) { //1、因为业务需要,这里执行一些比耗时的代码,如for循环等 //2、查询数据 xxxMapper.select(param1, param2); //3、因为业务需要,这里再次执行一些比耗时的代码 //4、删除数据 xxxMapper.delete(param1, param2); //5、插入数据 xxxMapper.insert(param); }
2、对该业务进行优化
@Slf4j @Service public class xxxServiceImpl extends BaseServiceImpl<xxx> implements xxxService { //1、注入对应的事务管理器 //若项目上只有一个数据源,则不需要使用@Qualifier @Qualifier(BaseDataSourceConfiguration.TRANSACTION_MANAGER_NAME) @Autowired private DataSourceTransactionManager dataSourceTransactionManager; @Override //注意:这里将@Transactional注释掉,用try/catch来控制事务的提交和回滚 //@Transactional public Integer method1(JSONObject json) { try { //1、因为业务需要,这里执行一些比耗时的代码,如for循环等 //2、查询数据 xxxMapper.select(param1, param2); //3、因为业务需要,这里再次执行一些比耗时的代码 //4、在真正操作数据库(增、删、改)之前手动开启事务 // 获取事务定义 DefaultTransactionDefinition df = new DefaultTransactionDefinition(); // 设置事务隔离级别,开启新的数据 df.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 获取事务状态,相当于开启事务 TransactionStatus transaction = dataSourceTransactionManager.getTransaction(df); //5、删除数据 xxxMapper.delete(param1, param2); //6、插入数据 xxxMapper.insert(param); //7、提交事务 dataSourceTransactionManager.commit(transaction); } catch (Exception e) { //8、回滚事务 dataSourceTransactionManager.rollback(transaction); } } }
说明:这里是把事务的开启时机,尽量往后移,在真正操作数据库之前才开启事务
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。