Hibernate事務(wù)管理機(jī)制剖析
在向大家詳細(xì)介紹Hibernate事務(wù)管理機(jī)制之前,首先讓大家了解下JTA事務(wù)管理,然后全面介紹Hibernate事務(wù)管理機(jī)制。
JTA 提供了跨Session 的事務(wù)管理能力。這一點(diǎn)是與JDBC Transaction ***的差異。JDBC 事務(wù)由Connnection管理,也就是說,事務(wù)管理實(shí)際上是在JDBC Connection中實(shí)現(xiàn)。事務(wù)周期限于Connection的生命周期之類。同樣,對于基于JDBC Transaction的Hibernate事務(wù)管理機(jī)制而言,事務(wù)管理在Session 所依托的JDBC Connection中實(shí)現(xiàn),事務(wù)周期限于Session的生命周期。
JTA事務(wù)管理則由 JTA 容器實(shí)現(xiàn),JTA 容器對當(dāng)前加入事務(wù)的眾多Connection 進(jìn)行調(diào)度,實(shí)現(xiàn)其事務(wù)性要求。JTA的事務(wù)周期可橫跨多個JDBC Connection生命周期。同樣對于基于JTA事務(wù)的Hibernate而言,JTA事務(wù)橫跨可橫跨多個Session。JTA 事務(wù)是由JTA Container 維護(hù),而參與事務(wù)的Connection無需對事務(wù)管理進(jìn)行干涉。這也就是說,如果采用JTA Transaction,我們不應(yīng)該再調(diào)用HibernateTransaction功能。
上面基于JDBC Transaction的正確代碼,這里就會產(chǎn)生問題:
- public class ClassA{
- public void saveUser(User user){
- session = sessionFactory.openSession();
- Transaction tx = session.beginTransaction();
- session.save(user);
- tx.commit();
- session.close();
- }
- }
- public class ClassB{
- public void saveOrder(Order order){
- session = sessionFactory.openSession();
- Transaction tx = session.beginTransaction();
- session.save(order);
- tx.commit();
- session.close();
- }
- }
- public class ClassC{
- public void save(){
- ……
- UserTransaction tx = new InitialContext().lookup(“……”);
- ClassA.save(user);
- ClassB.save(order);
- tx.commit();
- ……
- }
- }
這里有兩個類ClassA和ClassB,分別提供了兩個方法:saveUsersaveOrder,用于保存用戶信息和訂單信息。在ClassC中,我們接連調(diào)用了ClassA.saveUser方法和ClassB.saveOrder 方法,同時(shí)引入了JTA 中的UserTransaction 以實(shí)現(xiàn)ClassC.save方法中的事務(wù)性。問題出現(xiàn)了,ClassA 和ClassB 中分別都調(diào)用了Hibernate 的Transaction 功能。在Hibernate 的JTA 封裝中,Session.beginTransaction 同樣也執(zhí)行了InitialContext.lookup方法獲取UserTransaction實(shí)例,Transaction.commit方法同樣也調(diào)用了UserTransaction.commit方法。
實(shí)際上,這就形成了兩個嵌套式的JTA Transaction:ClassC 申明了一個事務(wù),而在ClassC 事務(wù)周期內(nèi),ClassA 和ClassB也企圖申明自己的事務(wù),這將導(dǎo)致運(yùn)行期錯誤。因此,如果決定采用JTA Transaction,應(yīng)避免再重復(fù)調(diào)用Hibernate 的Transaction功能,上面的代碼修改如下:
- public class ClassA{
- public void save(TUser user){
- session = sessionFactory.openSession();
- session.save(user);
- session.close();
- }
- ……
- }
- public class ClassB{
- public void save (Order order){
- session = sessionFactory.openSession();
- session.save(order);
- session.close();
- }
- ……
- }
- public class ClassC{
- public void save(){
- ……
- UserTransaction tx = new InitialContext().lookup(“……”);
- classA.save(user);
- classB.save(order);
- tx.commit();
- ……
- }
- }
上面代碼中的ClassC.save方法,也可以改成這樣:
- public class ClassC{
- public void save(){
- ……
- session = sessionFactory.openSession();
- Transaction tx = session.beginTransaction();
- classA.save(user);
- classB.save(order);
- tx.commit();
- ……
- }
- }
實(shí)際上,這是利用Hibernate來完成啟動和提交UserTransaction的功能,但這樣的做法比原本直接通過InitialContext獲取UserTransaction 的做法消耗了更多的資源,得不償失。
在EJB 中使用JTA Transaction 無疑最為簡便,我們只需要將save 方法配置為JTA事務(wù)支持即可,無需顯式申明任何事務(wù),下面是一個Session Bean的save方法,它的事務(wù)屬性被申明為“Required”,EJB容器將自動維護(hù)此方法執(zhí)行過程中的事務(wù):
- /**
- * @ejb.interface-method
- * view-type="remote"
- *
- * @ejb.transaction type = "Required"
- **/
- public void save(){
- //EJB環(huán)境中,通過部署配置即可實(shí)現(xiàn)事務(wù)申明,而無需顯式調(diào)用事務(wù)
- classA.save(user);
- classB.save(log);
- }
- //方法結(jié)束時(shí),如果沒有異常發(fā)生,則事務(wù)由EJB容器自動提交。
以上介紹Hibernate事務(wù)管理機(jī)制。
【編輯推薦】