通常来说一个项目中,我们会使用到多个Dao,例如一个学生管理系统,可能就包含AdminDao,StudentDao,CourseDao等模块,每个Dao都有相同的增删改查代码,每个Dao去写也是可以的,不过代码量就会偏多。实际上可以通过泛型,来抽取出一个BaseDao,这个BaseDao包含了各个Dao常用的增删改查代码,创建新的Dao时,继承BaseDao,就可以少写很多重复代码。
下面我们先写一个普通的Dao,然后抽取出BaseDao,看Dao前后代码变化。
1、抽取前dao接口代码
package cn.tax.nsfw.user.dao;
import java.io.Serializable;
import java.util.List;
import cn.tax.nsfw.user.entity.User;
public interface UserDao {
public void save(User user);// 保存
public void delete(User user);// 删除用户
public void update(User user);// 更新用户
public User findById(Serializable id);// 根据主键查找用户
public List<User> getAll();// 查看所有
}
2、抽取前dao实现类
package cn.tax.nsfw.user.dao.impl;
import java.io.Serializable;
import java.util.List;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import cn.tax.nsfw.user.dao.UserDao;
import cn.tax.nsfw.user.entity.User;
public class UserDaoImpl extends HibernateDaoSupport implements UserDao {
public void save(User user) {
getSession().save(user);
}
public void delete(User user) {
getSession().delete(user);
}
public void update(User user) {
getSession().update(user);
}
public User findById(Serializable id) {
return (User) getSession().get(User.class, id);
}
public List<User> getAll() {
return getSession().createQuery("FROM User").list();
}
}
3、创建BaseDao接口
这个接口不需要改动太多,只需要把基本的增删改查代码改成泛型(把dao接口的复制过来,把User 改成 T ,)T是可以任意一个字母,只是习惯都用T (泛型知识)。
package cn.tax.nsfw.core.dao;
import java.io.Serializable;
import java.util.List;
public interface BaseDao<T> {
public void save(T entity);// 保存
public void delete(T entity);// 删除用户
public void update(T entity);// 更新用户
public T findById(Serializable id);// 根据主键查找用户
public List<T> getAll();// 查看所有
}
4、创建BaseDao实现
实现了BaseDao接口后,最主要的做的事情是要获取到T的类型。
因为在查询数据库的时候Hibernate需要用到这个字段去拼接查询语句
其实在service层调用的时候,就已经知道T的传入类型,问题就在于怎么在BaseDao实现类中获取到这个传入类型,看下面这行代码,这行代码返回的是包含泛型的父类:
a、ParameterizedType pt =
(ParameterizedType)this.getClass().getGenericSuperclass();
具体打印出来是:cn.tax.nsfw.core.dao.impl.BaseDaoImpl< cn.tax.nsfw.user.entity.User >
b、clazz = (Class< T >)pt.getActualTypeArguments()[0]
这行代码返回的是此类型实际类型参数的Type对象的数组,数组里放的都是对应类型的Class
具体打印出来的是:cn.tax.nsfw.user.entity.User
c、到这里就已经拿到了在service层传进来的实体类类型。
最后用的时候再通过clazz.getSimpleName()就可以拿到“User”字段去拼接查询语句了
BaseDao实现类代码:
package cn.tax.nsfw.core.dao.impl;
import java.io.Serializable;
import java.lang.reflect.ParameterizedType;
import java.util.List;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import cn.tax.nsfw.core.dao.BaseDao;
public class BaseDaoImpl<T> extends HibernateDaoSupport implements BaseDao<T> {
Class<T> clazz;
ParameterizedType pt;
public BaseDaoImpl() {
pt = (ParameterizedType)this.getClass().getGenericSuperclass(); //cn.tax.nsfw.core.dao.impl.BaseDaoImpl<cn.tax.nsfw.user.entity.User>
clazz = (Class<T>)pt.getActualTypeArguments()[0]; //cn.tax.nsfw.user.entity.User
}
public void save(T entity) {
getSession().save(entity);
}
public void delete(T entity) {
getSession().delete(entity);
}
public void update(T entity) {
getSession().update(entity);
}
public T findById(Serializable id) {
return (T) getSession().get(clazz, id);
}
public List<T> getAll() {
return getSession().createQuery("FROM " + clazz.getSimpleName()).list();
}
}
5、修改抽取前的Dao接口
A、继承BaseDao< User >
B、把BaseDao< User >中有的方法都可以注释掉(删掉),
C、以后有新增的业务,只需要加新增的业务代码。整个dao就没有多少代码了。
package cn.tax.nsfw.user.dao;
import cn.tax.nsfw.core.dao.BaseDao;
import cn.tax.nsfw.user.entity.User;
public interface UserDao extends BaseDao<User> {
//public void save(User user);// 保存
//public void delete(User user);// 删除用户
//public void update(User user);// 更新用户
//public User findById(Serializable id);// 根据主键查找用户
//public List<User> getAll();// 查看所有
}
6、修改抽取前的dao实现类
A、继承BaseDaoImpl< Use r> ,因为BaseDaoImpl< User >继承了hibernateDaoSupport,所以UserDaoImpl 也是可以用hibernateDaoSupport的方法的
B、同样是把BaseDaoImpl< User >中已有的方法注释掉(删掉),只需添加新的业务代码。
package cn.tax.nsfw.user.dao.impl;
import cn.tax.nsfw.core.dao.impl.BaseDaoImpl;
import cn.tax.nsfw.user.dao.UserDao;
import cn.tax.nsfw.user.entity.User;
public class UserDaoImpl extends BaseDaoImpl<User> implements UserDao {
//如果没有新的业务,dao层代码基本是空的,所有基本的增删改查都交给baseDao来处理,
//这里只需要实现一些新增业务代码就可以了
/*public void save(User user) {
getSession().save(user);
}
public void delete(User user) {
getSession().delete(user);
}
public void update(User user) {
getSession().update(user);
}
public User findById(Serializable id) {
return (User) getSession().get(User.class, id);
}
public List<User> getAll() {
return getSession().createQuery("FROM User").list();
}*/
}