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

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

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

    yxhxj2006

    常用鏈接

    統計

    最新評論

    最簡單的Java處理事務

    用一個簡單的例子來說明Java處理事務:
    我們用銀行轉賬的時候可以簡單的看成是兩步操作--將錢從A賬戶轉出和將錢轉到B賬戶。問題來了,如果我從A賬戶轉出之后,突然無法連接數據庫了,這樣錢就不能轉到B賬戶了,可是A的錢已經沒了。所以我們應該把這兩步看成是一個整體,要么同時成功,要么什么都不做。這就是事務了。
     
    Java中是如何處理事務的呢?
    我們從java.sql.Connection說起,Connection表示了一個和數據庫的鏈接,可以通過Connection來對數據庫操作。在通常情況是Connection的屬性是自動提交的,也就是說每次的操作真的更新了數據庫,真的無法回退了。針對上述的例子,一旦A賬戶的錢轉出了,即對數據庫進行了更新操作了,但是錢并沒有轉到B的賬戶,這筆錢就白白“不見”了。這并不是我們希望的。 
        我們希望的是:看起來成功了,但是沒有真的操作數據庫,知道我想讓他真的發生??梢酝ㄟ^Connection的setAutoCommit(false)讓Connection不自動提交你的數據,除非你真的想提交。那么如何讓操作真的發生呢?可以使用Connection的commit方法。如何讓操作回退呢?使用rollback方法。
    例如: 
      try{ 
      Connection conn = getConnection(); // 不管如何我們得到了鏈接 
      conn.setAutoCommit(false); 
      // A賬戶轉出
      // B賬戶轉入
      conn.commit(); // 成功的情況下,提交更新。 
      } catch(SQLException ex) { 
      conn.rollback(); // 失敗的情況下,回滾所有的操作 
      } finally { 
      conn.close();
      } 
        這里有一點非常重要,事務是基于數據庫鏈接的。所以在但數據庫的情況下,事務操作很簡單。 
      那么如果表分布在兩個不同的數據庫中呢? 
      例如訂單表在訂單庫中,庫存表在庫存庫中,那么我們如何處理這樣的事務呢? 
      需要注意,提交也可以遇到錯誤呀! 
      try{ 
      Connection conn1 = getConnection1(); 
      Connection conn2 = getConnection2(); 
      // 基于conn1做更新操作 
      // 基于conn2做更新操作 
      try{ 
      conn1.commit() 
      } catch(SQLExcetion ) { 
      conn1.rollback(); 
      } 
      try { 
      conn2.commit(); 
      } catch(SQLException ) { 
      conn2.rollbakc(); 
      // 保證務必將剛才的更新還原回來。 
      } 
      } catch(SQLException ex) { 
      // 如果更新失敗,conn1.rollback 
      // 如果更新失敗,conn1.rollback && conn2.rollback 
      } finally { 
      conn1.close(); 
      conn2.close(); 
      } 
      看看上述的代碼就知道,其實操作非常的復雜,甚至:保證肯定還原剛才更新的賬戶根本無法保證。
    在上述情況下的事務可以稱之為分布式事務,通過上述的代碼中事務同時提交處理的部分我們可以得出,要想處理分布式事務,必須有獨立于數據庫的第三方的事務處理組件。 
      幸運的是通常情況下,JavaEE兼容的應用服務器,例如:Weblogic,Websphere,JBoss,Glassfish等都有這種分布式事務處理的組件。 

    如何使用應用服務器的分布式事務管理器處理分布式事務? 
      以galssfish為例 
      1 建立對應兩個數據庫的XA(javax.sql.XADataSource)類型的數據源。 
      2 使用UserTransaction來保證分布式事務。 
      try{ 
      Connection conn1 = datasource1.getConnection(); 
      Connection conn2 = datasource2.getConnection(); 
      UserTransaction ut = getUserTransaction(); 
      ut.begin(); 
      // A賬戶轉出
      // B賬戶轉入
      ut.commit(); // 成功的情況下,提交更新。 
      } catch(SQLException ex) { 
      ut.rollback(); // 失敗的情況下,回滾所有的操作 
      } finally { 
      conn.close(); 
      } 
      如何獲取UserTransaction呢?可以使用如下方法 
      UserTransaction tx = (UserTransaction) ctx.lookup("jndi/UserTransaction"); 

    posted on 2012-07-19 15:35 奮斗成就男人 閱讀(186) 評論(0)  編輯  收藏


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


    網站導航:
     
    主站蜘蛛池模板: 亚洲不卡视频在线观看| 精品久久久久国产免费| 亚洲国产精品狼友中文久久久| 亚洲伦理一二三四| 中国在线观看免费高清完整版| 亚洲国产成人久久三区| 在线v片免费观看视频| 亚洲中文字幕AV每天更新| 日本免费人成黄页在线观看视频| 亚洲 欧洲 视频 伦小说| 日韩成人免费aa在线看| 边摸边吃奶边做爽免费视频99 | 国产大片线上免费观看 | 91亚洲精品自在在线观看| 野花高清在线电影观看免费视频| 亚洲伊人久久大香线蕉结合| 在线a人片天堂免费观看高清| 亚洲A∨精品一区二区三区下载| 日本不卡在线观看免费v| 免费福利资源站在线视频| 综合亚洲伊人午夜网 | 亚洲五月综合网色九月色| 日韩成人免费aa在线看| 老司机精品免费视频| 久久精品国产亚洲av影院| 成人黄18免费视频| 免费一级全黄少妇性色生活片 | 特级aa**毛片免费观看| 亚洲成a人片77777kkkk| 日韩精品无码区免费专区 | 国产亚洲精品a在线观看| 91精品国产免费网站| 亚洲中文字幕久久精品无码A| 亚洲中文字幕丝袜制服一区| **毛片免费观看久久精品| 美女被羞羞网站免费下载| 亚洲人成在线影院| 国产又大又黑又粗免费视频| 四虎国产成人永久精品免费| 亚洲精品无码av片| 亚洲ⅴ国产v天堂a无码二区|