package cn.happy.util;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import org.hibernate.cfg.Configuration;

public class ThreadUtil {

        // 初始化一个ThreadLocal对象

        private static final ThreadLocal sessionTL = new ThreadLocal();

        private static Configuration configuration;

        private final static SessionFactory sessionFactory;

        static {

            try {

                configuration = new Configuration().configure();

                sessionFactory = configuration.buildSessionFactory();

            } catch (Throwable ex) {

                throw new ExceptionInInitializerError(ex);

            }

        }

        public static Session currentSession() {

            //sessionTL的get()方法根据当前线程返回其对应的线程内部变量，

            //也就是我们需要的Session，多线程情况下共享数据库连接是不安全的。

            //ThreadLocal保证了每个线程都有自己的Session。

            Session session = (Session) sessionTL.get();

            // 如果session为null，则打开一个新的session

            if (session == null) {

                //创建一个数据库连接对象session。

                session = sessionFactory.openSession();

                // 保存该数据库连接session到ThreadLocal中。

                sessionTL.set(session);

            }

            //如果当前线程已经访问过数据库了，

            //则从sessionTL中get()就可以获取该线程上次获取过的数据库连接对象。

            return session;

        }

        /**

         * 关闭Session

         */

        public static void closeSession(){

            Session session = (Session) sessionTL.get();

            sessionTL.set(null);

            session.close();

        }

}