Hibernate baseDao底層封裝

package com.test.main.core.dao;

import java.math.BigDecimal;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;

import org.apache.commons.lang.StringUtils;
import org.hibernate.Hibernate;
import org.hibernate.Query;
import org.hibernate.SessionFactory;
import org.hibernate.transform.Transformers;
import org.springframework.dao.DataAccessException;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.springframework.stereotype.Repository;
import org.springframework.util.Assert;

import com.test.main.core.web.Page;

@Repository("hibernateGenericDao")
public class HibernateGenericDao<T> extends HibernateDaoSupport {

    @Resource(name = "sessionFactory")
    public void setSuperSessionFactory(SessionFactory sessionFactory) {
	super.setSessionFactory(sessionFactory);
    }

    /**
     * 根據hql查詢,直接使用HibernateTemplate的find函數.
     * 
     * @param values：可變參數
     */
    @SuppressWarnings("unchecked")
    public List<T> find(String hql, Object... values) throws DataAccessException {
	Assert.hasText(hql);
	return getHibernateTemplate().find(hql, values);
    }

    /**
     * 按HQL分頁查詢.
     * 
     * @param page 分頁參數. 注意不支持其中的orderBy參數.
     * @param hql hql語句.
     * @param values 數量可變的查詢參數,按順序綁定.
     * 
     * @return  分頁查詢結果, 附帶結果列表及全部查詢輸入參數.
     */
    @SuppressWarnings("unchecked")
    public Page<T> findPage(final Page<T> page, final String hql, final Object... values) {
	Assert.notNull(page, "page不能爲空");

	Query q = createQuery(hql, values);

	if (page.isAutoCount()) {
	    long totalCount = countHqlResult(hql, values);
	    page.setTotalCount(totalCount);
	}

	setPageParameterToQuery(q, page);

	List result = q.list();
	page.setResult(result);
	return page;
    }
    
    /**
     * 按HQL分頁查詢.
     * 
     * @param page 分頁參數. 注意不支持其中的orderBy參數.
     * @param hql hql語句.
     * @param values 數量可變的查詢參數,按順序綁定.
     * 
     * @return  分頁查詢結果, 附帶結果列表及全部查詢輸入參數.
     */
    @SuppressWarnings("unchecked")
    public Page<T> findPage(final Page<T> page, final String hql, Map paramMap) {
	Assert.notNull(page, "page不能爲空");
	
	Query q = createQuery(hql, paramMap);
	
	if (page.isAutoCount()) {
	    long totalCount = countHqlResult(hql, paramMap);
	    page.setTotalCount(totalCount);
	}
	
	setPageParameterToQuery(q, page);
	
	List result = q.list();
	page.setResult(result);
	return page;
    }
    
    
    /**
     * 按SQL分頁查詢.
     * 
     * @param page 分頁參數. 注意不支持其中的orderBy參數.
     * @param hql hql語句.
     * @param values 數量可變的查詢參數,按順序綁定.
     * 
     * @return  分頁查詢結果, 附帶結果列表及全部查詢輸入參數.
     */
    @SuppressWarnings("unchecked")
    public Page findPageBySql(final Page page, final String sql, final Object... values) {
	Assert.notNull(page, "page不能爲空");

	Query q = createQuerySQL(sql, values);

	if (page.isAutoCount()) {
	    long totalCount = countSqlResult(sql, values);
	    page.setTotalCount(totalCount);
	}
	q.setFirstResult(page.getFirst() - 1);
	q.setMaxResults(page.getPageSize());
	
	List result = q.list();
	page.setResult(result);
	return page;
    }
    //重載方法 返回Map 對象集合
    @SuppressWarnings("unchecked")
    public Page findPageBySql(final Page page, final String sql,boolean isReturnMap, final Object... values) {
	Assert.notNull(page, "page不能爲空");

	Query q = createQuerySQL(sql, values);

	if (page.isAutoCount()) {
	    long totalCount = countSqlResult(sql, values);
	    page.setTotalCount(totalCount);
	}
	q.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
	q.setFirstResult(page.getFirst() - 1);
	q.setMaxResults(page.getPageSize());
	
	List result = q.list();
	page.setResult(result);
	return page;
    }    
    
