标签:figure void 执行 ext .class 创建过程 了解 thread .config
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实例的副本,不影响其他线程。
Hibernate的执行流程——SessionFactory的创建
标签:figure void 执行 ext .class 创建过程 了解 thread .config
原文地址:https://www.cnblogs.com/SysoCjs/p/9496358.html