当前位置:   article > 正文

使用@Transaction注解时Mysql事务锁等待超时Lock wait timeout exceeded; try restarting transaction_cause: com.mysql.cj.jdbc.exceptions.mysqltransacti

cause: com.mysql.cj.jdbc.exceptions.mysqltransactionrollbackexception: lock


场景

使用@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
  • 2

原因

事务锁从开始直到提交或回滚,中间等待的时间太长,超时了==


解决

手动控制事务,把比较耗时的代码放在事务之外处理


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);
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16

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);
        }
	}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45

说明:这里是把事务的开启时机,尽量往后移,在真正操作数据库之前才开启事务

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/Cpp五条/article/detail/729252
推荐阅读
相关标签
  

闽ICP备14008679号