    /**
     * 根據查詢SQL與參數列表建立Query對象. 與find()函數可進行更加靈活的操做.
     * 
     * @param values 數量可變的參數,按順序綁定.
     */
    public Query createQuerySQL(final String sql, final Object... values) {
	Assert.hasText(sql, "sql不能爲空");
	Query query = getSession().createSQLQuery(sql);
	if (values != null) {
	    for (int i = 0; i < values.length; i++) {
		query.setParameter(i, values[i]);
	    }
	}
	return query;
    }
    
    /**
     * 執行count查詢得到本次sql查詢所能得到的對象總數.
     * 
     * 本函數只能自動處理簡單的hql語句,複雜的hql查詢請另行編寫count語句查詢.
     */
    protected long countSqlResult(final String hql, final Object... values) {
	String countHql = prepareCountSQL(hql);

	try {
	    Long count = findUniqueSQL(countHql, values);
	    return count;
	} catch (Exception e) {
	    throw new RuntimeException("hql can't be auto count, hql is:" + countHql, e);
	}
    }

    
    /**
     * 根據查詢HQL與參數列表建立Query對象. 與find()函數可進行更加靈活的操做.
     * 
     * @param values 數量可變的參數,按順序綁定.
     */
    public Query createQuery(final String queryString, final Object... values) {
	Assert.hasText(queryString, "queryString不能爲空");
	Query query = getSession().createQuery(queryString);
	if (values != null) {
	    for (int i = 0; i < values.length; i++) {
		query.setParameter(i, values[i]);
	    }
	}
	return query;
    }
    /**
     * 根據查詢HQL與參數列表建立Query對象. 與find()函數可進行更加靈活的操做.
     * 
     * @param paramMap 過濾條件
     */
    public Query createQuery(final String queryString, final Map<String,?> paramMap) {
	Assert.hasText(queryString, "queryString不能爲空");
	Query query = getSession().createQuery(queryString);
	if (paramMap != null) {
	    Iterator<String> it= paramMap.keySet().iterator();
	    while (it.hasNext()) {
		String key = (String) it.next();
		Object value=paramMap.get(key);
		if(value instanceof Object[]){
		    query.setParameterList(key, (Object[])value);
		}else{
		    query.setParameter(key, value);
		}
	    }
	}
	return query;
    }

    /**
     * 執行count查詢得到本次SQL查詢所能得到的對象總數.
     * 
     * 本函數只能自動處理簡單的hql語句,複雜的hql查詢請另行編寫count語句查詢.
     */
    protected long countHqlResult(final String hql, final Object... values) {
	String countHql = prepareCountHql(hql);

	try {
	    Long count = findUnique(countHql, values);
	    return count;
	} catch (Exception e) {
	    throw new RuntimeException("hql can't be auto count, hql is:" + countHql, e);
	}
    }
    /**
     * 執行count查詢得到本次SQL查詢所能得到的對象總數.
     * 
     * 本函數只能自動處理簡單的hql語句,複雜的hql查詢請另行編寫count語句查詢.
     */
    protected long countHqlResult(final String hql, final Map<String, Object> paramMap) {
	String countHql = prepareCountHql(hql);
	
	try {
	    Long count = findUnique(countHql, paramMap);
	    return count;
	} catch (Exception e) {
	    throw new RuntimeException("hql can't be auto count, hql is:" + countHql, e);
	}
    }

    private String prepareCountHql(String orgHql) {
	String fromHql = orgHql;
	// select子句與order by子句會影響count查詢,進行簡單的排除.
	fromHql = "from " + StringUtils.substringAfter(fromHql, "from");
	fromHql = StringUtils.substringBefore(fromHql, "order by");

	String countHql = "select count(*) " + fromHql;
	return countHql;
    }

    private String prepareCountSQL(String orgSql) {
	String countSql = "select count(*) from (" + orgSql+") tt";
	return countSql;
    }
    
    /**
     * 按SQL查詢惟一對象.
     * 
     * @param values 數量可變的參數,按順序綁定.
     */
    public Long findUniqueSQL(final String sql, final Object... values) {
	return ((BigDecimal) createQuerySQL(sql, values).uniqueResult()).longValue();
    }
    
