在Hibernate中,可以通过代码来操作管理事务,如通过
“Transaction tx=session.beginTransactiong();”
开启一个事务,持久化操作后,通过"tx.commit();" 提交事务;如果事务出现异常,又通过“tx.rollback();"操作来撤销事务(事务回滚)。
除了在代码中对事务开启,提交和回滚操作外,还可以在hibernate的配置文件中对事务进行配置。配置文件中,可以设置事务的隔离级别。其具体的配置方法是在hibernate.cfg.xml文件中的
<session-factory>标签元素中进行的。配置方法如下所示。
<!--
事务隔离级别
hibernate.connection.isolation = 4
1-- Read uncommitted isolation
2-- Read committed isolation
4-- Repeatable read isolation
8-- Serializable isolation
-->
<property name="hibernate.connection.isolation">4</property>
到这里我们已经设置了事务的隔离级别,那么我们在真正进行事务管理的时候,需要考虑事务的应用场景,也就是说我们的事务控制不应该是在DAO层实现的,应该在Service层实现,并且在Service中调用多个DAO实现一个业务逻辑的操作。具体操作如下显示:
其实最主要的是如何保证在Service中开启的事务时使用的Session对象和DAO中多个操作使用的是同一个Session对象。
其实有两种办法可以实现:
1. 可以在业务层获取到Session,并将Session作为参数传递给DAO。
2. 可以使用ThreadLocal将业务层获取的Session绑定到当前线程中,然后再DAO中获取Session的时候,都从当前线程中获取。
其实使用第二种方式肯定是最优方案,那么具体的实现已经不用我们来完成了,hibernate的内部已经将这个事情做完了。我们只需要完成一段配置即可。
Hibernate5中自身提供了三种管理Session对象的方法
Session对象的生命周期与本地线程绑定
Session对象的生命周期与JTA事务绑定
Hibernate委托程序管理Session对象的生命周期
在Hibernate的配置文件中,hibernate.current_session_context_class属性用于指定Session管理方式,可选值包括:
1. thread:Session对象的生命周期与本地线程绑定(推荐)
2. jta:Session对象的生命周期与JTA事务绑定
3. managed:hibernate委托程序来管理Session对象的生命周期。
在hibernate.cfg.xml中进行如下配置:
<!-- 配置session绑定本地线程 -->
<property name="hibernate.current_session_context_class">thread</property>
Hibernate提供sessionFactory.getCurrentSession()创建一个session和ThreadLocal绑定方法。
在HibernateUtils工具类中更改getCurrentSession方法:
public static Session getCurrentSession() {
return sessionFactory.getCurrentSession();
}
而且Hibernate中提供的这个与线程绑定的session可以不用关闭,当线程执行结束后,就会自动关闭了。
所以最终的配置文件如下:
1 <?xml version="1.0" encoding="UTF-8"?> 2 <!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd" > 3 <hibernate-configuration> 4 <session-factory> 5 <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property> 6 <property name="hibernate.connection.url">jdbc:mysql:///day24_db</property> 7 <property name="hibernate.connection.username">root</property> 8 <property name="hibernate.connection.password">toor</property> 9 <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property> 10 <property name="hibernate.show_sql">true</property> 11 <property name="hibernate.format_sql">true</property> 12 <property name="hibernate.hbm2ddl.auto">update</property> 13 <!-- 配置C3P0连接池 14 <property name="connection.provider_class">org.hibernate.c3p0.internal.C3P0ConnectionProvider</property> 15 在连接池中可用的数据库连接的最少数目 16 <property name="c3p0.min_size">5</property> 17 在连接池中所有数据库连接的最大数目 18 <property name="c3p0.max_size">20</property> 19 设定数据库连接的过期时间,以秒为单位,如果连接池中的某个数据库连接处于 20 空闲状态的时间超过了timeout时间,就会从连接池中清除 21 <property name="c3p0.timeout"></property> 22 每3000秒检查所有连接池中的空闲连接,以秒为单位 23 <property name="c3p0.idle_test_period">3000</property> --> 24 25 <!-- 配置隔离级别 --> 26 <property name="hibernate.connection.isolation">4</property> 27 <!-- 配置session绑定本地线程 --> 28 <property name="hibernate.current_session_context_class">thread</property> 29 <mapping resource="cn/eagle/domain/Customer.hbm.xml" /> 30 </session-factory> 31 </hibernate-configuration>
1 package cn.eagle.utils; 2 3 import org.hibernate.Session; 4 import org.hibernate.SessionFactory; 5 import org.hibernate.cfg.Configuration; 6 7 public class HibernateUtils { 8 9 private static final Configuration configuration; 10 private static final SessionFactory sessionFactory; 11 12 static { 13 configuration = new Configuration().configure(); 14 sessionFactory = configuration.buildSessionFactory(); 15 } 16 17 public static Session getCurrentSession() { 18 return sessionFactory.getCurrentSession(); 19 } 20 }