Generic Data Access Objects 設計模式

Generic Data Access Objects

    普通數據訪問對象，這個是Hibernate官方網站上面的一個DAO類的設計模式，基於JDK5.0范型支持,文章地址如下：

http://www.hibernate.org/328.Html

我下面的代碼與Hibernate官網上提供的有點不同。
　　

首先定義DAO類的接口IGenericDAO，該接口定義了共同的CRUD操作：<？XML:NAMESPACE PREFIX = O />

1. /** 
2.  * 定義通用的CRUD操作 
3.  * @author rainlife 
4.  */  
5. public interface IGenericDAO 〈T, ID extends Serializable〉
6. {  
7. //  通過主鍵標識查找某個對象。  
8.     public T findById(ID id);  
9.       
10. //  通過主鍵標識查找某個對象，可以鎖定表中對應的記錄。  
11.     T findById(ID id, boolean lock);  
12.   
13.     //得到所有的對象。  
14.     List findAll();  
15.   
16.     //通過給定的一個對象，查找與其匹配的對象。  
17.     List findByExample(T exampleInstance);  
18.   
19.     //持久化對象。  
20.     T makePersistent(T entity);  
21.   
22.     //刪除對象。  
23.     void makeTransient(T entity);  
24. }  

下面是使用Hibernate針對該接口的實現GenericDAOHibernate：

1. /** 
2.  * 這是針對IGenericDAO接口的Hibernate實現，完成通用的CRUD操作。 
3.  * @author rainlife 
4.  * @param  POJO類 
5.  * @param   POJO類的主鍵標識符 
6.  * @param  針對每一個POJO類的DAO類實現  
7.  */  
8. public abstract class GenericDAOHibernate 〈T,ID extends Serializable, DAOImpl extends IGenericDAO〈T,ID〉〉
9.         implements IGenericDAO〈T,ID〉
10. {  
11.     private Class persistentClass;  
12.   
13.     protected Session session;  
14.   
15.     public GenericDAOHibernate()  
16.     {  
17.         this.persistentClass = (Class) ((ParameterizedType) getClass()  
18.                 .getGenericSuperclass()).getActualTypeArguments()[0];  
19.     }  
20.   
21.     @SuppressWarnings("unchecked")  
22.     public DAOImpl setSession(Session s)  
23.     {  
24.         this.session = s;  
25.         return (DAOImpl)this;  
26.     }  
27.   
28.     protected Session getSession()  
29.     {  
30.         if (session == null)  
31.             throw new IllegalStateException(  
32.                     "Session has not been set on DAO before usage");  
33.         return session;  
34.     }  
35.   
36.     public Class getPersistentClass()  
37.     {  
38.         return persistentClass;  
39.     }  
40.   
41.       
42.     @SuppressWarnings("unchecked")  
43.     public T findById(ID id)  
44.     {  
45.         return (T) getSession().load(getPersistentClass(), id);  
46.     }  
47.       
48.     @SuppressWarnings("unchecked")  
49.     public T findById(ID id, boolean lock)  
50.     {  
51.         T entity;  
52.         if (lock)  
53.             entity = (T) getSession().load(getPersistentClass(), id, LockMode.UPGRADE);  
54.         else  
55.             entity = findById(id);  
56.   
57.         return entity;  
58.     }  
59.   
60.     @SuppressWarnings("unchecked")  
61.     public List findAll()  
62.     {  
63.         return findByCriteria();  
64.     }  
65.   
66.     @SuppressWarnings("unchecked")  
67.     public List findByExample(T exampleInstance)  
68.     {  
69.         Criteria crit = getSession().createCriteria(getPersistentClass());  
70.         Example example = Example.create(exampleInstance);  
71.         crit.add(example);  
72.         return crit.list();  
73.     }  
74.       
75.     @SuppressWarnings("unchecked")  
76.     public List findByExample(T exampleInstance, String[] excludeProperty)  
77.     {  
78.         Criteria crit = getSession().createCriteria(getPersistentClass());  
79.         Example example = Example.create(exampleInstance);  
80.         for (String exclude : excludeProperty)  
81.         {  
82.             example.excludeProperty(exclude);  
83.         }  
84.         crit.add(example);  
85.         return crit.list();  
86.     }  
87.   
88.     @SuppressWarnings("unchecked")  
89.     public T makePersistent(T entity)  
90.     {  
91.         getSession().saveOrUpdate(entity);  
92.         //getSession().save(entity);  
93.         return entity;  
94.     }  
95.   
96.     public void makeTransient(T entity)  
97.     {  
98.         getSession().delete(entity);  
99.     }  
100.   
101.     @SuppressWarnings("unchecked")  
102.     protected List findByCriteria(Criterion... criterion)  
103.     {  
104.         Criteria crit = getSession().createCriteria(getPersistentClass());  
105.         for (Criterion c : criterion)  
106.         {  
107.             crit.add(c);  
108.         }  
109.         return crit.list();  
110.     }  
111.       
112.     @SuppressWarnings("unchecked")  
113.     /** 
114.      * 增加了排序的功能。 
115.      */  
116.     protected List findByCriteria(Order order,Criterion... criterion)  
117.     {  
118.         Criteria crit = getSession().createCriteria(getPersistentClass());  
119.         for (Criterion c : criterion)  
120.         {  
121.             crit.add(c);  
122.         }  
123.         if(order!=null)  
124.             crit.addOrder(order);  
125.         return crit.list();  
126.     }  
127.       
128.     @SuppressWarnings("unchecked")  
129.     protected List findByCriteria(int firstResult,int rowCount,Order order,Criterion... criterion)  
130.     {  
131.         Criteria crit = getSession().createCriteria(getPersistentClass());  
132.         for (Criterion c : criterion)  
133.         {  
134.             crit.add(c);  
135.         }  
136.         if(order!=null)  
137.             crit.addOrder(order);  
138.         crit.setFirstResult(firstResult);  
139.         crit.setMaxResults(rowCount);  
140.         return crit.list();  
141.     }  
142. }  

這樣，我們自己所要使用的DAO類，就可以直接從這個Hibernate的DAO類繼續：

比如說我們定義一個IUserDAO接口，該接口繼續IGenericDAO:

1. public interface IUserDAO extends IGenericDAO〈User,Integer〉
2. {  
3.     public User find(String username,String passWord);  
4.     public User find(String username);  
5. }  

該接口從IGenericDAO繼續，自然也就定義了IGenericDAO接口所定義的通用CRUD操作。