    /**
     * 按HQL查詢惟一對象.
     * 
     * @param values 數量可變的參數,按順序綁定.
     */
    public Long findUnique(final String hql, final Object... values) {
	return (Long) createQuery(hql, values).uniqueResult();
    }
    /**
     * 按HQL查詢惟一對象.
     * 
     * @param paramMap 數量可變的參數,按順序綁定.
     */
    public Long findUnique(final String hql, final Map<String,Object> paramMap) {
	return (Long) createQuery(hql, paramMap).uniqueResult();
    }

    /**
     * 設置分頁參數到Query對象,輔助函數.
     */
    protected Query setPageParameterToQuery(final Query q, final Page<T> page) {

	Assert.isTrue(page.getPageSize() > 0, "Page Size must larger than zero");

	// hibernate的firstResult的序號從0開始
	q.setFirstResult(page.getFirst() - 1);
	q.setMaxResults(page.getPageSize());
	return q;
    }
}
 
package com.test.main.core.dao;

import java.io.Serializable;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.Order;
import org.springframework.dao.DataAccessException;

import com.test.main.core.web.Page;

public interface BaseDao<T, PK extends Serializable> {

    /**
     * 清除全部對象緩存
     */
    public void clear() throws DataAccessException;

    /**
     * 持久化多個實體。
     * 
     * @param entities ：處於臨時狀態的實體的集合。
     * @throws DataAccessException
     */
    void create(Collection<T> entities) throws DataAccessException;

    /**
     * 持久化一個實體。
     * 
     * @param entity ：處於臨時狀態的實體。
     * @throws DataAccessException
     */
    void create(T entity) throws DataAccessException;

    /**
     * 持久化或者更新多個實體。
     * 
     * @param entities ：處於臨時或者持久化狀態的實體的集合。
     * @throws DataAccessException
     */
    void createOrUpdate(Collection<T> entities) throws DataAccessException;

    /**
     * 持久化或者更新實體。
     * 
     * @param entity ：處於臨時或者持久化狀態的實體。
     * @throws DataAccessException
     */
    void createOrUpdate(T entity) throws DataAccessException;

    /**
     * 刪除多個持久化的實體。
     * 
     * @param entities ：處於持久化狀態的實體的集合。
     * @throws DataAccessException
     */
    void delete(Collection<T> entities) throws DataAccessException;

    /**
     * 刪除一個持久化的實體。
     * 
     * @param entity ：處於持久化狀態的實體。
     * @throws DataAccessException
     */
    void delete(T entity) throws DataAccessException;

    /**
     * 根據ID移除對象.
     */
    public void deleteById(PK id) throws DataAccessException;

    /**
     * 消除與 Hibernate Session 的關聯
     */
    public void evit(T entity) throws DataAccessException;

    /**
     * 執行本地sql語句得到標量數值列表 返回Object數組
     */
    @SuppressWarnings("unchecked")
    public List executeNativeSql(String sql) throws DataAccessException;

    /**
     * 執行hql語句
     * 
     * @param hql
     * @throws DataAccessException
     */
    public void executeUpdate(String hql) throws DataAccessException;

    /**
     * 執行本地sql語句得到標量數值列表 返回實體對象
     */
    public List<T> executeNativeSqlToClass(String sql) throws DataAccessException;

    /**
     * 根據hql查詢,直接使用HibernateTemplate的find函數.
     */
    @SuppressWarnings("unchecked")
    public List<T> find(String hql, Object... values) throws DataAccessException;

    public void flush();

    /**
     * 根據ID獲取對象,若是對象不存在，返回 null
     */
    public T get(PK id) throws DataAccessException;

    /**
     * 獲取所有對象
     */
    public List<T> getAll() throws DataAccessException;

    /**
     * 獲取所有對象,帶排序字段與升降序參數.
     */
    public List<T> getAll(String orderBy, boolean isAsc) throws DataAccessException;

    /**
     * 根據ID獲取對象，若是對象不存在，拋出異常.
     */
    public T load(PK id) throws DataAccessException;

