OA学习笔记-007-Dao层设计

一、

User, UserDao
save(User user), update(), delete(), find(), ...
Role, RoleDao
save(Role role), update(), delete(), find(), ...
Student, StudentDao
save(Student student), update(), delete(), find(), ...
...

BaseDao<T>
save(T t), update(), delete(), find()

UserDao extends BaseDao<User> { ... }
RoleDao extends BaseDao<Role>{ ... }
...

二、接口层抽取公共代码

BaseDao.java

 1 public interface BaseDao<T> {
 2
 3     /**
 4      * 保存实体
 5      *
 6      * @param entity
 7      */
 8     void save(T entity);
 9
10     /**
11      * 删除实体
12      *
13      * @param id
14      */
15     void delete(Long id);
16
17     /**
18      * 更新实体
19      *
20      * @param entity
21      */
22     void update(T entity);
23
24     /**
25      * 按id查询
26      *
27      * @param id
28      * @return
29      */
30     T getById(Long id);
31
32     /**
33      * 按id查询
34      *
35      * @param ids
36      * @return
37      */
38     List<T> getByIds(Long[] ids);
39
40     /**
41      * 查询所有
42      *
43      * @return
44      */
45     List<T> findAll();
46
47 }

三、实现层抽取公共代码

BaseDaoImpl.java

 1 import java.lang.reflect.ParameterizedType;
 2 import java.util.List;
 3
 4 import javax.annotation.Resource;
 5
 6 import org.hibernate.Session;
 7 import org.hibernate.SessionFactory;
 8
 9 @SuppressWarnings("unchecked")
10 public abstract class BaseDaoImpl<T> implements BaseDao<T> {
11
12     //这里不用管事务，因为由spring做
13     @Resource
14     private SessionFactory sessionFactory;
15     private Class<T> clazz;
16
17     public BaseDaoImpl() {
18         // 使用反射技术得到T的真实类型
19         // this表示当前new 的对象
20         ParameterizedType pt = (ParameterizedType) this.getClass().getGenericSuperclass(); // 获取当前new的对象的 泛型的父类 类型
21         this.clazz = (Class<T>) pt.getActualTypeArguments()[0]; // 获取第一个类型参数的真实类型，如 new Map<K,V>,此方法返回[k,v]
22         System.out.println("clazz ---> " + clazz);
23     }
24
25     /**
26      * 获取当前可用的Session
27      * 给子类方便获取session
28      * @return
29      */
30     protected Session getSession() {
31         return sessionFactory.getCurrentSession();
32     }
33
34     public void save(T entity) {
35         getSession().save(entity);
36     }
37
38     public void update(T entity) {
39         getSession().update(entity);
40     }
41
42     public void delete(Long id) {
43         Object obj = getById(id);
44         if (obj != null) {
45             getSession().delete(obj);
46         }
47     }
48
49     public T getById(Long id) {
50         return (T) getSession().get(clazz, id);
51     }
52
53     public List<T> getByIds(Long[] ids) {
54         return getSession().createQuery(//防止被格式化
55                 "FROM User WHERE id IN (:ids)")//
56                 .setParameterList("ids", ids)//
57                 .list();
58     }
59
60     public List<T> findAll() {
61         return getSession().createQuery(//
62                 "FROM " + clazz.getSimpleName())//
63                 .list();
64     }
65
66 }

四、测试

1 public class BaseDaoTest {
2
3     @Test
4     public void testSave() {
5         UserDao userDao = new UserDaoImpl();
6         RoleDao roleDao = new RoleDaoImpl();
7     }
8
9 }