使用HibernateDaoSupport抽取BaseDao

时间：2017-08-19 19:59:08 阅读：267 评论：0 收藏：0 [点我收藏+]

标签：sed param exce save size date bst tor round

在开发采用Struts2+Spring+hibernate这三大框架的项目时，我们需要一个抽取一个BaseDao。这个Dao里面CRUD都给封装好，后续的其他Dao直接用它的功能就可以。Spring里面有个HibernateDaoSupport的类，这个类需要给他一个SessionFactory。有了SessionFactory后，他就可以做各种操作；最强大的功能是它可以getHibernateTemplate来获取一个HibernateTemplate。有了HibernateTemplate，就有了各种CRUD方法。废话不多说，下面直接看代码

一、BaseDao接口及实现的代码

（1）BaseDao接口的代码

package com.tax.core.dao;
import java.io.Serializable;
import java.util.List;
/**
 * BaseDao
 * @author ZENG.XIAO.YAN
 * @date 2017年6月29日 上午10:36:57
 * @version v1.0
 */
public interface BaseDao<T> {
	/**
	 * 新增
	 * @param entity
	 */
	public void save(T entity);
	/**
	 * 更新
	 * @param entity
	 */
	public void update(T entity);
	/**
	 * 根据id删除
	 * @param id
	 */
	public void deleteById(Serializable id);
	
	/**
	 * 通过id查找
	 * @param id
	 * @return 实体
	 */
	public T findById(Serializable id);
	
	/**
	 * 查找所有
	 * @return List集合
	 */
	public List<T> findAll();
}

（2）BaseDaoImpl的代码

package com.tax.core.dao.impl;
import java.io.Serializable;
import java.lang.reflect.ParameterizedType;
import java.util.List;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.orm.hibernate5.support.HibernateDaoSupport;
import com.tax.core.dao.BaseDao;
/**
 * BaseDaoImpl
 * @author   ZENG.XIAO.YAN
 * @date 	 2017年6月29日 下午12:23:16
 * @version  v1.0
 */
public abstract class BaseDaoImpl<T> extends HibernateDaoSupport implements BaseDao<T> {
	
	private Class<T> clazz;
	
	// 按照类型自动注入SessionFactory; 在实例化的时候,Spring按照形参的类型自动注入
	@Autowired
	public void setMySessionFactory(SessionFactory sessionFactory){
		setSessionFactory(sessionFactory);
	}
	
	public BaseDaoImpl() {
		//this表示当前被实例化的对象；如UserDaoImpl
		ParameterizedType pt = (ParameterizedType)this.getClass().getGenericSuperclass();//BaseDaoImpl<User> 
		clazz = (Class<T>)pt.getActualTypeArguments()[0];
	}
	
	/**
	 * 获取session
	 * @return session
	 */
	public Session getCurrentSession(){
		Session session = null;
		this.currentSession();
		try {
			session = getSessionFactory().getCurrentSession();
		} catch (HibernateException e) {
			session = getSessionFactory().openSession();
		}
		return session;
	}
	
	@Override
	public void save(T entity) {
		getHibernateTemplate().save(entity);
	}
	
	@Override
	public void update(T entity) {
		getHibernateTemplate().update(entity);
	}
	
	@Override
	public void deleteById(Serializable id) {
		getHibernateTemplate().delete(findById(id));
	}
	
	@Override
	public T findById(Serializable id) {
		return getHibernateTemplate().get(clazz, id);
	}
	@Override
	public List<T> findAll() {
		Session session = getCurrentSession();
		Query query = session.createQuery("FROM "+ clazz.getSimpleName());
		return query.list();
	}
}