    /**
     * 根據查詢HQL與參數列表建立Query對象. 與find()函數可進行更加靈活的操做.
     * 
     * @param values 命名參數,按名稱綁定.
     */
    public Query createQuery(final String queryString, final Map<String, ?> values);

    /**
     * 根據查詢HQL與參數列表建立Query對象. 與find()函數可進行更加靈活的操做.
     * 
     * @param values 數量可變的參數,按順序綁定.
     */
    public Query createQuery(final String queryString, final Object... values);

    /**
     * 根據Criterion條件建立Criteria. 與find()函數可進行更加靈活的操做.
     * 
     * @param criterions 數量可變的Criterion.
     */
    public Criteria createCriteria(final Criterion... criterions);

    /**
     * 保存處於遊離狀態的多個實體，更新後實體對象仍然處於遊離狀態。
     * 
     * @param entities ：處於遊離狀態的實體的集合。
     * @throws DataAccessException
     */
    void merge(Collection<T> entities) throws DataAccessException;

    /**
     * 更新處於遊離狀態的實體，更新後實體對象仍然處於遊離狀態。
     * 
     * @param entity ：處於遊離狀態的實體。
     * @throws DataAccessException
     */
    void merge(T entity) throws DataAccessException;

    /**
     * 分頁查詢
     * 
     * @param page ：分頁對象
     * @param hql ：hql語句
     * @param values ：參數值
     * @return  page：對象
     * @throws DataAccessException
     */
    Page<T> findPage(Page<T> page, String hql, Object... values) throws DataAccessException;
    Page<T> findPage(Page<T> page, String hql, Map<String, Object> paramMap) throws DataAccessException;

    /**
     * 分頁查詢
     * 
     * @param page ：分頁對象
     * @param sql ：hql語句
     * @param values ：參數值
     * @return  page：對象
     * @throws DataAccessException
     */
    Page<T> findPageBySQL(Page<T> page, String sql, Object... values) throws DataAccessException;

    
    /**
     * 更新多個實體。
     * 
     * @param entities ：處於持久化狀態的實體的集合。
     * @throws DataAccessException
     */
    void update(Collection<T> entities) throws DataAccessException;

    /**
     * 更新實體。
     * 
     * @param entity ：處於持久化狀態的實體。
     * @throws DataAccessException
     */
    void update(T entity) throws DataAccessException;

    /**
     * 按Criteria查詢對象列表.
     * 
     * @param criterions 數量可變的Criterion.
     */
    List<T> find(final Criterion... criterions);

    /**
     * 按屬性過濾條件列表查找對象列表.
     */
    List<T> find(List<PropertyFilter> filters);
    List<T> find(List<PropertyFilter> filters,List<Order> orders);
    List<T> find(HashMap<String, String> aliasMap, List<PropertyFilter> filters);

    /**
     * 執行count查詢得到本次Criteria查詢所能得到的對象總數.
     */
    long countCriteriaResult(final Criteria c);

    /**
     * 按Criteria分頁查詢.
     * 
     * @param page 分頁參數.
     * @param criterions 數量可變的Criterion.
     * 
     * @return  分頁查詢結果.附帶結果列表及全部查詢輸入參數.
     */
    @SuppressWarnings("unchecked")
    public Page<T> findPage(final Page<T> page, final Criterion... criterions);

    /**
     * 按屬性過濾條件列表分頁查找對象.
     */
    Page<T> findPage(final Page<T> page, final List<PropertyFilter> filters);

}

package com.test.main.core.dao;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;

import org.apache.commons.lang.StringUtils;
import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.SessionFactory;
import org.hibernate.criterion.CriteriaSpecification;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.DetachedCriteria;
import org.hibernate.criterion.Disjunction;
import org.hibernate.criterion.MatchMode;
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Projection;
import org.hibernate.criterion.Projections;
import org.hibernate.criterion.Restrictions;
import org.hibernate.impl.CriteriaImpl;
import org.hibernate.transform.ResultTransformer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.dao.DataAccessException;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.springframework.util.Assert;

import com.test.main.core.dao.PropertyFilter.MatchType;
import com.test.main.core.web.Page;
import com.test.main.util.ReflectionUtils;

@Scope("prototype")
public class BaseDaoHibernate<T, PK extends Serializable> extends HibernateDaoSupport implements BaseDao<T, PK> {

