疯狂ajax 讲义 第三版 源码 01-05

package org.crazyit.common.dao.impl; import org.hibernate.*; import java.util.List; import java.io.Serializable; import org.crazyit.common.dao.*; /** * Description: * <br/>网站: <a href="http://www.crazyit.org">疯狂Java联盟</a> * <br/>Copyright (C), 2001-2012, Yeeku.H.Lee * <br/>This program is protected by copyright laws. * <br/>Program Name: * <br/>Date: * @author Yeeku.H.Lee kongyeeku@163.com * @version 1.0 */ public class BaseDaoHibernate4<T> implements BaseDao<T> { // DAO组件进行持久化操作底层依赖的SessionFactory组件 private SessionFactory sessionFactory; // 依赖注入SessionFactory所需的setter方法 public void setSessionFactory(SessionFactory sessionFactory) { this.sessionFactory = sessionFactory; } public SessionFactory getSessionFactory() { return this.sessionFactory; } // 根据ID加载实体 @SuppressWarnings("unchecked") public T get(Class<T> entityClazz , Serializable id) { return (T)getSessionFactory().getCurrentSession() .get(entityClazz , id); } // 保存实体 public Serializable save(T entity) { return getSessionFactory().getCurrentSession() .save(entity); } // 更新实体 public void update(T entity) { getSessionFactory().getCurrentSession().saveOrUpdate(entity); } // 删除实体 public void delete(T entity) { getSessionFactory().getCurrentSession().delete(entity); } // 根据ID删除实体 public void delete(Class<T> entityClazz , Serializable id) { delete(get(entityClazz , id)); } // 获取所有实体 @SuppressWarnings("unchecked") public List<T> findAll(Class<T> entityClazz) { return find("select en from " + entityClazz.getSimpleName() + " en"); } // 获取实体总数 public long findCount(Class<T> entityClazz) { List l = find("select count(*) from " + entityClazz.getSimpleName()); // 查询得到的实体总数 if (l != null && l.size() == 1 ) { return (Long)l.get(0); } return 0; } // 根据HQL语句查询实体 @SuppressWarnings("unchecked") protected List<T> find(String hql) { return (List<T>)getSessionFactory().getCurrentSession() .createQuery(hql) .list(); } // 根据带占位符参数HQL语句查询实体 @SuppressWarnings("unchecked") protected List<T> find(String hql , Object... params) { // 创建查询 Query query = getSessionFactory().getCurrentSession() .createQuery(hql); // 为包含占位符的HQL语句设置参数 for(int i = 0 , len = params.length ; i < len ; i++) { query.setParameter(i + "" , params[i]); } return (List<T>)query.list(); } /** * 使用hql 语句进行分页查询操作 * @param hql 需要查询的hql语句 * @param pageNo 查询第pageNo页的记录 * @param pageSize 每页需要显示的记录数 * @return 当前页的所有记录 */ @SuppressWarnings("unchecked") protected List<T> findByPage(String hql, int pageNo, int pageSize) { // 创建查询 return getSessionFactory().getCurrentSession() .createQuery(hql) // 执行分页 .setFirstResult((pageNo - 1) * pageSize) .setMaxResults(pageSize) .list(); } /** * 使用hql 语句进行分页查询操作 * @param hql 需要查询的hql语句 * @param params 如果hql带占位符参数，params用于传入占位符参数 * @param pageNo 查询第pageNo页的记录 * @param pageSize 每页需要显示的记录数 * @return 当前页的所有记录 */ @SuppressWarnings("unchecked") protected List<T> findByPage(String hql , int pageNo, int pageSize , Object... params) { // 创建查询 Query query = getSessionFactory().getCurrentSession() .createQuery(hql); // 为包含占位符的HQL语句设置参数 for(int i = 0 , len = params.length ; i < len ; i++) { query.setParameter(i + "" , params[i]); } // 执行分页，并返回查询结果 return query.setFirstResult((pageNo - 1) * pageSize) .setMaxResults(pageSize) .list(); } }