Hibernate的执行流程——SessionFactory的创建

Hibernate的执行流程：

1、创建Configuration类实例，用来读取并解析配置文件(如Hibernate.cfg.xml)，一个Configuration实例代表hibernate所有Pojo类到SQL数据库映射的集合；

2、创建SessionFactory对象，用来读取并解析映射信息，同时将上一步Configuration对象中的所有配置信息copy到SessionFactory缓存中；

3、通过上一步创建的SessionFactory对象，打开Session；

4、开始事务，事务指Session提供的接口对数据库进行CRUD操作。

只有了解Hibernate的执行流程，才能够更好的理解SessionFactory的创建过程。

先放代码：

package com;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
import org.hibernate.service.ServiceRegistry;
import org.hibernate.service.ServiceRegistryBuilder;

public class HibernateSessionFactory {
    private static String CONFIG_FILE_LOCATION = "/hibernate.cfg.xml";
    private static final ThreadLocal<Session> sessionThreadLocal = new ThreadLocal<Session>();//创建一个ThreadLocal<Session>对象用来存放当前Session对象
    private static Configuration configuration = new Configuration();
    private static SessionFactory sessionFactory;
    private static String configFile = CONFIG_FILE_LOCATION;
    
    static
    {
        try{
            configuration.configure();//读取并解析hibernate.cfg.xml文件
　　　　　　　//在Hibernate4.x会使用注册机来解析映射信息，所以会先创建ServiceRegistry对象
            ServiceRegistry serviceRgistry = new ServiceRegistryBuilder().applySettings(configuration.getProperties()).buildServiceRegistry();
　　　　　　　//ServiceRegister对象作为参数，使用configuration对象创建sessionFactory对象，即将configuration对象里的信息copy到sessionFactory缓存中
            sessionFactory = configuration.buildSessionFactory(serviceRgistry);
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    
　　//声明一个私有无参构造函数
    private HibernateSessionFactory(){}
    
    public static SessionFactory getSessionFactory(){
        return sessionFactory;
    }
    
    public static void rebuildSessionFactory(){
        synchronized(sessionFactory){
            try{
                configuration.configure(configFile);
                ServiceRegistry serviceRegistry = new ServiceRegistryBuilder().applySettings(configuration.getProperties()).buildServiceRegistry();
                sessionFactory = configuration.buildSessionFactory(serviceRegistry);
            }catch(Exception e){
                e.printStackTrace();
            }
        }
    }
    
　　//打开session
    public static Session getSession(){
　　　　　　//获取当前线程的session对象
        Session session = sessionThreadLocal.get();
        try{
            if(session == null || !session.isOpen()){
                if(sessionFactory == null){//如果sessionFactory为null，创建一个
                    rebuildSessionFactory();
                }
　　　　　　　　　　//如果session没有打开，就用sessionFactory打开
                session = (sessionFactory!=null)?sessionFactory.openSession():null;
　　　　　　　　　　//将session对象放到ThreadLocal对象里，以便使用
                sessionThreadLocal.set(session);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
        
        return session;
    }
    
    public static void closeSession(){
        Session session = sessionThreadLocal.get();
        sessionThreadLocal.set(null);
        try{
            if(session != null && session.isOpen()){
                session.close();
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    
    public static void setConfigFile(String configFile){
        HibernateSessionFactory.configFile = configFile;
        sessionFactory = null;
    }
    
    public static Configuration getConfiguration(){
        return configuration;
    }
}

代码里已经有部分注释，相信足够理解代码了。这里特别注意的一点就是，这个SessionFactory创建代码使用的jar包是Hibernate4.x，如果使用5.x以上版本，需要对创建SessionFactory过程做出以下改变：

//添加add(User.class)，这个User类是一个POJO类，对应数据库的一个user表，hibernate.cfg.xml里面有配置的，如果没有这一条语句，将会报错：Unknow Entity xxx
configuration。add(User.class);
configuration.configure();//读取并解析hibernate.cfg.xml文件
//在Hibernate5.x会使用注册机来解析映射信息，所以会先创建ServiceRegistry对象，使用StandardServiceRegistryBuilder()
ServiceRegistry serviceRgistry = new StandardServiceRegistryBuilder().applySettings(configuration.getProperties()).build();
//ServiceRegister对象作为参数，使用configuration对象创建sessionFactory对象，即将configuration对象里的信息copy到sessionFactory缓存中
sessionFactory = configuration.buildSessionFactory(serviceRgistry);

细心的读者可以看出，创建出来的SessionFactory是线程安全的，因此SessionFactory可以同时被多个线程共享，但是正常情况下，session并不是线程安全，每个线程都会使用这个session实例，如果多个线程同时操作数据库时，某个线程将session关闭了，正在操作数据库的线程就会出现异常，为了解决这个问题，代码中使用ThreadLocal对象来保证session的线程安全，这样的话，每个线程只会操作当前session实例的副本，不影响其他线程。