    @Autowired
    private HibernateGenericDao<T> hibernateGenericDao;
    protected final Logger logger = LogManager.getLogger(BaseDaoHibernate.class);
    protected Class<T> entityClass;

    public BaseDaoHibernate() {
    }

    public BaseDaoHibernate(Class<T> entityClass) {
	this.entityClass = entityClass;
    }

    public void clear() throws DataAccessException {
	getHibernateTemplate().clear();
    }

    public void create(Collection<T> entities) throws DataAccessException {
	if (entities != null && entities.size() > 0) {
	    Iterator<T> it = entities.iterator();
	    for (T e = null; it.hasNext();) {
		e = it.next();
		create(e);
	    }
	}
    }

    public void create(T entity) throws DataAccessException {
	getHibernateTemplate().save(entity);
    }

    public void createOrUpdate(Collection<T> entities) throws DataAccessException {
	if (entities != null && entities.size() > 0) {
	    Iterator<T> it = entities.iterator();
	    for (T e = null; it.hasNext();) {
		e = it.next();
		createOrUpdate(e);
	    }
	}
    }

    public void createOrUpdate(T entity) throws DataAccessException {
	getHibernateTemplate().saveOrUpdate(entity);
    }

    public void delete(Collection<T> entities) throws DataAccessException {
	if (entities != null && entities.size() > 0) {
	    Iterator<T> it = entities.iterator();
	    for (T e = null; it.hasNext();) {
		e = it.next();
		delete(e);
	    }
	}
    }

    public void delete(T entity) throws DataAccessException {
	super.getHibernateTemplate().delete(entity);
    }

    public void deleteById(PK id) throws DataAccessException {
	delete(get(id));
    }

    public void evit(T entity) throws DataAccessException {
	getHibernateTemplate().evict(entity);
    }

    /**
     * 執行本地sql語句得到標量數值列表 返回Object數組
     */
    @SuppressWarnings("unchecked")
    public List executeNativeSql(String sql) throws DataAccessException {
	return getSession().createSQLQuery(sql).list();
    }

    @SuppressWarnings("unchecked")
    public void executeUpdate(String hql) throws DataAccessException {
	getSession().createQuery(hql).executeUpdate();
    }

    /**
     * 執行本地sql語句得到標量數值列表 返回實體對象
     */
    @SuppressWarnings("unchecked")
    public List<T> executeNativeSqlToClass(String sql) throws DataAccessException {
	return getSession().createSQLQuery(sql).addEntity(this.entityClass).list();
    }

    @SuppressWarnings("unchecked")
    public List<T> find(String hql, Object... values) throws DataAccessException {
	return hibernateGenericDao.find(hql, values);
    }

    /**
     * 根據查詢HQL與參數列表建立Query對象. 與find()函數可進行更加靈活的操做.
     * 
     * @param values 命名參數,按名稱綁定.
     */
    public Query createQuery(final String queryString, final Map<String, ?> values) {
	Assert.hasText(queryString, "queryString不能爲空");
	Query query = hibernateGenericDao.createQuery(queryString,values);
	return query;
    }

    /**
     * 根據查詢HQL與參數列表建立Query對象. 與find()函數可進行更加靈活的操做.
     * 
     * @param values 數量可變的參數,按順序綁定.
     */
    public Query createQuery(final String queryString, final Object... values) {
	Assert.hasText(queryString, "queryString不能爲空");
	Query query = getSession().createQuery(queryString);
	if (values != null) {
	    for (int i = 0; i < values.length; i++) {
		query.setParameter(i, values[i]);
	    }
	}
	return query;
    }

    /**
     * 根據Criterion條件建立Criteria. 與find()函數可進行更加靈活的操做.
     * 
     * @param criterions 數量可變的Criterion.
     */
    public Criteria createCriteria(final Criterion... criterions) {
	Criteria criteria = getSession().createCriteria(entityClass);
	for (Criterion c : criterions) {
	    criteria.add(c);
	}
	return criteria;
    }

    public void flush() throws DataAccessException {
	getHibernateTemplate().flush();
    }

    public T get(PK id) throws DataAccessException {
	return (T) getHibernateTemplate().get(entityClass, id);
    }

