package com.anxin.dao.impl;

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

import org.hibernate.Query;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.anxin.dao.BaseDAO;
import com.anxin.util.PageListData;

public class BaseDAOImpl<T, PK extends Serializable> extends
		HibernateDaoSupport implements BaseDAO<T, PK> {

	static Logger logger = LoggerFactory.getLogger(BaseDAOImpl.class);

	// 保存
	public void save(T entity) {
		try {
			getHibernateTemplate().save(entity);
		} catch (RuntimeException re) {
			throw re;
		}
	}

	// 保存或者更新
	public void saveOrUpdate(T entity) {
		try {
			getHibernateTemplate().merge(entity);
		} catch (RuntimeException re) {
			throw re;
		}
	}

	// 删除
	public void delete(T entity) {
		try {
			getHibernateTemplate().delete(entity);
		} catch (RuntimeException re) {
			throw re;
		}
	}

	// 根据id删除某个对象
	public void deleteById(Class<T> entityClass, PK id) {
		try {
			getHibernateTemplate().delete(findById(entityClass, id));
		} catch (RuntimeException re) {
			throw re;
		}
	}

	// 根据id加载某个对象
	public T findById(Class<T> entityClass, PK id) {
		try {
			return (T) getHibernateTemplate().get(entityClass, id);
		} catch (RuntimeException re) {
			logger.error("findById " + entityClass.getName() + " failed :{}",
					re);
			throw re;
		}
	}

	// 查找所有的对象
	public List<T> findAll(Class<T> entityClass) {
		try {
			return getHibernateTemplate().loadAll(entityClass);
		} catch (RuntimeException re) {
			throw re;
		}
	}

	// 根据某个属性及其值精确或模糊查找对象
	public List<T> findByProperty(Class<T> entityClass, String propertyName,
			Object value, int type) {
		String queryString = "";
		try {
			if (type == 1) {// type=1是精确查找
				queryString = "from " + entityClass.getName()
						+ " as model where model." + propertyName + "= ?";
			} else if (type == 2) {// type=2是模糊查找
				queryString = "from " + entityClass.getName()
						+ " as model where model." + propertyName + "like ?";
			}
			return getHibernateTemplate().find(queryString, value);
		} catch (RuntimeException re) {
			throw re;
		}
	}

	// 根据hql语句及其查询参数，当前页数，每页显示的数目得到分页列表
	public PageListData findList(Class<T> entityClass, String hql,
			Object[] params, int currentPage, int pageSize) {
		PageListData listdata=null;
		try {
			Query query = getSession().createQuery(getCountsHql(hql));
			if (null != params && 0 != params.length) {
				for (int i = 0; i < params.length; i++) {
					query.setParameter(i, params[i]);
				}
			} else {
				logger.warn("参数为空");
			}
			int total = ((Long) query.uniqueResult()).intValue();
			logger.debug("总记录数:", total);
			query = getSession().createQuery(hql);
			if (null != params && 0 != params.length) {
				for (int i = 0; i < params.length; i++) {
					query.setParameter(i, params[i]);
				}
			}
			if (0 != pageSize) {
				query.setFirstResult(
						(currentPage == 0 ? 0 : currentPage - 1) * pageSize)
						.setMaxResults(pageSize);
			}
			List data = query.list();
			listdata=new PageListData(total,pageSize,currentPage,
					data);
		} catch (RuntimeException re) {
			throw re;
		}
		return listdata;
	}

	private String getCountsHql(String hql) {
		int index = hql.indexOf("from");
		if (index != -1) {
			return "select count(*) " + hql.substring(index);
		}
		throw new RuntimeException("sql语句异常" + hql);
	}
}