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(); } }
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(); } } }
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(); } } } }
@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; } }); }
Copyright @ 飛飛 Powered by: .Text and ASP.NET Theme by: .NET Monster