extjs+struts2+spring+hibernate

/** * $Revision 1.1 $ * $Date 2009-07-25$ * * Copyright(C) 2009 Umessage Co.,Ltd. All rights reserved. */ package framework.dao.impl; import java.io.Serializable; import java.util.Collection; import java.util.List; import org.hibernate.Query; import org.hibernate.Session; import org.springframework.orm.hibernate3.support.HibernateDaoSupport; import framework.dao.IBaseDAO; import framework.model.PageBean; /** * @Descriptor : base dao for getPageBean * @author : umessage software */ public class BaseDAO extends HibernateDaoSupport implements IBaseDAO { /** * Description : 根据实体类名及ID取出实体对象 * * @param 类名 * @param ID * @return Object */ @SuppressWarnings("rawtypes") public Object load(Class entityClass, Serializable id) { Object entity = getHibernateTemplate().get(entityClass, id); return entity; } /** * Description : 根据实体类名取出所有的实体对象 * * @param 类名 * @return List */ @SuppressWarnings("rawtypes") public List<?> loadAll(Class entityClass) { return getHibernateTemplate().loadAll(entityClass); } /** * Description : 保存或更新单个实体对象 * * @param Object * @return void */ public void saveOrUpdate(Object entity) { getHibernateTemplate().saveOrUpdate(entity); // getHibernateTemplate().saveOrUpdateObj(entity); getHibernateTemplate().flush(); } /** * Description : 保存或更新多个实体对象 * * @param objs * @return void */ @SuppressWarnings("rawtypes") public void saveOrUpdate(Collection objs) { getHibernateTemplate().saveOrUpdateAll(objs); // getHibernateTemplate().saveOrUpdateAllObj(objs); getHibernateTemplate().flush(); } /** * Description : 根据实体类名及ID删除实体对象 * * @param 类名 * @param ID * @return void */ @SuppressWarnings("rawtypes") public void delete(Class entityClass, Serializable id) { getHibernateTemplate().delete(load(entityClass, id)); } /** * Description : 删除实体对象集合 * * @param 对象集合 * @return void */ @SuppressWarnings("rawtypes") public void deleteAll(Collection objs) { getHibernateTemplate().deleteAll(objs); } /** * Description : 查询数据 * * @param sql语句 * @param 参数 * @return void */ public List<?> qryList(String queryString, Object[] params) { return getHibernateTemplate().find(queryString, params); } /** * Description : 查询数据 * * @param sql语句 * @return List */ public List<?> qryList(String queryString) { return qryList(queryString, null); } /** * Description : 查询 * * @param queryString * @param value * @return List */ public List<?> qryList(String queryString, Object value) { return qryList(queryString, new Object[] { value }); } /** * Description : 添加 * * @param entity * @return void */ public void save(Object entity) { // getHibernateTemplate().saveObj(entity); getHibernateTemplate().save(entity); // getHibernateTemplate().flush(); } /** * Description : 更新 * * @param entity * @return void */ public void update(Object entity) { // getHibernateTemplate().updateObj(entity); getHibernateTemplate().update(entity); getHibernateTemplate().flush(); } /** * Description : 更新 * * @param entity * @return void */ public void merge(Object entity) { // getHibernateTemplate().updateObj(entity); getHibernateTemplate().merge(entity); getHibernateTemplate().flush(); } /** * Description : 删除 * * @param hql * @return void */ public void delete(final String hql, final Object[] values) { // getHibernateTemplate().deleteBatch(hql,values); Session session = this.getSession(); try { Query query = session.createQuery(hql); if (values != null) { for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } } query.executeUpdate(); } catch (Exception e) { e.printStackTrace(); } finally { releaseSession(session); } } /** * Description : 更新 * * @param hql * @return void */ public void update(final String hql, final Object[] values) { // getHibernateTemplate().updateBatch(hql,values); Session session = this.getSession(); try { Query query = session.createQuery(hql); if (values != null) { for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } } query.executeUpdate(); } catch (Exception e) { e.printStackTrace(); } finally { releaseSession(session); } } /** * Description : 删除 * * @param hql * @param void */ public void delete(String hql, Object value) { delete(hql, new Object[] { value }); } /** * Description : 删除 * * @param hql * @param void */ public void delete(String hql) { delete(hql, null); } /** * Description : 删除 * * @param obj * @param void */ public void delete(Object obj) { try { getHibernateTemplate().delete(obj); } catch (Exception e) { e.printStackTrace(); } } /** * Description : 更新 * * @param hql * @param void */ public void update(String hql, Object value) { update(hql, new Object[] { value }); } /** * Description : 占位符传参方式的分页查询(通过传入参数确定是否启用缓存) * * @param hql * @param countHql * @param params * @param pageBean * @param flg * @return */ public boolean getQueryPageBean(String hql, String countHql, Object[] params, PageBean pageBean, boolean flg) { Session session = getSession(); try { Query query = session.createQuery(hql.toString()); if (params != null) { for (int i = 0; i < params.length; i++) { if (params[i] != null) { query.setParameter(i, params[i]); } } } query.setCacheable(flg);//是否开启查询缓存 query.setFirstResult((pageBean.getPage() - 1) * pageBean.getPageSize()); query.setMaxResults(pageBean.getPageSize()); // 获取需要显示的结果和符合条件的总数 pageBean.setResultList(query.list()); // getHibernateTemplate().setCacheQueries(true); if (params != null) { pageBean.setTotal((Long) getHibernateTemplate() .find(countHql.toString(), params).listIterator() .next()); } else { pageBean.setTotal((Long) getHibernateTemplate() .find(countHql.toString()).listIterator().next()); } // 计算pageBean的其他信息 pageBean.compute(); } catch (Exception e) { logger.error(e, e); } finally { releaseSession(session); } return true; } }