码迷,mamicode.com
首页 > Web开发 > 详细

hibernate框架学习笔记6:事务

时间:2018-02-15 10:27:52      阅读:271      评论:0      收藏:0      [点我收藏+]

标签:学习   imp   根据   print   als   pool   pos   UI   指定   

MySQL的事务、JDBC事务操作:

详细见这篇文章:比较详细

http://www.cnblogs.com/xuyiqing/p/8430214.html

 

如何在hibernate中配置隔离级别:

再核心配置文件中:

         <!-- 指定hibernate操作数据库时的隔离级别 
            #hibernate.connection.isolation 1|2|4|8        
            0001    1    读未提交
            0010    2    读已提交
            0100    4    可重复读
            1000    8    串行化
         -->
         <property name="hibernate.connection.isolation">4</property>                

 

这里是二进制,转换成十进制就是1,2,4,8

 

项目中管理事务:

没有学习hibernate框架以前,在项目中,开启事务在业务层(service),执行之后提交或回滚

而在hibernate框架中,也是这样,操作数据库需要用到的session对象,一定保证,service层和dao层的session是同一个

类似servlet项目中需要确保service层和dao层的connection对象一致,当时用到了绑定线程

(这是以前sevlet项目中的一个工具类,可以浏览下对比)

技术分享图片
package utils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class DataSourceUtils {

    private static DataSource dataSource = new ComboPooledDataSource();

    private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();

    // 直接可以获取一个连接池
    public static DataSource getDataSource() {
        return dataSource;
    }

    // 获取连接对象
    public static Connection getConnection() throws SQLException {

        Connection con = tl.get();
        if (con == null) {
            con = dataSource.getConnection();
            tl.set(con);
        }
        return con;
    }

    // 开启事务
    public static void startTransaction() throws SQLException {
        Connection con = getConnection();
        if (con != null) {
            con.setAutoCommit(false);
        }
    }

    // 事务回滚
    public static void rollback() throws SQLException {
        Connection con = getConnection();
        if (con != null) {
            con.rollback();
        }
    }

    // 提交并且 关闭资源及从ThreadLocall中释放
    public static void commitAndRelease() throws SQLException {
        Connection con = getConnection();
        if (con != null) {
            con.commit(); // 事务提交
            con.close();// 关闭资源
            tl.remove();// 从线程绑定中移除
        }
    }

    // 关闭资源方法
    public static void closeConnection() throws SQLException {
        Connection con = getConnection();
        if (con != null) {
            con.close();
        }
    }

    public static void closeStatement(Statement st) throws SQLException {
        if (st != null) {
            st.close();
        }
    }

    public static void closeResultSet(ResultSet rs) throws SQLException {
        if (rs != null) {
            rs.close();
        }
    }

}
View Code

 

在hibernate框架中,原理是一样的,绑定线程

但是,只需要在核心配置文件中配置:

         <!-- 指定session与当前线程绑定 -->
         <property name="hibernate.current_session_context_class">thread</property>

 

代码只需一行:

                SessionFactory sf = new Configuration().configure().buildSessionFactory();
                sf.getCurrentSession();

 

简单的测试即可理解:

package demo;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;
import org.junit.Test;

import utils.HibernateUtils;

//测试getCurrentSession
public class Demo {

    @Test
    //返回同一个与线程绑定的session
    public void fun1(){
        Session session1 = HibernateUtils.getCurrentSession();
        Session session2 = HibernateUtils.getCurrentSession();
        
        System.out.println(session1==session2);//true
    }
    
    @Test
    //返回不同的session
    public void fun2(){
        Session session1 = HibernateUtils.openSession();
        Session session2 = HibernateUtils.openSession();
        
        System.out.println(session1==session2);//false
    }
    
    
}

补上工具类:

技术分享图片
package utils;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

public class HibernateUtils {
    private static SessionFactory sf;
    
    static{
        //1 创建,调用空参构造
        Configuration conf = new Configuration().configure();
        //2 根据配置信息,创建 SessionFactory对象
         sf = conf.buildSessionFactory();
    }
    
    //获得session => 获得全新session
    public static Session openSession(){
                //3 获得session
                Session session = sf.openSession();
                
                return session;
        
    }
    //获得session => 获得与线程绑定的session
    public static Session getCurrentSession(){
        //3 获得session
        Session session = sf.getCurrentSession();
        
        return session;
    }    
}
View Code

 

 

注意:

通过getCurrentSession方法获得的session对象,事务提交时候,会自动关闭session,不要手动关闭,否则会有异常

 

hibernate框架学习笔记6:事务

标签:学习   imp   根据   print   als   pool   pos   UI   指定   

原文地址:https://www.cnblogs.com/xuyiqing/p/8449167.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!