    public List<T> getAll() throws DataAccessException {
	return (List<T>) (getHibernateTemplate().loadAll(entityClass));
    }

    @SuppressWarnings("unchecked")
    public List<T> getAll(String orderBy, boolean isAsc) throws DataAccessException {
	Assert.hasText(orderBy);
	if (isAsc)
	    return getHibernateTemplate().findByCriteria(
		    DetachedCriteria.forClass(entityClass).addOrder(Order.asc(orderBy)));
	else
	    return getHibernateTemplate().findByCriteria(
		    DetachedCriteria.forClass(entityClass).addOrder(Order.desc(orderBy)));
    }

    public T load(PK id) throws DataAccessException {
	return (T) getHibernateTemplate().load(entityClass, id);
    }

    public void merge(Collection<T> entities) throws DataAccessException {
	if (entities != null && entities.size() > 0) {
	    Iterator<T> it = entities.iterator();
	    for (T e = null; it.hasNext();) {
		e = it.next();
		merge(e);
	    }
	}
    }

    public void merge(T entity) throws DataAccessException {
	super.getHibernateTemplate().merge(entity);
    }

    public Page<T> findPage(Page<T> page, String hql, Object... values) throws DataAccessException {
	return hibernateGenericDao.findPage(page, hql, values);
    }
    public Page<T> findPage(Page<T> page, String hql, Map<String,Object> paramMap) throws DataAccessException {
	return hibernateGenericDao.findPage(page, hql, paramMap);
    }

    @Resource(name = "sessionFactory")
    public void setSuperSessionFactory(SessionFactory sessionFactory) {
	super.setSessionFactory(sessionFactory);
    }

    public void update(Collection<T> entities) throws DataAccessException {
	if (entities != null && entities.size() > 0) {
	    Iterator<T> it = entities.iterator();
	    for (T e = null; it.hasNext();) {
		e = it.next();
		update(e);
	    }
	}

    }

    public void update(T entity) throws DataAccessException {
	getHibernateTemplate().update(entity);
    }

    /**
     * 按Criteria查詢對象列表.
     * 
     * @param criterions 數量可變的Criterion.
     */
    @SuppressWarnings("unchecked")
    public List<T> find(final Criterion... criterions) {
	DetachedCriteria criteria = DetachedCriteria.forClass(entityClass);
	for (Criterion c : criterions) {
	    criteria.add(c);
	}
	return getHibernateTemplate().findByCriteria(criteria);
    }
    /**
     * 按Criteria查詢對象列表.
     * 
     * @param criterions 數量可變的Criterion.
     */
    @SuppressWarnings("unchecked")
    public List<T> find(List<Order> orders,final Criterion... criterions) {
	DetachedCriteria criteria = DetachedCriteria.forClass(entityClass);
	for (Criterion c : criterions) {
	    criteria.add(c);
	}
	for (Order order : orders) {
	    criteria.addOrder(order);
	}
	return getHibernateTemplate().findByCriteria(criteria);
    }

    /**
     * 按Criteria查詢對象列表.
     * 
     * @param criterions 數量可變的Criterion.
     */
    @SuppressWarnings("unchecked")
    public List<T> find(final HashMap<String, String> aliasMap, final Criterion... criterions) {
	DetachedCriteria criteria = DetachedCriteria.forClass(entityClass);
	if (aliasMap != null) {
	    Iterator<String> iterator = aliasMap.keySet().iterator();
	    while (iterator.hasNext()) {
		String alias = (String) iterator.next();
		criteria.createAlias(alias, aliasMap.get(alias));
	    }
	}
	for (Criterion c : criterions) {
	    criteria.add(c);
	}
	return getHibernateTemplate().findByCriteria(criteria);
    }

    /**
     * 按屬性過濾條件列表查找對象列表.
     */
    public List<T> find(List<PropertyFilter> filters) {
	Criterion[] criterions = buildCriterionByPropertyFilter(filters);
	return find(criterions);
    }
    /**
     * 按屬性過濾條件列表查找對象列表.待排序
     */
    public List<T> find(List<PropertyFilter> filters,List<Order> orders) {
	Criterion[] criterions = buildCriterionByPropertyFilter(filters);
	return find(orders,criterions);
    }

