225JSP采购管理系统

package com.oa.web; import java.io.Serializable; import java.sql.SQLException; import java.util.List; import org.hibernate.HibernateException; import org.hibernate.Query; import org.hibernate.Session; import org.springframework.orm.hibernate3.HibernateCallback; import org.springframework.orm.hibernate3.support.HibernateDaoSupport; public abstract class AbstractServices extends HibernateDaoSupport { public PageModel searchPaginated(String hql){ return searchPaginated(hql, null); } public PageModel searchPaginated(String hql,Object[] values){ return searchPaginated(hql, values, SystemContext.getOffset(), SystemContext.getPagesize()); } public PageModel searchPaginated(String hql,Object value,int offset,int pagesize){ return searchPaginated(hql, new Object[]{value}, offset, pagesize); } /** * * * 功能：公共分页1 * */ public List query(final String hql, final int currentpage, final int pageunit, final Object... Params) throws Exception { return (List) this.getHibernateTemplate().execute( new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException, SQLException { Query q = session.createQuery(hql); if (Params != null && Params.length > 0) { // 取出可变参数中设置的条件 int i = 0; for (Object obj : Params) { if (obj != null) { q.setString(i, obj.toString()); i++; } } } // q.setFirstResult((currentpage-1)*pageunit); //分页展现 // q.setMaxResults(pageunit); try { page(q, currentpage, pageunit); } catch (Exception e) { e.printStackTrace(); } List list = q.list(); return list; } }); } /** * * * 功能：公共分页2 * */ public Query page(final Query q, final int currentpage, final int pageunit) throws Exception { return (Query) this.getHibernateTemplate().execute( new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException, SQLException { q.setFirstResult((currentpage - 1) * pageunit); q.setMaxResults(pageunit); return q; } }); } public Object queryAggregation(final String hql, final Object... Params) throws Exception { return this.getHibernateTemplate().execute(new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException, SQLException { Query q = session.createQuery(hql); if (Params != null && Params.length > 0) { int i = 0; for (Object obj : Params) { if (obj != null) { q.setString(i, obj.toString()); i++; } } } return q.uniqueResult(); } }); } /** * 分页查询语句 * @param hql 查询的hql * @param values 参数数组 * @param offset 当前页 * @param pagesize 每页显示几条记录 * @return */ public PageModel searchPaginated(String hql,Object[] values,int offset,int pagesize){ //获得总记录数 String countHql = getCountQuery(hql); Query query=getQuery(countHql,values); int total = ((Long)query.uniqueResult()).intValue(); //获得当前页的数据 query =getQuery(hql,values); query.setFirstResult(offset); query.setMaxResults(pagesize); List datas = query.list(); PageModel pm = new PageModel(); pm.setList(datas); pm.setTotalRecords(total); pm.setPageNo(offset); pm.setPageSize(pagesize); return pm; } /** * 根据HQL语句，获得查询总记录数的HQL语句 * @param hql * @return */ private String getCountQuery(String hql){ int index = hql.indexOf("from"); if(index != -1){ return "select count(*) " + hql.substring(index); } throw new RuntimeException("无效的HQL查询语句【"+hql+"】"); } /** * 封装了返回为Query的方法 * @param hql * @return */ private Query getQuery(String hql,Object[] values){ Query query = this.getSession().createQuery(hql); if(values != null && values.length > 0){ for(int i=0; i<values.length; i++){ query.setParameter(i, values[i]); } } return query; } /** * 封装增加操作 */ public void save(Object o){ this.getSession().save(o); } /** * 封装删除操作 * @param clazz * 要删除的类 * @param objectId * 对象ID */ public void deleteById(Class clazz,int objectId){ Object o=this.getSession().get(clazz,objectId); delete(o); } public void delete(Object o){ this.getSession().delete(o); } /** * 封装删除操作 * @param o * 要删除的对象 */ public void update(Object o){ this.getSession().update(o); } public Object load(Class theClass,Serializable id){ return this.getSession().load(theClass, id); } /** * 带查询的不是分页语句 * @param hql * @param values * @return */ public List getResultList(String hql,Object[] values){ Query query=getQuery(hql,values); List ls=query.list(); return query.list(); } public List getResultList(String hql,Object value){ return getResultList(hql,new Object[]{value}); } public List getResultList(String hql){ return getResultList(hql,null); } public List getResultListSQL(String sql){ return this.getSession().createSQLQuery(sql).list(); } public Object getuniqueResult(String hql,Object[] values){ Query query=getQuery(hql,values); return query.uniqueResult(); } public Object getuniqueResult(String hql,Object value){ return getuniqueResult(hql,new Object[]{value}); } public Object getuniqueResult(String hql){ return getuniqueResult(hql,null); } }