176142998

從4個(gè)層面分析這部分實(shí)現(xiàn)： 

1. iBatis的基本實(shí)現(xiàn)
2. 基于事務(wù)的iBatis的基本實(shí)現(xiàn)
3. 基于事務(wù)的Spring+iBatis實(shí)現(xiàn)
4. 基于回調(diào)方式的Spring+iBatis實(shí)現(xiàn)

1.iBatis的基本實(shí)現(xiàn)
iBatis通過SqlMapClient提供了一組方法用于批處理實(shí)現(xiàn)：

1. startBatch() 開始批處理
2. executeBatch() 執(zhí)行批處理

代碼如下：

	public void create(List<Reply> replyList) {
try {
// 開始批處理
sqlMapClient.startBatch();
for (Reply reply: replyList) {
// 插入操作
sqlMapClient.insert("Reply.create", reply);
}
// 執(zhí)行批處理
sqlMapClient.executeBatch();
} catch (Exception e) {
e.printStackTrace();
}
}

這是基于iBatis的最基本實(shí)現(xiàn)，如果你一步一步debug，你會(huì)發(fā)現(xiàn)：其實(shí)，數(shù)據(jù)庫已經(jīng)執(zhí)行了插入操作！
因此，除了這兩個(gè)核心方法外，你還需要開啟事務(wù)支持。否則，上述代碼只不過是個(gè)空架子！

2.基于事務(wù)的iBatis的基本實(shí)現(xiàn)
事務(wù)處理：

1. startTransaction() 開始事務(wù)
2. commitTransaction() 提交事務(wù)
3. endTransaction() 結(jié)束事務(wù)

我們以insert操作為例，把它們結(jié)合到一起：

	public void create(List<Reply> replyList) {
try {
// 開始事務(wù)
sqlMapClient.startTransaction();
// 開始批處理
sqlMapClient.startBatch();
for (Reply reply: replyList) {
// 插入操作
sqlMapClient.insert("Reply.create", reply);
}
// 執(zhí)行批處理
sqlMapClient.executeBatch();
// 提交事務(wù)
sqlMapClient.commitTransaction();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
// 結(jié)束事務(wù)
sqlMapClient.endTransaction();
} catch (SQLException e) {
e.printStackTrace();
}
}
}

replyList是一個(gè)List，要把這個(gè)List插入到數(shù)據(jù)庫，就需要經(jīng)過這三個(gè)步驟：

1. 開始批處理 startBatch()
2. 插入      insert()
3. 執(zhí)行批處理 executeBatch()

如果要在Spring+iBatis中進(jìn)行批處理實(shí)現(xiàn)，需要注意使用同一個(gè)sqlMapClient！同時(shí)，將提交事務(wù)的工作交給Spring統(tǒng)一處理！

3.基于事務(wù)的Spring+iBatis實(shí)現(xiàn)

	public void create(List<Reply> replyList) {
if (!CollectionUtils.isEmpty(replyList)) {
// 注意使用同一個(gè)SqlMapClient會(huì)話
SqlMapClient sqlMapClient = sqlMapClientTemplate.getSqlMapClient();
try {
// 開始事務(wù)
sqlMapClient.startTransaction();
// 開始批處理
sqlMapClient.startBatch();
for (Reply reply : replyList) {
// 插入操作
sqlMapClient.insert("Reply.create", reply);
}
// 執(zhí)行批處理
sqlMapClient.executeBatch();
// 提交事務(wù) 交給Spring統(tǒng)一控制
// sqlMapClient.commitTransaction();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
// 結(jié)束事務(wù)
sqlMapClient.endTransaction();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}

注意使用同一個(gè)sqlMapClient：
SqlMapClient sqlMapClient = sqlMapClientTemplate.getSqlMapClient();
如果直接sqlMapClientTemplate執(zhí)行insert()方法，將會(huì)造成異常！

想想，還有什么問題？其實(shí)問題很明顯，雖然解決了批處理實(shí)現(xiàn)的問題，卻造成了事務(wù)代碼入侵的新問題。 這么做，有點(diǎn)惡心！
除此之外，異常的處理也很惡心，不能夠簡(jiǎn)單的包裝為 DataAccessException 就無法被Spring當(dāng)作統(tǒng)一的數(shù)據(jù)庫操作異常做處理。


4.基于回調(diào)方式的Spring+iBatis實(shí)現(xiàn)
如果觀察過Spring的源代碼，你一定知道，Spring為了保持事務(wù)統(tǒng)一控制，在實(shí)現(xiàn)ORM框架時(shí)通常都采用了回調(diào)模式，從而避免了事務(wù)代碼入侵的可能！
修改后的代碼如下：

	@SuppressWarnings("unchecked")
public void create(final List<Reply> replyList) {
// 執(zhí)行回調(diào)
sqlMapClientTemplate.execute(new SqlMapClientCallback() {
// 實(shí)現(xiàn)回調(diào)接口
public Object doInSqlMapClient(SqlMapExecutor executor)
throws SQLException {
// 開始批處理
executor.startBatch();
for (Reply reply : replyList) {
// 插入操作
executor.insert("Reply.create", reply);
}
// 執(zhí)行批處理
executor.executeBatch();
return null;
}
});
}

注意，待遍歷的參數(shù)replyList需要加入final標(biāo)識(shí)！即，待遍歷對(duì)象不能修改！

這樣做，就將事務(wù)處理的控制權(quán)完全交給了Spring！
簡(jiǎn)述：

1. SqlMapClientCallback 回調(diào)接口
2. doInSqlMapClient(SqlMapExecutor executor) 回調(diào)實(shí)現(xiàn)方法
3. DataAccessException 最終可能拋出的異常