hibernatesessionfactory.java

前期开发时开发的新闻发布系统

package com.xh369.actions;

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

public class HibernateSessionFactory 
{

    private static String CONFIG_FILE_LOCATION = "/hibernate.cfg.xml";
    private static final ThreadLocal threadLocal = new ThreadLocal();
    private static final ThreadLocal threadLocalTrans = new ThreadLocal();
    private static Configuration configuration = null;
    private static SessionFactory sessionFactory;
    private static String configFile = CONFIG_FILE_LOCATION;

    static 
    {
        try 
        {
            configuration = new Configuration();
            configuration.configure(configFile);
            sessionFactory = configuration.buildSessionFactory();
        } 
        catch(Exception ex) 
        {
            ex.printStackTrace();
        }
    }

    private HibernateSessionFactory() 
    {
    
    }

    //打开session(即获取session)
    public static Session getSession() throws HibernateException 
    {
        Session session = (Session) threadLocal.get();
        if(session == null || !session.isOpen()) 
        {
            if(sessionFactory == null) 
            {
                rebuildSessionFactory();
            }
            session = (sessionFactory != null) ? sessionFactory.openSession() : null;
            threadLocal.set(session);
        }
        return session;
    }

    //再次创建sessionFactory缓存
    public static void rebuildSessionFactory() 
    {
        try 
        {
            sessionFactory = configuration.buildSessionFactory();
        } 
        catch(Exception e) 
        {
            System.err.println("%%%% Error Creating SessionFactory %%%%");
            e.printStackTrace();
        }
    }

    //关闭session
    public static void closeSession() throws HibernateException 
    {
        Session session = (Session) threadLocal.get();
        threadLocal.set(null);
        if(session != null) 
        {
            session.close();
        }
    }

    //创建事务
    public static void beginTransaction()
    {
        Transaction trans = (Transaction) threadLocalTrans.get();
        try 
        {
            if(trans == null)
            {
                trans = getSession().beginTransaction();
                threadLocalTrans.set(trans);
            }
        } 
        catch(Exception ex) 
        {
            ex.printStackTrace();
        }
    }

    //提交事务
    public static void commitTransaction()
    {
        Transaction trans = (Transaction) threadLocalTrans.get();
        try 
        {
            if(trans != null && !trans.wasCommitted() && !trans.wasRolledBack()) 
            {
                trans.commit();
            }
            threadLocalTrans.set(null);
        } 
        catch(HibernateException e) 
        {
            e.printStackTrace();
        }
    }

    //回滚事务
    public static void rollbackTransaction()
    {
        Transaction trans = (Transaction) threadLocalTrans.get();
        try 
        {
            threadLocalTrans.set(null);
            if(trans != null && !trans.wasCommitted() && !trans.wasRolledBack()) 
            {
                trans.rollback();
            }
        } 
        catch(HibernateException e) 
        {
            e.printStackTrace();
        }
    }

    //获取sessionFactory缓存
    public static SessionFactory getSessionFactory() 
    {
        return sessionFactory;
    }

    //设置Hibernate配置
    public static void setConfigFile(String configFile) 
    {
        HibernateSessionFactory.configFile = configFile;
        sessionFactory = null;
    }

    //获取Hibernate配置
    public static Configuration getConfiguration() 
    {
        return configuration;
    }
}