daohelperhiberante3imp.java

使用WEBWORK,SPRING,HIBERNATE编写的简单的添加

/**
 *文件功能： 
 */
package com.common.dao;

import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.hibernate.Hibernate;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.dao.DataAccessException;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.common.Config;
import com.common.exception.DAOException;
import com.common.util.PaginationSupport;

/**
 * @作者 徐建协
 * @日期 2008-3-9
 */
public class DaoHelperHiberante3Imp extends HibernateDaoSupport implements DaoHelper{
	private static Log log = LogFactory.getLog(HibernateDaoHelper.class);
	public final static String COUNT_ALIAS = "count";
	protected final static String ALIAS_PREFIX = "alias_";	
	protected final static int DEFAULT_BATCH_SIZE = Config.batchSize;
	
	private String queryCacheRegion;
	public String getQueryCacheRegion() {
		return queryCacheRegion;
	}
	public void setQueryCacheRegion(String queryCacheRegion) {
		this.queryCacheRegion = queryCacheRegion;
	}
	public String queryForOne(final String sql, final String alias,final Object values[]){
        String res = (String) getHibernateTemplate().execute(new HibernateCallback() {
            public Object doInHibernate(Session session) throws HibernateException {
            	String trueAlias = (alias == null) ? COUNT_ALIAS : alias;
                Query query = session.createSQLQuery(sql).addScalar(trueAlias, Hibernate.STRING);
                if (values!=null&&values.length>0){
                	for (int index = 0; index < values.length;index++) {
						Object value = values[index];
						query.setParameter(index, value);
					}
                }
                return query.uniqueResult();
            }
        }, true);
        return res;
	}
			
	
	public int countBySQL(final String sql, final String alias,final Object values[]) {
        Integer count = (Integer) getHibernateTemplate().execute(new HibernateCallback() {
            public Object doInHibernate(Session session) throws HibernateException {
            	String trueAlias = (alias == null) ? COUNT_ALIAS : alias;
                Query query = session.createSQLQuery(sql).addScalar(trueAlias, Hibernate.INTEGER);
                if (values!=null&&values.length>0){
                	for (int index = 0; index < values.length;index++) {
						Object value = values[index];
						query.setParameter(index, value);
					}
                }
                return query.uniqueResult();
            }
        }, true);
        return count == null ? 0 : count.intValue();
    }  
    @SuppressWarnings("unchecked")
    public List findBySQL(final String sql, final String alias, final Class entityClass,final Object values[], final boolean cacheable, final int startIndex, final int maxResultCount) {
        return (List) getHibernateTemplate().execute(new HibernateCallback() {
            public Object doInHibernate(Session session) throws HibernateException {
                Query query = (alias == null) ? session.createSQLQuery(sql).addEntity(entityClass) : session.createSQLQuery(sql).addEntity(alias, entityClass);
                if (values!=null&&values.length>0){
                	for (int index = 0; index < values.length;index++) {
						Object value = values[index];
						query.setParameter(index, value);
					}
                }
                if (cacheable) {
                    query.setCacheable(true);
                    if (getQueryCacheRegion() != null) {
                        query.setCacheRegion(getQueryCacheRegion());
                    }
                }
                if (maxResultCount != -1) {
                    query.setMaxResults(maxResultCount);
                }
                if (startIndex != -1) {
                    query.setFirstResult(startIndex);
                }
                
                return query.list();
            }
        }, true);
    }
    public PaginationSupport findBySQL(PaginationSupport paginationSupport,String countSQL,String countAlias,String sql,String sqlAlias,Object[] values, final Class entityClass, final boolean cacheable) {   
    	paginationSupport.setTotalCount(countBySQL(countSQL,countAlias,values));
    	paginationSupport.setItems(findBySQL(sql,sqlAlias,entityClass,values,cacheable,paginationSupport.getStartIndex(),paginationSupport.getPageSize()));
    	return paginationSupport;
    } 
    /********************
     * 批量执行hibernate的hql语句
     * @param hql
     * @param values
     */
    public void batchHQL(final String hql,final Object[] values){
    	getHibernateTemplate().execute(
				new HibernateCallback() {
					public Object doInHibernate(Session session)
							throws HibernateException {
						try {
							Query query=session.createQuery(hql);
							if (values!=null&&values.length>0){
			                	for (int index = 0; index < values.length;index++) {
									Object value = values[index];
									query.setParameter(index, value);
								}
			                }
							query.executeUpdate();
						} catch (HibernateException e) {
							e.printStackTrace();
							log.error("批量执行hql出错:" + e);
							throw new DAOException("批量执行hql出错:"
											+ e.getMessage());
						} catch (DataAccessException e) {
							e.printStackTrace();
							log.error("批量执行hql出错:" + e);
							throw new DAOException(e);
						} catch (Throwable e) {
							e.printStackTrace();
							log.error("系统错误:" + e);
							throw new DAOException(e);
						}
						return null;
					}
				},true);	
    }    
}