Hibernate事务管理 仙佛寺综合事务管理服务中心

在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 }