Hibernate 是對JDBC的輕量級對象封裝,Hibernate本身是不具備Transaction處理功能的,Hibernate的Transaction實際上是底層的JDBC Transaction的封裝,或者是JTA Transaction的封裝,下面我們詳細的分析:
Hibernate可以配置為JDBCTransaction或者是JTATransaction,這取決于你在hibernate.properties中的配置:
#hibernate.transaction.factory_class net.sf.hibernate.transaction.JTATransactionFactory
#hibernate.transaction.factory_class net.sf.hibernate.transaction.JDBCTransactionFactory
如果你什么都不配置,默認情況下使用JDBCTransaction,如果你配置為:
hibernate.transaction.factory_class net.sf.hibernate.transaction.JTATransactionFactory
將使用JTATransaction
不管你準備讓Hibernate使用JDBCTransaction,還是JTATransaction,我的忠告就是什么都不配,將讓它保持默認狀態,如下:
#hibernate.transaction.factory_class net.sf.hibernate.transaction.JTATransactionFactory
#hibernate.transaction.factory_class net.sf.hibernate.transaction.JDBCTransactionFactory
在下面的分析中我會給出原因。
一、JDBC Transaction
看看使用JDBC Transaction的時候我們的代碼例子:
Session session = sf.openSession();
Transaction tx = session.beginTransactioin();
...
session.flush();
tx.commit();
session.close();
這是默認的情況,當你在代碼中使用Hibernate的Transaction的時候實際上就是JDBCTransaction。那么JDBCTransaction究竟是什么東西呢?來看看源代碼就清楚了:
Hibernate2.0.3源代碼中的類
net.sf.hibernate.transaction.JDBCTransaction:
public void begin() throws HibernateException {
...
if (toggleAutoCommit) session.connection().setAutoCommit(false);
...
}
這是啟動Transaction的方法,看到 connection().setAutoCommit(false) 了嗎?是不是很熟悉?
再來看
public void commit() throws HibernateException {
...
try {
if ( session.getFlushMode()!=FlushMode.NEVER ) session.flush();
try {
session.connection().commit();
committed = true;
}
...
toggleAutoCommit();
}
這是提交方法,看到connection().commit() 了嗎?下面就不用我多說了,這個類代碼非常簡單易懂,通過閱讀使我們明白Hibernate的Transaction都在干了些什么?我現在把用 Hibernate寫的例子翻譯成JDBC,大家就一目了然了:
Connection conn = ...; <--- session = sf.openSession();
conn.setAutoCommit(false); <--- tx = session.beginTransactioin();
... <--- ...
conn.commit(); <--- tx.commit(); (對應左邊的兩句)
conn.setAutoCommit(true);
conn.close(); <--- session.close();
看明白了吧,Hibernate的JDBCTransaction根本就是conn.commit而已,根本毫無神秘可言,只不過在Hibernate 中,Session打開的時候,就會自動conn.setAutoCommit(false),不像一般的JDBC,默認都是true,所以你最后不寫 commit也沒有關系,由于Hibernate已經把AutoCommit給關掉了,所以用Hibernate的時候,你在程序中不寫 Transaction的話,數據庫根本就沒有反應。
如果你在EJB中使用Hibernate,或者準備用JTA來管理跨Session的長事務,那么就需要使用JTATransaction,先看一個例子:
javax.transaction.UserTransaction tx = new InitialContext().lookup("javax.transaction.UserTransaction");
Session s1 = sf.openSession();
...
s1.flush();
s1.close();
...
Session s2 = sf.openSession();
...
s2.flush();
s2.close();
tx.commit();
這是標準的使用JTA的代碼片斷,Transaction是跨Session的,它的生命周期比Session要長。如果你在EJB中使用 Hibernate,那么是最簡單不過的了,你什么Transaction代碼統統都不要寫了,直接在EJB的部署描述符上配置某某方法是否使用事務就可以了。
現在我們來分析一下JTATransaction的源代碼, net.sf.hibernate.transaction.JTATransaction:
public void begin(InitialContext context, ...
...
ut = (UserTransaction) context.lookup(utName);
...
看清楚了嗎? 和我上面寫的代碼 tx = new Initial Context?().lookup("javax.transaction.UserTransaction"); 是不是完全一樣?
public void commit() ...
...
if (newTransaction) ut.commit();
...
JTATransaction的控制稍微復雜,不過仍然可以很清楚的看出來Hibernate是如何封裝JTA的Transaction代碼的。
但是你現在是否看到了什么問題? 仔細想一下,Hibernate Transaction是從Session中獲得的,tx = session.beginTransaction(),最后要先提交tx,然后再session.close,這完全符合JDBC的 Transaction的操作順序,但是這個順序是和JTA的Transactioin操作順序徹底矛盾的?。?! JTA是先啟動Transaction,然后啟動Session,關閉Session,最后提交Transaction,因此當你使用JTA的 Transaction的時候,那么就千萬不要使用Hibernate的Transaction,而是應該像我上面的JTA的代碼片斷那樣使用才行。
總結:
1、在JDBC上使用Hibernate
必須寫上Hibernate Transaction代碼,否則數據庫沒有反應。此時Hibernate的Transaction就是Connection.commit而已
2、在JTA上使用Hibernate
寫JTA的Transaction代碼,不要寫Hibernate的Transaction代碼,否則程序會報錯
3、在EJB上使用Hibernate
什么Transactioin代碼都不要寫,在EJB的部署描述符里面配置
|---CMT(Container Managed Transaction)
|
|---BMT(Bean Managed Transaction)
|
|----JDBC Transaction
|
|----JTA Transaction
--------------------------------------------------------------------------------
提問:
javax.transaction.UserTransaction tx = new InitialContext().lookup("javax.transaction.UserTransaction");
Session s1 = sf.openSession();
...
s1.flush();
s1.close();
...
Session s2 = sf.openSession();
...
s2.flush();
s2.close();
tx.commit();
s1不關閉,使用s2進行操作的代碼中使用s1可不可以(我覺得這樣更加節約資源,不需要反復的連接、關閉)
但sf.opengSession()時,并沒有setAutoCommit(false),我想問的是,如果不編寫任何事務代碼,如:
Session s = sf.openSession();
......
s.close();
數據庫會不會有反應(此時應該是默認AutoCommit為true)。
不會有反應。在sf.openSession() 創建Session實例的時候,就已經調用了conn.setAutoCommit(false)了。
另外,我想問一下:
1. s.flush()是不是必須的
2. s.close()是不是一定要關閉
--------------------------------------------------------------------------------
回答:
s.flush不是必須的,s.close()會調用一次s.flush()
s.close()正常情況下應該關閉,除非你是用ThreadLocal管理Session。
s1不關閉,使用s2進行操作的代碼中使用s1可不可以(我覺得這樣更加節約資源,不需要反復的連接、關閉)
在這個例子中看不出來JTA的作用。
假設
Class A {
find() {
Session s1 = sf.openSession();
...
s1.flush();
s1.close();
}
}
Class B {
find() {
Session s2 = sf.openSession();
...
s2.flush();
s2.close();
}
}
Main {
tx = ...;
A.find();
B.find();
tx.commit();
} (全文完)
數據庫事務必須具備ACID特征,ACID是Atomic(原子性),Consistency(一致性),Isolation(隔離性),和Durability(持久性).
Atomic(原子性):指整個數據庫事務是不可分割的工作單元,只有事務中所有的操作執行成功,才算整個事務成功.
Consistency(一致性):指數據庫事務不能破換關系數據的完整性以及業務邏輯上的一致性(比如說銀行轉帳事務,不管事務成功還是
失敗,應該保證事務結束后的存款總額為原來的.)
Isolation(隔離性):指在并發環境中,當不同的事務同時操縱相同的數據時,每個事務都有各自的完整數據空間.
Durability(持久性):指的是只要事務成功工結束,它對數據庫所做的更新就必須永久保存下來,即使發生系統崩潰,從新啟動數據庫系統后,數據庫還能恢復到事務成功結束時候的狀態.
數據庫管理系統采用日志來保證事務的原子性,一致性和持久性,日志記錄了事務對數據庫所做的更新,如果某個事務在執行過程中發生錯誤,就可以根據日志,撤消事務對數據庫已做的更新,使數據庫退回到執行事務前的初始狀態.
數據庫管理系統采用鎖機制來實現事務的隔離性,當多個事務同時更新數據庫中的相同的數據時,只允許只有鎖的事務能更新該數據,其他事務必須等待,直到前一個事務釋放了鎖,其他事務才有機會更新該數據。
(POJOs IN ACTION中文版)
隔離的(isolated)數據庫事務
有時,你可以直接依賴數據庫本身處理共享數據的并發訪問。可以將數據庫配置成執行相互隔離(isolated,用數據庫的行話來講)的數據庫事務。如果你還不熟悉這一概念,請別擔心,第12章里會進行詳細說明。眼下最關鍵的是要記住,如果應用程序使用完全隔離的事務,那么同時執行兩個事務的效果將與一個接一個執行這兩個事務完全等效。
從表面上看,這種方法看似非常簡單,但這類事務也存在問題,由于隔離事務如何實現完全由數據庫決定,因此有時它們會導致性能降低,令人無法接受。鑒于此,許多應用程序都避免使用這類事務,轉而采用所謂的樂觀(optimistic)或者悲觀(pessimistic)鎖,稍后將作描述。
樂觀鎖
處理并發更新的一種方式是使用樂觀鎖(optimistic locking)。樂觀鎖的工作原理是讓應用程序檢查它即將更新的數據是否已被另一個事務修改(自該數據上次讀取以來)。實現樂觀鎖的一種常見做法是在每個表里添加一個版本字段,每次應用程序更新數據表記錄時就增加這個版本字段。每個UPDATE語句中的WHERE子句會根據上次讀取的值來判斷這個版本號是否改變。通過查看PreparedStatement.executeUpdate()返回的記錄數,應用程序可以判斷UPDATE語句是否成功。如果這條記錄已被另一個事務更新或刪除,應用程序可以回滾這個事務,并重新開始。
在直接執行SQL語句的應用程序中,樂觀鎖機制的實現非常容易。不過,使用諸如JDO和Hibernate的持久層構架時,實現更為容易,因為它們已將樂觀鎖作為配置選項提供。一旦啟用該配置選項,持久層框架會自動生成SQL UPDATE語句,執行版本檢查。第12章將分析樂觀鎖的使用時機及其缺點,并向你展示怎樣在iBATIS、JDO和Hibernate中使用樂觀鎖。
樂觀鎖的名稱源自如下假定情況,即并發更新的幾率極小,此外應用程序并不阻止并發更新,而是檢測并發更新,并從并發更新中恢復過來。另一種方式是使用悲觀鎖(pessimistic locking),它假定并發更新將會發生,因此必須預先阻止。
悲觀鎖
不同于樂觀鎖的另一種方式是使用悲觀鎖。當讀取某些記錄時,事務先鎖住這些記錄,這樣可以防止其他事務訪問這些數據記錄。具體細節要視數據庫而定,不過糟糕的是,并非所有數據庫都支持悲觀鎖。如果數據庫支持悲觀鎖,在直接執行SQL語句的應用程序中,實現悲觀鎖非常容易。然而,正如你所預料的,在JDO或Hibernate應用程序中使用悲觀鎖更為容易。JDO以配置選項的方式提供悲觀鎖,而Hibernate則提供一個簡單實用的API,來鎖定對象。同樣,在第12章,你將學習何時使用悲觀鎖,分析其缺點,并看看怎樣在iBATIS、JDO和Hibernate中使用悲觀鎖。
除了處理單個數據庫事務里的并發,通常你還必須處理跨一系列數據庫事務的并發