一、问题描述
场景描述:有这样一个service方法,调用了两个dao中的方法。第一个方法按照传入的id批量更新用户名。第二个dao方法无数据库操作,仅仅抛出一个RuntimeException.
这个service方法通过xml配置由spring事务管理的。
两个DAO类中分别有SqlSessionTemplate类型的属性template,使用IOC的方式注入的。
public void batchUpdate() {
String username="newname59";
List<Integer> idList=Arrays.asList(10000,10001);
userDao.batchUpdateUsername(username, idList);
testDao.testException();
userDao.batchUpdateUserage(55, idList);
testDao.testNormal();
}
当userDao及testDao中注入的是ExcutorType.Simple类型的template时,批量更新用户名的操作会回滚。
当userDao及testDao中注入的是ExcutorType.Batch类型的template时,批量更新用户名的操作未回滚。
经过检查数据库日志,发现第二种情况的数据库执行序列如下:
1 set autocommit = 0
2 rollback
3 update t_user set username="newname59" where id = '10000'
4 update t_user set username="newname59" where id = '10001'
5 set autocommit = 1
更新操作在回滚之后执行,故回滚失败。
调试源代码发现有如下序列:
AbstractPlatformTransactionManager
processRollback () --> triggerAfterCompletion() --> invokeAfterCompletion()
-->
TransactionSynchronizationUtils
invokeAfterCompletion()
-->
SqlSessionUtils
afterCompletion()
-->
DefaultSqlSession
close()
-->
BaseExecutor
close() --> rollback() --> flushStatement()
-->
BatchExecutor
doFlushStatements()
这时就执行了sql语句。
简单来说:抛出异常,spring事务回滚,清理资源关闭sqlSession.
mybatis关闭sqlsession,关闭前先flushStatements,执行未执行的sql语句,然后再rollback.
但是这个rollback方法里判断connection是受事务管理的,就不执行任何操作。
public void rollback(boolean required) throws SQLException {
if (!closed) {
try {
clearLocalCache();
flushStatements();
} finally {
if (required) {
transaction.rollback();
}
}
}
}
public void rollback() throws SQLException {
if (!this.isConnectionTransactional) {
if (this.logger.isDebugEnabled()) {
this.logger.debug("Rolling back JDBC Connection [" + this.connection + "]");
}
this.connection.rollback();
}
}
二、解决办法:
1、在自己的应用程序中写个拦截器。在执行完executor的close()之后,由这个拦截器再执行一遍connection.rollback(),但从代码的可读性来看,会非常的差。
2、修改mybatis的bug。修改BaseExecutor的rollback()
public void rollback(boolean required) throws SQLException {
if (!closed) {
try {
clearLocalCache();
if (!required) {
flushStatements();
}
} finally {
if (required) {
transaction.rollback();
}
}
}
}
不知道大家有没有碰到过类似的问题,又是通过什么方案解决的呢?