使用@Transaction注解时Mysql事务锁等待超时Lock wait timeout exceeded； try restarting transaction

太过爱你忘了你带给我的痛 2023-10-10 17:19 114阅读 0赞

#### 目录 ####

*   *  场景
     *  报错信息
     *  原因
     *  解决
     *  例

--------------------

### 场景 ###

使用@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);
            }
    	}
    }

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