一種好的持久層開發方法——建立BaseDao和BaseDaoImpl

    使用hibernate開發持久層時，我們會發現：雖然entity類的含義和需求不同，其對應的Dao層類對應的方法也是不同的。但是有許多方法操作確實相同的。比如實體的增加，刪除，修改更新，以及許多常用的查詢方法。這些都是可復用的。因此可以把這些操作寫在一個BaseDao中，其他的dao都繼承於這個Dao。每個子dao只寫與自己的業務相關的方法，這樣可以提高代碼的復用，增加了開發效率，也方便今后可能的擴展。下面是我在我的項目中使用的BaseDao和BaseDaoImpl的使用方法。僅供參考：

BaseDao：

package com.bupt.auth.dao.base;

import java.io.Serializable;
import java.util.List;

public interface BaseDao<T> {
    Long save(T entity);  //保存實體類
    
    void delete(Long id); //刪除實體類

    void update(T entity); //更新實體

    T getById(Long id); //通過id獲得實體

    List<T> getByIds(Long[] ids);//根據id數組獲得對應的實體數組

    List<T> findAll();//獲得全部的實體

    Long totalNum();//實體類的數量
    
    List<T> getPage(int pageNow, int pageSize);//分頁查找
    
    List<T> find(String hql , String param);//根據具體的hql語句查找實體類


}

BaseDaoImpl：

package com.bupt.auth.dao.base;

import java.lang.reflect.ParameterizedType;
import java.util.Collections;
import java.util.List;

import javax.annotation.Resource;

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.transaction.annotation.Transactional;


@Transactional
@SuppressWarnings("unchecked")
public abstract class BaseDaoImpl<T> implements BaseDao<T> {
    @Resource
    private SessionFactory sessionFactory;

    private Class<T> clazz=null;
    
    @SuppressWarnings("unchecked")
    public BaseDaoImpl(){
        ParameterizedType pt=(ParameterizedType)this.getClass().getGenericSuperclass();
        this.clazz = (Class<T>) pt.getActualTypeArguments()[0];
    }
    public Session getSession() {
        return sessionFactory.getCurrentSession();
    }
    
    public void setSessionFactory(SessionFactory sessionFactory)
    {
        this.sessionFactory = sessionFactory;
    }
    public SessionFactory getSessionFactory()
    {
        return this.sessionFactory;
    }
    public Long save(T entity) {
        return    (Long)getSession().save(entity);
    }

    public void delete(Long id) {
        // TODO Auto-generated method stub
        Object object = getById(id);
        if(object != null){
            getSession().delete(object);
        }
    }

    public void update(T entity) {
        // TODO Auto-generated method stub
        getSession().update(entity);
    }

    public T getById(Long id) {
        // TODO Auto-generated method stub
        if(id != null){
            return (T)getSession().get(clazz, id);
        }else{
            return null;
        }
    }

    public List<T> getByIds(Long[] ids) {
        // TODO Auto-generated method stub\
        if(ids == null || ids.length == 0){
            return Collections.emptyList();
        }else{
            return getSession().createQuery("from "+
                    clazz.getSimpleName() + " where id in(:ids)").setParameterList("ids",ids).list();
        }
    }
    
    public List<T> find(String hql , String param)
    {
        // 創建查詢
        Query query = getSession()
            .createQuery(hql);
        // 為包含占位符的HQL語句設置參數
        
            query.setParameter("1",param);
        
        return (List<T>)query.list();
    }

    public List<T> findAll() {
        // TODO Auto-generated method stub
        return getSession().createQuery("from " + clazz.getSimpleName()).list();
    }

    public Long totalNum() {
        // TODO Auto-generated method stub
        return (Long)getSession().createQuery("select count(*) from " + clazz.getSimpleName()).uniqueResult();
    }

    public List<T> getPage(int pageNow, int pageSize) {
        // TODO Auto-generated method stub
        return getSession().createQuery("from " + clazz.getSimpleName()).setFirstResult((pageNow - 1) * pageSize).setMaxResults(pageSize).list();
    }
    
    /*@SuppressWarnings("unchecked")
    public T get(Class<T> entityClazz , String id)
    {
        return (T)((SessionFactory) getSession()).getCurrentSession()
            .get(entityClazz , id);
    }*/
}