Chinaunix首页 | 论坛 | 博客
  • 博客访问: 369658
  • 博文数量: 100
  • 博客积分: 2586
  • 博客等级: 少校
  • 技术积分: 829
  • 用 户 组: 普通用户
  • 注册时间: 2008-04-09 15:20
个人简介

我是一个Java爱好者

文章分类

全部博文(100)

文章存档

2014年(2)

2013年(7)

2012年(2)

2010年(44)

2009年(28)

2008年(17)

我的朋友

分类: Java

2009-09-21 22:24:00

Hibernate JDBC 的轻量级封装,本身并不具备事务管理能力。在事务管理层,
Hibernate
将其委托给底层的JDBC或者JTA,以实现事务管理和调度功能。
Hibernate
的默认事务处理机制基于JDBC Transaction。我们也可以通过配置文
件设定采用JTA作为事务管理实现:

Java代码

  1.   
  2.   
  3. ……   
  4.   
  5. net.sf.hibernate.transaction.JTATransactionFactory   
  6.   
  7.   
  8. ……   
  9.   
  10.   

……

net.sf.hibernate.transaction.JTATransactionFactory

……


基于JDBC的事务管理将事务管理委托给JDBC 进行处理无疑是最简单的实现方式,Hibernate 对于JDBC事务的封装也极为简单。
我们来看下面这段代码:

Java代码

  1. session = sessionFactory.openSession();   
  2. Transaction tx = session.beginTransaction();   
  3. ……   
  4. tx.commit();  

session = sessionFactory.openSession();

Transaction tx = session.beginTransaction();

……

tx.commit();


JDBC层面而言,上面的代码实际上对应着:

Java代码

  1. Connection dbconn = getConnection();   
  2. dbconn.setAutoCommit(false);   
  3. ……   
  4. dbconn.commit();  

Connection dbconn = getConnection();

dbconn.setAutoCommit(false);

……

dbconn.commit();


就是这么简单,Hibernate并没有做更多的事情(实际上也没法做更多的事情),只是将这样的JDBC代码进行了封装而已。
这里要注意的是,在sessionFactory.openSession()中,hibernate会初始化数据库连接,与此同时,将其AutoCommit 设为关闭状态(false)。而其后,在Session.beginTransaction 方法中,Hibernate 会再次确认Connection AutoCommit 属性被设为关闭状态( 为了防止用户代码对session Connection.AutoCommit属性进行修改)。
这也就是说,我们一开始从SessionFactory获得的session,其自动提交属性就已经被关闭(AutoCommit=false),下面的代码将不会对数据库产生任何效果:

Java代码

  1. session = sessionFactory.openSession();   
  2. session.save(user);   
  3. session.close();  

session = sessionFactory.openSession();

session.save(user);

session.close();


这实际上相当于 JDBC ConnectionAutoCommit属性被设为false,执行了若干JDBC操作之后,没有调用commit操作即将Connection关闭。如果要使代码真正作用到数据库,我们必须显式的调用Transaction指令:

Java代码

  1. session = sessionFactory.openSession();   
  2. Transaction tx = session.beginTransaction();   
  3. session.save(user);   
  4. tx.commit();   
  5. session.close();  

session = sessionFactory.openSession();

Transaction tx = session.beginTransaction();

session.save(user);

tx.commit();

session.close();


基于JTA的事务管理
JTA
提供了跨Session 的事务管理能力。这一点是与JDBC Transaction 最大的差异。
JDBC
事务由Connnection管理,也就是说,事务管理实际上是在JDBC Connection中实现。事务周期限于Connection的生命周期之类。同样,对于基于JDBC TransactionHibernate 事务管理机制而言,事务管理在Session 所依托的JDBC Connection中实现,事务周期限于Session的生命周期。
JTA
事务管理则由 JTA 容器实现,JTA 容器对当前加入事务的众多Connection
行调度,实现其事务性要求。JTA的事务周期可横跨多个JDBC Connection生命周期。
同样对于基于JTA事务的Hibernate而言,JTA事务横跨可横跨多个Session
JTA
事务是由JTA Container 维护,而参与事务的Connection无需对事务管理进行干涉。这也就是说,如果采用JTA Transaction,我们不应该再调用HibernateTransaction功能。
上面基于JDBC Transaction的正确代码,这里就会产生问题:

Java代码

  1. public class ClassA{   
  2. public void saveUser(User user){   
  3. session = sessionFactory.openSession();   
  4. Transaction tx = session.beginTransaction();   
  5. session.save(user);   
  6. tx.commit();   
  7. session.close();   
  8. }   
  9. }   
  10. public class ClassB{   
  11. public void saveOrder(Order order){   
  12. session = sessionFactory.openSession();   
  13. Transaction tx = session.beginTransaction();   
  14. session.save(order);   
  15. tx.commit();   
  16. session.close();   
  17. }   
  18. }   
  19. public class ClassC{   
  20. public void save(){   
  21. ……   
  22. UserTransaction tx = new InitialContext().lookup(“……”);   
  23. ClassA.save(user);   
  24. ClassB.save(order);   
  25. tx.commit();   
  26. ……   
  27. }   
  28. }  

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();

……

}

}

这里有两个类ClassAClassB,分别提供了两个方法:saveUsersaveOrder
用于保存用户信息和订单信息。在ClassC中,我们接连调用了ClassA.saveUser方法和ClassB.saveOrder 方法,同时引入了JTA 中的UserTransaction 以实现ClassC.save方法中的事务性。问题出现了,ClassA ClassB 中分别都调用了Hibernate Transaction 功能。在Hibernate JTA 封装中,Session.beginTransaction 同样也执行了InitialContext.lookup方法获取UserTransaction实例,Transaction.commit方法同样也调用了UserTransaction.commit方法。实际上,这就形成了两个嵌套式的JTA TransactionClassC 申明了一个事务,而在ClassC 事务周期内,ClassA ClassB也企图申明自己的事务,这将导致运行期错误。因此,如果决定采用JTA Transaction,应避免再重复调用Hibernate
Transaction
功能,上面的代码修改如下:

Java代码

  1. public class ClassA{   
  2. public void save(TUser user){   
  3. session = sessionFactory.openSession();   
  4. session.save(user);   
  5. session.close();   
  6. }   
  7. ……   
  8. }   
  9. public class ClassB{   
  10. public void save (Order order){   
  11. session = sessionFactory.openSession();   
  12. session.save(order);   
  13. session.close();   
  14. }   
  15. ……   
  16. }   
  17. public class ClassC{   
  18. public void save(){   
  19. ……   
  20. UserTransaction tx = new InitialContext().lookup(“……”);   
  21. classA.save(user);   
  22. classB.save(order);   
  23. tx.commit();   
  24. ……   
  25. }   
  26. }  

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方法,也可以改成这样:

Java代码

  1. public class ClassC{   
  2. public void save(){   
  3. ……   
  4. session = sessionFactory.openSession();   
  5. Transaction tx = session.beginTransaction();   
  6. classA.save(user);   
  7. classB.save(order);   
  8. tx.commit();   
  9. ……   
  10. }   
  11. }  

public class ClassC{

public void save(){

……

session = sessionFactory.openSession();

Transaction tx = session.beginTransaction();

classA.save(user);

classB.save(order);

tx.commit();

……

}

}


实际上,这是利用Hibernate来完成启动和提交UserTransaction的功能,但这样的做法比原本直接通过InitialContext获取UserTransaction 的做法消耗了更多的资源,得不偿失。
EJB 中使用JTA Transaction 无疑最为简便,我们只需要将save 方法配置为JTA事务支持即可,无需显式申明任何事务,下面是一个Session Beansave方法,它的事务属性被申明为“Required”EJB容器将自动维护此方法执行过程中的事务:

Java代码

  1. /**  
  2. * @ejb.interface-method  
  3. * view-type="remote"  
  4. *  
  5. * @ejb.transaction type = "Required"  
  6. **/  
  7. public void save(){   
  8. //EJB环境中,通过部署配置即可实现事务申明,而无需显式调用事务   
  9. classA.save(user);   
  10. classB.save(log);   
  11. }//方法结束时,如果没有异常发生,则事务由EJB容器自动提交。
阅读(881) | 评论(1) | 转发(0) |
给主人留下些什么吧!~~

chinaunix网友2010-03-30 17:49:06

Hibernate 3 不是如此