    /**
     * 按屬性過濾條件列表查找對象列表.
     */
    public List<T> find(HashMap<String, String> aliasMap, List<PropertyFilter> filters) {
	Criterion[] criterions = buildCriterionByPropertyFilter(filters);
	return find(aliasMap, criterions);
    }

    /**
     * 按屬性條件參數建立Criterion,輔助函數.
     */
    protected Criterion buildCriterion(final String propertyName, final Object propertyValue, final MatchType matchType) {
	Assert.hasText(propertyName, "propertyName不能爲空");
	Criterion criterion = null;
	// 根據MatchType構造criterion
	switch (matchType) {
	case EQ:
	    criterion = Restrictions.eq(propertyName, propertyValue);
	    break;
	case LIKE:
	    criterion = Restrictions.like(propertyName, (String) propertyValue, MatchMode.ANYWHERE);
	    break;

	case LE:
	    criterion = Restrictions.le(propertyName, propertyValue);
	    break;
	case LT:
	    criterion = Restrictions.lt(propertyName, propertyValue);
	    break;
	case GE:
	    criterion = Restrictions.ge(propertyName, propertyValue);
	    break;
	case GT:
	    criterion = Restrictions.gt(propertyName, propertyValue);
	}
	return criterion;
    }

    /**
     * 按屬性條件列表建立Criterion數組,輔助函數.
     */
    protected Criterion[] buildCriterionByPropertyFilter(final List<PropertyFilter> filters) {
	List<Criterion> criterionList = new ArrayList<Criterion>();
	for (PropertyFilter filter : filters) {
	    if (!filter.hasMultiProperties()) { // 只有一個屬性須要比較的狀況.
		Criterion criterion = buildCriterion(filter.getPropertyName(), filter.getMatchValue(), filter
			.getMatchType());
		criterionList.add(criterion);
	    } else {// 包含多個屬性須要比較的狀況,進行or處理.
		Disjunction disjunction = Restrictions.disjunction();
		for (String param : filter.getPropertyNames()) {
		    Criterion criterion = buildCriterion(param, filter.getMatchValue(), filter.getMatchType());
		    disjunction.add(criterion);
		}
		criterionList.add(disjunction);
	    }
	}
	return criterionList.toArray(new Criterion[criterionList.size()]);
    }

    /**
     * 執行count查詢得到本次Criteria查詢所能得到的對象總數.
     */
    @SuppressWarnings("unchecked")
    public long countCriteriaResult(final Criteria c) {
	CriteriaImpl impl = (CriteriaImpl) c;

	// 先把Projection、ResultTransformer、OrderBy取出來,清空三者後再執行Count操做
	Projection projection = impl.getProjection();
	ResultTransformer transformer = impl.getResultTransformer();

	List<CriteriaImpl.OrderEntry> orderEntries = null;
	try {
	    orderEntries = (List) ReflectionUtils.getFieldValue(impl, "orderEntries");
	    ReflectionUtils.setFieldValue(impl, "orderEntries", new ArrayList());
	} catch (Exception e) {
	    logger.error("不可能拋出的異常:{}", e);
	}

	// 執行Count查詢
	Long totalCountObject = (Long) c.setProjection(Projections.rowCount()).uniqueResult();
	long totalCount = (totalCountObject != null) ? totalCountObject : 0;

	// 將以前的Projection,ResultTransformer和OrderBy條件從新設回去
	c.setProjection(projection);

	if (projection == null) {
	    c.setResultTransformer(CriteriaSpecification.ROOT_ENTITY);
	}
	if (transformer != null) {
	    c.setResultTransformer(transformer);
	}
	try {
	    ReflectionUtils.setFieldValue(impl, "orderEntries", orderEntries);
	} catch (Exception e) {
	    logger.error("不可能拋出的異常:{}", e);
	}

	return totalCount;
    }

