spring3.0 项目源码

/** * 项目名称：HR * 类名称:Dictionary.java * 包名称:com.aq.osgi.crm.base * * 创建日期:2011-1-4 * 创建人:heruizhe */ package com.aq.osgi.mdm.dao; import java.io.Serializable; import java.sql.SQLException; import java.util.ArrayList; import java.util.Collection; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.annotation.Resource; import org.apache.log4j.Logger; import org.hibernate.HibernateException; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.dialect.Dialect; import org.hibernate.engine.SessionFactoryImplementor; import org.hibernate.type.NullableType; import org.hibernate.type.Type; import org.springframework.orm.hibernate3.HibernateCallback; import org.springframework.orm.hibernate3.support.HibernateDaoSupport; import com.aq.osgi.mdm.beans.AQInfo; import com.aq.osgi.mdm.exception.CurrentlyException; import com.aq.osgi.mdm.exception.ErrorCodeConstant; import com.aq.osgi.mdm.util.ApplicationConstant; /** * 创建人: 何睿哲 * 类说明: DAO层基类,提供protected方法供各自的业务DAO调用,统一管理持久层方法 * @author heruizhe */ public abstract class BaseDAO extends HibernateDaoSupport { /** 日志记录 */ private static Logger log = Logger.getLogger(BaseDAO.class); /** * * 方法描述:spring3.x sessionFactory注入 * 创建人:heruizhe * 创建日期:2011-1-18 * @param sessionFactory spring配置xml文件中声明的sessionFactory */ @Resource(name = "sessionFactory") public void getHibernateSession(SessionFactory sessionFactory) { setSessionFactory(sessionFactory); } /** * 条件查询(where...and...子句),无最大条数限制版本<br> * @see com.aq.osgi.crm.base.BaseDAO.lookup(Object[] values, Type[] types, String query, int maxResults) */ protected List lookup(Object[] values, Type[] types, String query) throws CurrentlyException { return lookup(values, types, query, -1); } /** * * 方法描述:条件查询(where...and...子句)<br> * 创建人:heruizhe<br> * 创建日期:2011-1-18 * @param values 查询条件的值集合 * @param types 查询条件的值的类型集合 * @param query 标准HQL语句 * @param maxResults 查询最大条数 * @return 返回查询结果集 * @throws CurrentlyException 若查询结果为空则抛出ERROR_1100异常;若抓取到HibernateException则转为CurrentlyException(ErrorCodeConstant.ERROR_1001)抛出 */ protected List lookup(Object[] values, Type[] types, String query, int maxResults) throws CurrentlyException { List results = null; try { Session session = this.getSession(); Query q = session.createQuery(query); // 若有参数则添加 if (values != null && types != null) { q.setParameters(values, types); } // 若查询最大条数有效则设置查询最大条数 if (maxResults >= 0) { q.setMaxResults(maxResults); } // 执行查询 results = q.list(); //释放会话 releaseSession(session); // 若查询结果集为空则记录warn日志并抛出ERROR_1100异常(未查询到数据) // if (results == null || results.size() < 1) // { // // modify start // // by qixin // // in 2011-1-18 // // 修改异常处理,统一改为抛出CurrentlyException // log.warn(ErrorCodeConstant.ERROR_1100 + " 查询结果为空!"); // throw new CurrentlyException(ErrorCodeConstant.ERROR_1100, "查询结果为空"); // // modify end // } } catch (HibernateException he) { // 记录错误日志，抛出已定义异常 log.error("HibernateException", he); throw new CurrentlyException(ErrorCodeConstant.ERROR_1001, "数据库异常!"); } return results; } /** * 集合条件查询(in子句),无最大条数限制版本 * @see com.aq.osgi.crm.base.BaseDAO.lookup(String query, String parameterName, Collection values, NullableType type, int maxResults) */ protected List lookup(String query, String parameterName, Collection values, NullableType type) throws CurrentlyException { return lookup(query, parameterName, values, type, -1); } /** * 方法描述:集合条件查询(in子句) * 创建人:heruizhe<br> * 创建日期:2011-1-18<br> * @param query HQL语句 * @param parameterName 参数名 * @param values 条件值集合 * @param type 是否允许为null * @param maxResults 最大记录数 * @return 查询结果集 * @throws CurrentlyException 若查询结果为空则抛出ERROR_1100异常;若抓取到HibernateException则转为CurrentlyException(ErrorCodeConstant.ERROR_1001)抛出 */ protected List lookup(String query, String parameterName, Collection values, NullableType type, int maxResults) throws CurrentlyException { List results = null; try { Session session = this.getSession(); Query q = session.createQuery(query); q.setParameterList(parameterName, values, type); if (maxResults >= 0) { q.setMaxResults(maxResults); } // 执行查询 results = q.list(); //释放会话 releaseSession(session); // 若查询结果集为空则记录warn日志并抛出ERROR_1100异常(未查询到数据) if (results == null || results.size() < 1) { // modify start // by qixin // in 2011-1-18 // 修改异常处理,统一改为抛出CurrentlyException log.warn(ErrorCodeConstant.ERROR_1100 + " 查询结果为空!"); throw new CurrentlyException(ErrorCodeConstant.ERROR_1100, "查询结果为空"); // modify end} } } catch (HibernateException he) { // 记录错误日志，抛出已定义异常 log.error("HibernateException", he); throw new CurrentlyException(ErrorCodeConstant.ERROR_1001, "数据库异常!"); } return results; } /** * * 方法描述:查询指定序列的nextVal * 创建人:luowenyu * 创建日期:2011-1-18 * @param seqName oracle序列名 * @return 返回序列的nextVal */ protected String getSequence(String seqName) { Dialect da = ((SessionFactoryImplementor)getSessionFactory()).getDialect(); Query q = this.getSession().createSQLQuery(da.getSequenceNextValString(seqName)); return q.list().get(0).toString(); } /** * * 方法描述:bean对象单体查询 * 创建人:heruizhe * 创建日期:2011-1-18 * @param clazz bean类型 * @param id bean对象 * @return 返回查询到的bean对象 * @throws CurrentlyException * 入口参数为null——异常码ERROR_1001 * 未查询到结果——异常码ERROR_1100 * 数据库异常——异常码ERROR_1001 * runtime异常——异常吗ERROR_1000 */ protected Object load(Class<?> clazz, Serializable id)