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实例的副本,不影响其他线程。