    /**
     * 按Criteria分頁查詢.
     * 
     * @param page 分頁參數.
     * @param criterions 數量可變的Criterion.
     * 
     * @return  分頁查詢結果.附帶結果列表及全部查詢輸入參數.
     */
    @SuppressWarnings("unchecked")
    public Page<T> findPage(final Page<T> page, final Criterion... criterions) {
	Assert.notNull(page, "page不能爲空");

	Criteria c = createCriteria(criterions);

	if (page.isAutoCount()) {
	    long totalCount = countCriteriaResult(c);
	    page.setTotalCount(totalCount);
	}

	setPageParameterToCriteria(c, page);

	List result = c.list();
	page.setResult(result);
	return page;
    }

    /**
     * 設置分頁參數到Criteria對象,輔助函數.
     */
    protected Criteria setPageParameterToCriteria(final Criteria c, final Page<T> page) {

	Assert.isTrue(page.getPageSize() > 0, "Page Size must larger than zero");

	// hibernate的firstResult的序號從0開始
	c.setFirstResult(page.getFirst() - 1);
	c.setMaxResults(page.getPageSize());

	if (page.isOrderBySetted()) {
	    String[] orderByArray = StringUtils.split(page.getOrderBy(), ',');
	    String[] orderArray = StringUtils.split(page.getOrder(), ',');

	    Assert.isTrue(orderByArray.length == orderArray.length, "分頁多重排序參數中,排序字段與排序方向的個數不相等");

	    for (int i = 0; i < orderByArray.length; i++) {
		if (Page.ASC.equals(orderArray[i])) {
		    c.addOrder(Order.asc(orderByArray[i]));
		} else {
		    c.addOrder(Order.desc(orderByArray[i]));
		}
	    }
	}
	return c;
    }

    /**
     * 按屬性過濾條件列表分頁查找對象.
     */
    public Page<T> findPage(final Page<T> page, final List<PropertyFilter> filters) {
	Criterion[] criterions = buildCriterionByPropertyFilter(filters);
	return findPage(page, criterions);
    }

    @SuppressWarnings("unchecked")
    public Page<T> findPageBySQL(Page<T> page, String sql, Object... values) throws DataAccessException {
	return  hibernateGenericDao.findPageBySql(page, sql, values);
    }
    
    @SuppressWarnings("unchecked")
    public Page<T> findPageBySQL(Page<T> page, String sql,boolean isReturnMap, Object... values) throws DataAccessException {
	return  hibernateGenericDao.findPageBySql(page, sql,isReturnMap, values);
    }    
}

 應用例子：

package com.test.crawler.initcrawler.dao;

import java.util.List;

import com.test.crawler.core.dao.BaseDao;
import com.test.crawler.core.dao.Page;
import com.test.crawler.initcrawler.entity.UrlFilter;

public interface UrlFilterDao extends BaseDao<UrlFilter, String> {
	
	/**
	 * 根據種子節點與狀態，查詢種子入口過濾網址.
	 * @param note 節點
	 * @param stauts 狀態
	 * @return 
	 */
	public List<UrlFilter> findUrlFilterByNoteAndStruts(String note,String status);
	
	/**
	 * 根據節點與狀態，查詢過濾網址
	 * @param note
	 * @param stauts
	 * @param type
	 * @return 
	 */
	public List<UrlFilter> findFilterByType(String note,String stauts,String type);

package com.test.crawler.initcrawler.dao.imp;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import com.test.crawler.core.dao.BaseDaoHibernate;
import com.test.crawler.core.dao.Page;
import com.test.crawler.initcrawler.dao.UrlFilterDao;
import com.test.crawler.initcrawler.entity.UrlFilter;

@Repository("urlFilterDao")
public class UrlFilterDaoImp extends BaseDaoHibernate<UrlFilter,String> implements UrlFilterDao {
	@Autowired
	private JdbcTemplate jdbcTemplate;
	
	public UrlFilterDaoImp() {
		super(UrlFilter.class);
	}
	
	public List<UrlFilter> findUrlFilterByNoteAndStruts(String note,
			String status) {
		String hql = "FROM UrlFilter t WHERE t.node=? and t.status=?";
		return this.find(hql, note,status);
	}
	
	public List<UrlFilter> findFilterByType(String note,String stauts,String type){
		String hql = " FROM UrlFilter t WHERE t.node=? and t.status=? and t.type=?";
		
		return this.find(hql, note, stauts, type);
	}