<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    176142998

      BlogJava :: 首頁 :: 聯系 :: 聚合  :: 管理
      116 Posts :: 0 Stories :: 45 Comments :: 0 Trackbacks
    從4個層面分析這部分實現: 
    1. iBatis的基本實現
    2. 基于事務的iBatis的基本實現
    3. 基于事務的Spring+iBatis實現
    4. 基于回調方式的Spring+iBatis實現

    1.iBatis的基本實現

    iBatis通過SqlMapClient提供了一組方法用于批處理實現:
    1. startBatch() 開始批處理
    2. executeBatch() 執行批處理

    代碼如下:
    Java代碼 復制代碼 收藏代碼
    1. public void create(List<Reply> replyList) {   
    2.   
    3.     try {   
    4.         // 開始批處理   
    5.         sqlMapClient.startBatch();   
    6.   
    7.         for (Reply reply: replyList) {   
    8.             // 插入操作   
    9.             sqlMapClient.insert("Reply.create", reply);   
    10.         }   
    11.         // 執行批處理   
    12.         sqlMapClient.executeBatch();   
    13.   
    14.     } catch (Exception e) {   
    15.         e.printStackTrace();   
    16.     }   
    17. }  

    這是基于iBatis的最基本實現,如果你一步一步debug,你會發現:其實,數據庫已經執行了插入操作!
    因此,除了這兩個核心方法外,你還需要開啟事務支持。否則,上述代碼只不過是個空架子!

    2.基于事務的iBatis的基本實現
    事務處理:
    1. startTransaction() 開始事務
    2. commitTransaction() 提交事務
    3. endTransaction() 結束事務


    我們以insert操作為例,把它們結合到一起:
    Java代碼 復制代碼 收藏代碼
    1. public void create(List<Reply> replyList) {   
    2.   
    3.     try {   
    4.         // 開始事務   
    5.         sqlMapClient.startTransaction();   
    6.         // 開始批處理   
    7.         sqlMapClient.startBatch();   
    8.   
    9.         for (Reply reply: replyList) {   
    10.             // 插入操作   
    11.             sqlMapClient.insert("Reply.create", reply);   
    12.         }   
    13.         // 執行批處理   
    14.         sqlMapClient.executeBatch();   
    15.   
    16.         // 提交事務   
    17.         sqlMapClient.commitTransaction();   
    18.   
    19.     } catch (Exception e) {   
    20.         e.printStackTrace();   
    21.     } finally {     
    22.              try {   
    23.             // 結束事務   
    24.             sqlMapClient.endTransaction();   
    25.                 } catch (SQLException e) {   
    26.                          e.printStackTrace();   
    27.                      }   
    28.     }     
    29. }  

    replyList是一個List,要把這個List插入到數據庫,就需要經過這三個步驟:
    1. 開始批處理 startBatch()
    2. 插入      insert()
    3. 執行批處理 executeBatch()

    如果要在Spring+iBatis中進行批處理實現,需要注意使用同一個sqlMapClient!同時,將提交事務的工作交給Spring統一處理!

    3.基于事務的Spring+iBatis實現
    Java代碼 復制代碼 收藏代碼
    1. public void create(List<Reply> replyList) {   
    2.     if (!CollectionUtils.isEmpty(replyList)) {   
    3.         // 注意使用同一個SqlMapClient會話   
    4.         SqlMapClient sqlMapClient = sqlMapClientTemplate.getSqlMapClient();   
    5.   
    6.         try {   
    7.             // 開始事務   
    8.             sqlMapClient.startTransaction();   
    9.             // 開始批處理   
    10.             sqlMapClient.startBatch();   
    11.             for (Reply reply : replyList) {   
    12.                 // 插入操作   
    13.                 sqlMapClient.insert("Reply.create", reply);   
    14.             }   
    15.   
    16.             // 執行批處理   
    17.             sqlMapClient.executeBatch();   
    18.             // 提交事務 交給Spring統一控制   
    19.             // sqlMapClient.commitTransaction();   
    20.   
    21.         } catch (Exception e) {   
    22.             e.printStackTrace();   
    23.         } finally {     
    24.                  try {   
    25.                 // 結束事務   
    26.                 sqlMapClient.endTransaction();   
    27.                     } catch (SQLException e) {   
    28.                              e.printStackTrace();   
    29.                          }   
    30.         }     
    31.     }   
    32. }  

    注意使用同一個sqlMapClient:
    SqlMapClient sqlMapClient = sqlMapClientTemplate.getSqlMapClient();
    如果直接sqlMapClientTemplate執行insert()方法,將會造成異常!

    想想,還有什么問題?其實問題很明顯,雖然解決了批處理實現的問題,卻造成了事務代碼入侵的新問題。 這么做,有點惡心!
    除此之外,異常的處理也很惡心,不能夠簡單的包裝為 DataAccessException 就無法被Spring當作統一的數據庫操作異常做處理。


    4.基于回調方式的Spring+iBatis實現
    如果觀察過Spring的源代碼,你一定知道,Spring為了保持事務統一控制,在實現ORM框架時通常都采用了回調模式,從而避免了事務代碼入侵的可能!
    修改后的代碼如下:
    Java代碼 復制代碼 收藏代碼
    1. @SuppressWarnings("unchecked")   
    2. public void create(final List<Reply> replyList) {   
    3.     // 執行回調   
    4.     sqlMapClientTemplate.execute(new SqlMapClientCallback() {   
    5.         // 實現回調接口   
    6.         public Object doInSqlMapClient(SqlMapExecutor executor)   
    7.                 throws SQLException {   
    8.             // 開始批處理   
    9.             executor.startBatch();   
    10.             for (Reply reply : replyList) {   
    11.                 // 插入操作   
    12.                 executor.insert("Reply.create", reply);   
    13.   
    14.             }   
    15.             // 執行批處理   
    16.             executor.executeBatch();   
    17.   
    18.             return null;   
    19.   
    20.         }   
    21.     });   
    22.   
    23. }  

    注意,待遍歷的參數replyList需要加入final標識!即,待遍歷對象不能修改!
    引用
    public void create(final List<Reply> replyList)

    這樣做,就將事務處理的控制權完全交給了Spring!
    簡述:
    1. SqlMapClientCallback 回調接口
    2. doInSqlMapClient(SqlMapExecutor executor) 回調實現方法
    3. DataAccessException 最終可能拋出的異常
    posted on 2011-04-21 10:15 飛飛 閱讀(955) 評論(0)  編輯  收藏

    只有注冊用戶登錄后才能發表評論。


    網站導航:
     
    主站蜘蛛池模板: 又长又大又粗又硬3p免费视频| 97亚洲熟妇自偷自拍另类图片 | 水蜜桃视频在线观看免费播放高清| 日本成人免费在线| 亚洲av日韩av永久无码电影 | 一级做a爱过程免费视| 亚洲av日韩av欧v在线天堂| 黄色网址免费在线| 亚洲av永久中文无码精品综合 | 亚洲欧洲日韩极速播放| 无码国产精品一区二区免费I6| 亚洲国产一区在线观看| 国产黄在线播放免费观看| 亚洲无码日韩精品第一页| 成av免费大片黄在线观看| 久久亚洲精品中文字幕无码 | 亚洲爆乳AAA无码专区| 亚洲成aⅴ人片久青草影院| 久久久久亚洲精品日久生情| 久久精品国产免费观看三人同眠| 亚洲一区在线免费观看| 日韩特黄特色大片免费视频| 亚州**色毛片免费观看| 亚洲AV无码成人专区片在线观看| 免费A级毛片无码专区| 亚洲一卡2卡3卡4卡5卡6卡| vvvv99日韩精品亚洲| 日韩免费在线视频| 亚洲综合av一区二区三区不卡| 国产免费观看青青草原网站| 手机看片国产免费永久| jlzzjlzz亚洲jzjzjz| 亚洲国产成人a精品不卡在线| 日韩视频免费在线观看| 亚洲av无码专区首页| 亚洲国产另类久久久精品黑人| 无码乱肉视频免费大全合集| 农村寡妇一级毛片免费看视频| 亚洲一区二区在线视频| 国产精品免费视频播放器| 亚洲国产精品嫩草影院|