最新版struts-2.3.20+hibernate-4.3.8+spring-4.1.4集成

package cn.edu.cqut.bf.dao.impl; import java.io.Serializable; import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; import java.util.List; import org.hibernate.HibernateException; import org.hibernate.Query; import org.hibernate.SQLQuery; import org.hibernate.Session; import org.springframework.orm.hibernate4.HibernateCallback; import org.springframework.orm.hibernate4.support.HibernateDaoSupport; import cn.edu.cqut.bf.dao.IBaseDao; import cn.edu.cqut.bf.page.ObjectQuery; import cn.edu.cqut.bf.page.Pager; @SuppressWarnings({ "rawtypes", "unchecked" }) public abstract class BaseDaoImpl<T> extends HibernateDaoSupport implements IBaseDao<T> { private Class<T> entityClass; public BaseDaoImpl() { Class clazz = getClass(); Type type = clazz.getGenericSuperclass(); if (type instanceof ParameterizedType) { ParameterizedType pType = (ParameterizedType) type; entityClass = (Class<T>) pType.getActualTypeArguments()[0]; } } @Override public List<T> getAll() { return getHibernateTemplate().loadAll(entityClass); } @Override public T get(Serializable id) { return getHibernateTemplate().get(entityClass, id); } @Override public void save(T t) { getHibernateTemplate().save(t); } @Override public void update(T t) { getHibernateTemplate().update(t); } @Override public void delete(Serializable id) { // 容易出错的地方 // getHibernateTemplate().delete(id); T t = get(id); if (t == null) { throw new RuntimeException("找不到对应id=" + id + "的对象"); } getHibernateTemplate().delete(t); } @Override public List findByHql(String hql, Object... objects) { return getHibernateTemplate().find(hql, objects); } @Override public int getCount(final ObjectQuery query) { query.getWhere(); return getHibernateTemplate().execute(new HibernateCallback<Integer>() { @Override public Integer doInHibernate(Session session) throws HibernateException { final String hql = query.getHql(); Query q = session.createQuery("SELECT COUNT(o) FROM " + entityClass.getName() + " o where 1=1 " + hql); List params = query.getParams(); if (query != null && params.size() > 0) { int index = 0; for (int i = 0; i < params.size(); i++) { if (params.get(i) != null) { q.setParameter(index++, params.get(i)); } } } return ((Long) q.uniqueResult()).intValue(); } }); } @Override public Pager<T> findPager(final ObjectQuery query) { query.getWhere(); final Pager<T> pager = new Pager<T>(query.getPageNo(), query.getPageSize(), getCount(query)); List<T> rows = getHibernateTemplate().execute( new HibernateCallback<List<T>>() { @Override public List<T> doInHibernate(Session session) throws HibernateException { Query q = session.createQuery("SELECT o FROM " + entityClass.getName() + " o where 1=1 " + query.getHql() + " " + query.getOrder()); if (query.getParams().size() > 0) { int index = 0; for (int i = 0; i < query.getParams().size(); i++) { if (query.getParams().get(i) != null) { q.setParameter(index++, query.getParams() .get(i)); } } } // 从什么位置开始取数据 q.setFirstResult((pager.getPageNo() - 1) * pager.getPageSize()); // 取多少条记录数 q.setMaxResults(pager.getPageSize()); return q.list(); } }); pager.setRows(rows); return pager; } @Override public Pager<T> findPagerByHql(final int pageNo, final int pageSize, final String hql, final Object... objects) { // 编程式事务管理 int count = getHibernateTemplate().execute( new HibernateCallback<Integer>() { @Override public Integer doInHibernate(Session session) throws HibernateException { Query q = session.createQuery(hql); if (objects != null && objects.length > 0) { int index = 0; for (int i = 0; i < objects.length; i++) { if (objects[i] != null) { q.setParameter(index++, objects[i]); } } } return q.list().size(); } }); final Pager<T> pager = new Pager<T>(pageNo, pageSize, count); List<T> rows = getHibernateTemplate().execute( new HibernateCallback<List<T>>() { @Override public List<T> doInHibernate(Session session) throws HibernateException { Query q = session.createQuery(hql); if (objects != null && objects.length > 0) { int index = 0; for (int i = 0; i < objects.length; i++) { if (objects[i] != null) { q.setParameter(index++, objects[i]); } } } // 从什么位置开始取数据 q.setFirstResult((pager.getPageNo() - 1) * pager.getPageSize()); // 取多少条记录数 q.setMaxResults(pager.getPageSize()); return q.list(); } }); pager.setRows(rows); return pager; } @Override public List findByWhere(String hql, Object... objects) { return getHibernateTemplate().find(hql, objects); } public List findBySql(final String sql, final Object... objects) { return getHibernateTemplate().execute(new HibernateCallback() { public List doInHibernate(Session session) throws HibernateException { SQLQuery query = session.createSQLQuery(sql); for (int i = 0; i < objects.length; i++) { query.setParameter(i, objects[i]); } return query.list(); } }); } }