基于泛型的通用Dao接口和hibernate的实现

基于泛型的通用Dao接口：（主要是在使用hibernate或JPA时使用）

 

1. package com.qiujy.dao;
3. import java.io.Serializable;
4. import java.util.List;
6. /**
7.  * 基于泛型的通用Dao接口
8.  */
9. public interface GenericDao<T> {
10.     void create(T entity);
11.     void delete(T entity);
12.     void update(T entity);
13.     
14.     T findById(Serializable id);
15.     List<T> findAll();
16.     List<T> findList(int pageNo, int pageSize);
17.     int getCountOfAll();
18. }

hibernate对此泛型Dao接口的使用：

1. package com.qiujy.dao.hibernate;
3. import java.io.Serializable;
4. import java.lang.reflect.ParameterizedType;
5. import java.util.List;
7. import org.hibernate.criterion.Projections;
8. import com.qiujy.common.HibernateUtil;
9. import com.qiujy.dao.GenericDao;
11. /**
12.  * Hibernate对泛型通用Dao接口的实现
13.  */
14. public class GenericHibernateDaoImpl<T> implements GenericDao<T> {
16.     private Class<T> clazz;
18.     @SuppressWarnings("unchecked")
19.     public GenericHibernateDaoImpl() {
20.         //通过反射获取T的类型信息实例
21.         this.clazz = (Class<T>)((ParameterizedType)this.getClass().getGenericSuperclass())
22.                             .getActualTypeArguments()[0];
23.     }
25.     public void create(T entity) {
26.         HibernateUtil.getSession().save(entity);
27.     }
29.     public void delete(T entity) {
30.         HibernateUtil.getSession().delete(entity);
31.     }
32.     
33.     @SuppressWarnings("unchecked")
34.     public void update(T entity) {
35.         //HibernateUtil.getSession().saveOrUpdate(entity);
36.         entity = (T) HibernateUtil.getSession().merge(entity);
37.     }
39.     @SuppressWarnings("unchecked")
40.     public List<T> findAll() {
41.         return HibernateUtil.getSession().createCriteria(clazz).list();
42.     }
44.     @SuppressWarnings("unchecked")
45.     public List<T> findList(int pageNo, int pageSize) {
46.         return HibernateUtil.getSession().createCriteria(clazz)
47.                                          .setFirstResult((pageNo - 1) * pageSize)
48.                                          .setMaxResults(pageSize)
49.                                          .list();
50.     }
52.     public int getCountOfAll() {
53.         Integer count = (Integer) HibernateUtil.getSession()
54.                                                .createCriteria(clazz)
55.                                                .setProjection(Projections.rowCount())
56.                                                .uniqueResult();
57.         if (null == count) {
58.             return 0;
59.         } else {
60.             return count.intValue();
61.         }
62.     }
64.     @SuppressWarnings("unchecked")
65.     public T findById(Serializable id) {
66.         return (T)HibernateUtil.getSession().load(clazz, id); //get
67.     }
69. }

 

使用泛型Dao接口：

 

1. package com.qiujy.dao;
3. import java.util.List;
5. import com.qiujy.domain.Resource;
8. /**
9.  * Resource类的Dao接口
10.  */
11. public interface ResourceDao extends GenericDao<Resource> {
12.     
13.     public List<Resource> findResources(int status);
14. }

使用hibernate的实现：

1. package com.qiujy.dao.hibernate;
3. import java.util.List;
5. import com.qiujy.common.HibernateUtil;
6. import com.qiujy.dao.ResourceDao;
7. import com.qiujy.domain.Resource;
10. public class ResourceDaoImpl extends GenericHibernateDaoImpl<Resource> implements ResourceDao {
12.     @SuppressWarnings("unchecked")
13.     public List<Resource> findResources(int status) {
14.         
15.         return (List<Resource>)HibernateUtil.getSession()
16.                                     .createQuery("from Resource where status=:status")
17.                                     .setInteger("status", status)
18.                                     .list();
19.     }
20.     
21. }