一、问题描述
场景描述:有这样一个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();
}
}
}
}
不知道大家有没有碰到过类似的问题,又是通过什么方案解决的呢?
相关推荐
Mybatis批量foreach merge into的用法 Mybatis批量foreach merge into的用法是通过Mybatis的动态SQL语法foreach循环插入实现的,这种方法可以批量插入时间价格表数据。如果某个套餐的某天的价格存在,则更新,不...
mybatis批量添加的时候报错总结报错 parameter'_frch_item_0 not found
只提供代码,自己去下载相关jar包谢谢只提供代码,自己去下载相关jar包谢谢只提供代码,自己去下载相关jar包谢谢只提供代码,自己去下载相关jar包谢谢只提供代码,自己去下载相关jar包谢谢
本篇文章将详细介绍如何利用Java和MyBatis实现批量插入数据到Oracle数据库中。 首先,我们需要理解Oracle数据库的一些基本概念。Oracle是世界上最流行的商业关系型数据库管理系统之一,以其强大的功能和高可靠性而...
Mybatis批量更新三种方式的实现 Mybatis是一款流行的持久层框架,它提供了强大的数据库交互能力。其中,批量更新是一种常见的操作,能够提高数据库操作的效率。下面将介绍Mybatis批量更新三种方式的实现。 方式一...
mybatis 框架批量增删改代码 示例 含java与xml
本文将深入探讨如何在 Mybatis Plus 中自定义批量插入和批量更新,并根据唯一索引来确保数据的唯一性。 首先,了解 Mybatis Plus 的批量操作基础。Mybatis Plus 提供了 `batchInsert()` 和 `batchUpdate()` 方法来...
本文将详细分析Mybatis批量更新的报错问题及其解决方法。 首先,报错可能由于不支持批量更新操作的JDBC配置引起。在MySQL中,如果不开启`allowMultiQueries`参数,Mybatis尝试执行包含多个SQL语句的批量更新时,会...
需要注意的是,MyBatis批量插入可能会出现内存不足的问题,因此需要提前修改MySql的配置文件,增加max_allowed_packet的值以避免内存不足的问题。 MyBatis批量插入是一种高效的数据插入方式,可以大大提高插入速度...
MyBatis Plus 是 MyBatis 的一个扩展,它在 MyBatis 的基础上提供了更多的便捷功能,包括但不限于批量操作。在数据库交互中,批量操作能够显著提高效率,减少数据库连接的开销。本测试主要探讨了 MyBatis Plus 中的...
MyBatis 插件机制防止批量更新 MyBatis 是一个流行的持久层框架,它提供了插件机制来拦截 SQL 操作,以便于开发者可以在执行 SQL 语句前进行预处理或后续处理。本文将详细介绍 MyBatis 插件机制的实现原理和应用...
MyBatis动态SQL和批量插入的应用 MyBatis是一款功能强大且灵活的持久层框架,提供了多种方式来对数据库进行交互。其中,动态SQL是一种非常强大的特性,能够根据不同的条件生成不同的SQL语句。下面将详细介绍MyBatis...
本文将探讨Mybatis和JDBC在批量插入MySQL数据库时的性能差异,并提供相关的测试资源。 首先,JDBC(Java Database Connectivity)是Java平台中用于与数据库交互的一种规范,它允许程序员使用SQL语句直接操作数据库...
【Mybatis批量添加实现详解】 在数据库操作中,批量插入数据是常见的需求,尤其是在处理大量数据时,批量插入能够显著提高效率。Mybatis,作为一款轻量级的持久层框架,提供了灵活的方式来处理批量添加。本文将详细...
MyBatis批量更新数据两种方法效率对比 在MyBatis中,批量更新数据是指在一次数据库交互中更新多条记录的操作。这种操作可以提高应用程序的性能和效率。今天,我们将讨论两种批量更新数据的方法,并对其进行效率对比...
使用方法请看博客https://blog.csdn.net/bandaotixiruiqiang/article/details/72478361#comments_12931827
使用方法请看博客 https://blog.csdn.net/bandaotixiruiqiang/article/details/72478361#comments_12931827
在"mybatis数据操作(增删改查+批量操作)"这个主题中,我们将深入探讨如何利用MyBatis进行基本的数据操作,包括插入(Insert)、删除(Delete)、更新(Update)和查询(Select),以及如何执行批量操作。...
Mybatis实现多表联合查询和批量插入 Mybatis是一款流行的持久层框架,它可以帮助开发者快速、高效地访问数据库。在实际开发中,经常需要对多个表进行联合查询,或者对大量数据进行批量插入。本文将详细介绍如何使用...
- 谨慎处理批量更新的大小,过大的批量可能会导致内存问题或数据库服务器压力过大。 5. **最佳实践** 在实际应用中,你可以根据业务需求和数据库性能调整批量更新的大小,找到最佳的平衡点。此外,合理设计数据...