一、问题描述

场景描述：有这样一个service方法，调用了两个dao中的方法。第一个方法按照传入的id批量更新用户名。第二个dao方法无数据库操作，仅仅抛出一个RuntimeException.

这个service方法通过xml配置由spring事务管理的。

两个DAO类中分别有SqlSessionTemplate类型的属性template，使用IOC的方式注入的。

public void batchUpdate() {

String username="newname59";

List 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();

}

}

}

}

不知道大家有没有碰到过类似的问题，又是通过什么方案解决的呢？