`

iBatis整理——Spring环境下批处理实现

阅读更多
最近做一个小项目,用到Spring+iBatis。突然遇到一个很久远,却很实在的问题:在Spring下怎么使用iBatis的批处理实现?

大概是太久没有写Dao了,这部分真的忘得太干净了。

从4个层面分析这部分实现:
  1. iBatis的基本实现
  2. 基于事务的iBatis的基本实现
  3. 基于事务的Spring+iBatis实现
  4. 基于回调方式的Spring+iBatis实现


1.iBatis的基本实现
iBatis通过SqlMapClient提供了一组方法用于批处理实现:
  1. startBatch() 开始批处理
  2. executeBatch() 执行批处理

代码如下:
	public void create(List<Reply> replyList) {

		try {
			// 开始批处理
			sqlMapClient.startBatch();

			for (Reply reply: replyList) {
				// 插入操作
				sqlMapClient.insert("Reply.create", reply);
			}
			// 执行批处理
			sqlMapClient.executeBatch();

		} catch (Exception e) {
			e.printStackTrace();
		}
	}

这是基于iBatis的最基本实现,如果你一步一步debug,你会发现:其实,数据库已经执行了插入操作!
因此,除了这两个核心方法外,你还需要开启事务支持。否则,上述代码只不过是个空架子!

2.基于事务的iBatis的基本实现
事务处理:
  1. startTransaction() 开始事务
  2. commitTransaction() 提交事务
  3. endTransaction() 结束事务


我们以insert操作为例,把它们结合到一起:
	public void create(List<Reply> replyList) {

		try {
			// 开始事务
			sqlMapClient.startTransaction();
			// 开始批处理
			sqlMapClient.startBatch();

			for (Reply reply: replyList) {
				// 插入操作
				sqlMapClient.insert("Reply.create", reply);
			}
			// 执行批处理
			sqlMapClient.executeBatch();

			// 提交事务
			sqlMapClient.commitTransaction();

		} catch (Exception e) {
			e.printStackTrace();
		} finally {  
 			 try {
				// 结束事务
				sqlMapClient.endTransaction();
        		    } catch (SQLException e) {
       			         e.printStackTrace();
       			     }
		}  
	}

replyList是一个List,要把这个List插入到数据库,就需要经过这三个步骤:
  1. 开始批处理 startBatch()
  2. 插入      insert()
  3. 执行批处理 executeBatch()

如果要在Spring+iBatis中进行批处理实现,需要注意使用同一个sqlMapClient!同时,将提交事务的工作交给Spring统一处理!

3.基于事务的Spring+iBatis实现
	public void create(List<Reply> replyList) {
		if (!CollectionUtils.isEmpty(replyList)) {
			// 注意使用同一个SqlMapClient会话
			SqlMapClient sqlMapClient = sqlMapClientTemplate.getSqlMapClient();

			try {
				// 开始事务
				sqlMapClient.startTransaction();
				// 开始批处理
				sqlMapClient.startBatch();
				for (Reply reply : replyList) {
					// 插入操作
					sqlMapClient.insert("Reply.create", reply);
				}

				// 执行批处理
				sqlMapClient.executeBatch();
				// 提交事务 交给Spring统一控制
				// sqlMapClient.commitTransaction();

			} catch (Exception e) {
				e.printStackTrace();
			} finally {  
 				 try {
					// 结束事务
					sqlMapClient.endTransaction();
        			    } catch (SQLException e) {
       				         e.printStackTrace();
       				     }
			}  
		}
	}

注意使用同一个sqlMapClient:
SqlMapClient sqlMapClient = sqlMapClientTemplate.getSqlMapClient();
如果直接sqlMapClientTemplate执行insert()方法,将会造成异常!

想想,还有什么问题?其实问题很明显,虽然解决了批处理实现的问题,却造成了事务代码入侵的新问题。 这么做,有点恶心!
除此之外,异常的处理也很恶心,不能够简单的包装为 DataAccessException 就无法被Spring当作统一的数据库操作异常做处理。


4.基于回调方式的Spring+iBatis实现
如果观察过Spring的源代码,你一定知道,Spring为了保持事务统一控制,在实现ORM框架时通常都采用了回调模式,从而避免了事务代码入侵的可能!
修改后的代码如下:
	@SuppressWarnings("unchecked")
	public void create(final List<Reply> replyList) {
		// 执行回调
		sqlMapClientTemplate.execute(new SqlMapClientCallback() {
			// 实现回调接口
			public Object doInSqlMapClient(SqlMapExecutor executor)
					throws SQLException {
				// 开始批处理
				executor.startBatch();
				for (Reply reply : replyList) {
					// 插入操作
					executor.insert("Reply.create", reply);

				}
				// 执行批处理
				executor.executeBatch();

				return null;

			}
		});

	}

注意,待遍历的参数replyList需要加入final标识!即,待遍历对象不能修改!
引用
public void create(final List<Reply> replyList)

这样做,就将事务处理的控制权完全交给了Spring!
简述:
  1. SqlMapClientCallback 回调接口
  2. doInSqlMapClient(SqlMapExecutor executor) 回调实现方法
  3. DataAccessException 最终可能抛出的异常

通过上述修改,最终能够解决第三种实现方式中的种种不足!

Spring对iBatis提供的支持还是不够完善,即便是现在最新的Spring3.0.4。最开始,本打算用Spring3.0+iBatis3.0,结果Spring报错,说找不到“com.ibatis.xxxxx”完全是iBatis2.x的包路径!汗颜~ 还是Hibernate比较得宠!

做个小记录,呵呵!
19
2
分享到:
评论
13 楼 bluend1004 2013-09-06  
您好 求解释,博文中提到的”却造成了事务代码入侵的新问题“能具体解释下吗?谢谢
12 楼 veenter 2013-07-17  
snowolf 写道
sunjichao 写道
Copperfield 写道
哥们,咨询个问题:
第四种我试了一下, 在执行executor.executeBatch();时,一旦遇到异常,数据没有批量回滚,10条数据有2条异常,则正常插入8条数据,这个很是不解。。。

遇到同样的问题,求解释。

有没有配置事务层?这段代码很久了,我都是在service用配置事务。如果没有事务控制,不会回滚!


贴一下代码,看看是如果操作的
11 楼 snowolf 2012-06-25  
sunjichao 写道
Copperfield 写道
哥们,咨询个问题:
第四种我试了一下, 在执行executor.executeBatch();时,一旦遇到异常,数据没有批量回滚,10条数据有2条异常,则正常插入8条数据,这个很是不解。。。

遇到同样的问题,求解释。

有没有配置事务层?这段代码很久了,我都是在service用配置事务。如果没有事务控制,不会回滚!
10 楼 sunjichao 2011-12-20  
Copperfield 写道
哥们,咨询个问题:
第四种我试了一下, 在执行executor.executeBatch();时,一旦遇到异常,数据没有批量回滚,10条数据有2条异常,则正常插入8条数据,这个很是不解。。。

遇到同样的问题,求解释。
9 楼 77tt77 2011-04-15  
学习了。
8 楼 Copperfield 2011-02-23  
哥们,咨询个问题:
第四种我试了一下, 在执行executor.executeBatch();时,一旦遇到异常,数据没有批量回滚,10条数据有2条异常,则正常插入8条数据,这个很是不解。。。
7 楼 snowolf 2010-12-29  
guozq518 写道
我就是有的第三种来处理的  第四种方法没太看明白。

代码入侵的问题,如果用回调方式,你不需要考虑捕获异常。
6 楼 guozq518 2010-12-29  
我就是有的第三种来处理的  第四种方法没太看明白。
5 楼 snowolf 2010-10-21  
远去的渡口 写道
LZ是指第三种方式时直接使用SqlMapClientTemplate报错么?不好意思理解有误,第三种还没有试过,有时间也试一下

主要不是异常问题的考虑,主要是考虑事务统一处理!
4 楼 远去的渡口 2010-10-21  
LZ是指第三种方式时直接使用SqlMapClientTemplate报错么?不好意思理解有误,第三种还没有试过,有时间也试一下
3 楼 远去的渡口 2010-10-21  
其实我还没有完全搞明白 ,不过采用你这种方法试了,效率还不错的,实现了批处理。
另外,如果直接sqlMapClientTemplate执行insert()方法,将会造成异常!
我是直接用this.getSqlMapClientTemplate().execute(new SqlMapClientCallback() {没有抛出异常。
2 楼 snowolf 2010-09-07  
lyy3323 写道
。。。。。。。SPRING,自动拦截事务就可以了。无需回调这么麻烦。

真正的事务处理仍然在spring中的aop控制之中,当然是通过声明式事务自动拦截!
你可能没明白我的意思,或者说我没听明白你的涵义!
起初,我也只是调用批处理,心想只要我做了声明式事务,就能够做到事务控制,但却发现:不加事务代码,SqlMapClient 不会执行批处理,反而是简单的单条数据插入!所以,开始加事务代码,发现很繁琐,又要手动控制事务,又要破获异常,仔细看Spring源码,才恍然大悟——spring中所有的ORM实现都是用了回调方式,目的就是要兼容事务控制,包括我所需要的批处理!

PS:如果你有更好的办法,麻烦给点提示,我再测试测试!
1 楼 lyy3323 2010-09-07  
。。。。。。。SPRING,自动拦截事务就可以了。无需回调这么麻烦。

相关推荐

Global site tag (gtag.js) - Google Analytics