pjbasebo.java

此系统为我大家完全开发一个相册管理系统

/* ====================================================================
 * $Id$
 * ====================================================================
 *  文件名    PJBaseBo.java
 *  机能名    业务逻辑基类。
 *  履历      2005-1-27 dlxu 创建新文件  
 *           Copyright 2004 东南大学 All Rights Reserved
 * ====================================================================
 */
package cn.edu.seu.album.common;

import java.io.Serializable;

import net.sf.hibernate.HibernateException;
import net.sf.hibernate.Session;
import net.sf.hibernate.SessionFactory;
import net.sf.hibernate.cfg.Configuration;

import org.apache.log4j.Category;
import org.apache.log4j.Logger;
import org.apache.struts.action.ActionMessages;

/**
 * <p> [概 要] 业务逻辑基类。</p>
 * <p> [详 细] 业务逻辑基类。</p>
 * <p> [备 考] 无。</p>
 *
 * @author dlxu
 * @version 1.0 2005-1-27
 * @since 1.0
 */
public abstract class PJBaseBo implements Serializable {

    /**
     * Session工厂定义。
     */
    private static final SessionFactory sessionFactory;

    /**
     * 日志取得。
     */
    private static Category cat = Logger.getInstance(PJBaseBo.class.getName());

    static {
        try {
            sessionFactory = new Configuration().configure()
                    .buildSessionFactory();
            cat.debug("sessionFactory : " + sessionFactory);
        } catch (HibernateException ex) {
            cat.debug(ex);
            throw new RuntimeException("Exception building SessionFactory: "
                    + ex.getMessage(), ex);
        }
    }

    private static final ThreadLocal threadLocal = new ThreadLocal();

    /**
     * Session定义。
     */
    protected Session session = null;

    /**
     * <p> [概 要] 取得Session。</p>
     * <p> [详 细] 取得Session。</p>
     * <p> [备 考] 无。</p>
     * @return Session
     * @throws HibernateException 异常发生。
     */
    private static Session currentSession() throws HibernateException {
        Session s = (Session) threadLocal.get();
        if (s == null) {
            s = sessionFactory.openSession();
            threadLocal.set(s);
        }
        return s;
    }

    /**
     * <p> [概 要] 关闭Session。</p>
     * <p> [详 细] 关闭Session。</p>
     * <p> [备 考] 无。</p>
     * @throws HibernateException 异常发生。
     */
    private static void closeSession() throws HibernateException {
        Session s = (Session) threadLocal.get();
        threadLocal.set(null);
        if (s != null)
            s.close();
    }

    /**
     * <p> [概 要] 初始化操作。</p>
     * <p> [详 细] 初始化操作。</p>
     * <p> [备 考] 无。</p>
     *
     */
    public static void init() {

    }

    /**
     * <p> [概 要] 调用业务逻辑。</p>
     * <p> [详 细] 调用业务逻辑。</p>
     * <p> [备 考] 无。</p>
     * @param condition 条件
     * @param msgs 错误信息
     * @return 业务结果
     * @throws PJException 异常发生
     */
    PJResult gotoBiz(PJCondition condition, ActionMessages msgs)
            throws PJException {
        try {
            session = currentSession();
            return doBiz(condition, msgs);
        } catch (PJException e) {
            throw e;
        } catch (Exception ex) {
            throw new PJException(ex);
        } finally {
            try {
                closeSession();
            } catch (Exception ex) {
                throw new PJException(ex);
            }
        }
    }

    /**
     * <p> [概 要] </p>
     * <p> [详 细] </p>
     * <p> [备 考] 无。</p>
     * @param condition 条件
     * @param errs 错误信息
     * @return 业务结果
     * @throws PJException 异常发生
     */
    abstract public PJResult doBiz(PJCondition condition, ActionMessages errs)
            throws PJException;
}