SpringHibernate复杂查询分页

1、Spring Hibernate 复杂查询分页Spring+Hibernate 复杂查询分页/* 分页包装类很简单 :)*/package com.xing.cms.model.util;public class Pager private int totalPages = 0;private int totalObjects = 0;private int pageNumber = 1;private int pageSize = 3;private boolean pageAble = true;private int firstResult;public void calc()total

2、Pages = totalObjects % pageSize = 0 totalObjects/ pageSize : totalObjects / pageSize + 1;firstResult = (pageNumber - 1) * pageSize;public boolean isPageAble() return pageAble; public void setPageAble(boolean pageAble) this.pageAble = pageAble; public int getTotalObjects() return totalObjects; public

3、 void setTotalObjects(int param) this.totalObjects = param; public int getTotalPages() return totalPages; public void setTotalPages(int param) this.totalPages = param; public int getPageNumber() return pageNumber; public void setPageNumber(int pageNumber) this.pageNumber = pageNumber; public int get

4、PageSize() return pageSize; public void setPageSize(int pageSize) this.pageSize = pageSize;public String toString() return(ntotalPages: + totalPages + ntotalObjects: + totalObjects + npageNumber: + pageNumber + npageSize: + pageSize + npageAble: + pageAble + nfirstResult: + firstResult); public int

5、getFirstResult() return firstResult; public void setFirstResult(int firstResult) this.firstResult = firstResult;/*UserDao 接口 */package com.xing.cms.model.dao;import java.util.List;import com.xing.cms.model.businessobject.User;import com.xing.cms.model.util.Pager;public interface UserDao public abstr

6、act boolean save(User model);public abstract boolean update(User model); public abstract User get(int id);public abstract boolean delete(int id);public abstract void truncate();public abstract boolean delete(int id);public abstract List<User> find(String searchPara,Pager pager);public abstract

7、 List<User> find(String searchPara); /*UserDao 实现 */package com.xing.cms.model.dao.impl;import java.sql.SQLException;import java.util.List;import org.hibernate.Criteria;import org.hibernate.Hibernate;import org.hibernate.HibernateException;import org.hibernate.Query;import org.hibernate.Sessio

8、n;/import org.hibernate.criterion.Expression;import org.hibernate.criterion.Restrictions;import org.hibernate.criterion.MatchMode;import org.hibernate.criterion.Order;import org.hibernate.criterion.Projections;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.orm.hibernate

9、3.HibernateCallback;import org.springframework.orm.hibernate3.support.HibernateDa oSupport;import com.xing.cms.model.businessobject.User; import com.xing.cms.model.dao.UserDao; import com.xing.cms.model.util.GeneralTool;import com.xing.cms.model.util.Pager;public class UserDaoImpl extends HibernateD

10、aoSupport implements UserDao private JdbcTemplate jdbcTemplate;/ Spring Injection public UserDaoImpl() super(); public JdbcTemplate getJdbcTemplate() return jdbcTemplate; public void setJdbcTemplate(JdbcTemplate param) this.jdbcTemplate = param; SuppressWarnings(unchecked)public List<User> fin

11、d(final String searchPara, final Pager pager) return (List<User>) this.getHibernateTemplate().execute(new HibernateCallback() public Object doInHibernate(Session session) throws SQLException, HibernateException Criteria ca_count = null;if(pager.isPageAble()ca_count = session.createCriteria(Use

12、r.class);/不能避免 ,需要查询两次数据库 ,这个获取总数Criteria ca = session.createCriteria(User.class); if(searchPara != null)ca.setProjection(null);for (int i = 0; i < searchPara.length; i+) if(searchParai1.equalsIgnoreCase(=) if(pager.isPageAble() ca_count.add(Restrictions.eq(searchParai0, searchParai2);ca.add(Rest

13、rictions.eq(searchParai0, searchParai2); else if (searchParai1.equalsIgnoreCase(like)if(pager.isPageAble() ca_count.add(Restrictions.like(searchParai0, searchParai2,MatchMode.ANYWHERE);ca.add(Restrictions.like(searchParai0,searchParai2,MatchMode.ANYWHERE);List ret_list;if (pager.isPageAble() pager.s

14、etTotalObjects(Integer) (ca_count .setProjection(Projections.rowCount() .uniqueResult().intValue(); / 获取 Count pager.calc();ca.addOrder(Order.desc(UID); ca.setFirstResult(pager.getFirstResult(); ca.setMaxResults(pager.getPageSize(); ret_list = ca.list(); else ca.addOrder(Order.desc(UID); ret_list =

15、ca.list(); return ret_list; );/ 其它方法略去 /* 测试类 */package test; import mons.logging.Log;import mons.logging.LogFactory;importorg.springframework.test.AbstractTransactionalDataSourc eSpringContextTests;import com.xing.cms.model.businessobject.User;import com.xing.cms.model.dao.DocumentDao;import com.xi

16、ng.cms.model.dao.UserDao;import com.xing.cms.model.util.HtmlGenerator;import com.xing.cms.model.util.Pager;import com.xing.cms.model.util.UtilXml;import com.xing.cms.action.UserAction;public classTestSpring extendsAbstractTransactionalDataSourceSpringContextTestsprivate Log logger = LogFactory.getLo

17、g(TestSpring.class); public String getConfigLocations() String config = new StringapplicationContext.xml; return config; public void testUserAction() throws ExceptionUserDao dao =(UserDao)applicationContext.getBean(userDao);assertTrue(dao!=null);User user = (User)applicationContext.getBean(user);ass

18、ertTrue(user!=null);Pager pager =(Pager)applicationContext.getBean(pager); assertTrue(pager!=null);UserAction action =(UserAction)applicationContext.getBean(userAction);assertTrue(action!=null);/clear all first dao.truncate();/super.setComplete();/addfor(int i=0;i<20;i+)User u = new User(); u.setGID(1); u.setUsername(xzw_+i); u.setPassword(abcd); dao.save(u);/no pager/* assertEquals(0,dao.find(new Stringnew Stringusername,=,xzw).size();assertEquals(20,dao.find(null).size();*/with pager /action.getPager().setPageSize(9);/10 11 12 . 19 + 1 = 11/*分页，取第一页，前 4 条，应该返回 4*/action.g