devbox
凡人多烦事01
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Hibernate Criteria查询之多表连接分页-2【分页封装】_hibernate 多表查询分页

作者：凡人多烦事01 | 2024-05-03 09:54:31

赞

踩

hibernate 多表查询分页

分页相关实体类：

分页信息类：

  1. package org.accp.mhouse.pager;
  2.  
  3. import java.io.Serializable;
  4. import java.util.List;
  5.  
  6. /**分页信息类
  7.  * 封装分页条件和结果
  8.  * */
  9. public class PageInfo<T> implements Serializable {
  10. 	
  11. 	/**
  12. 	 * 
  13. 	 */
  14. 	private static final long serialVersionUID = -4026351129192551762L;
  15.  
  16.  
  17. 	/*条件部分*/
  18. 	private Class<T> classzz;
  19. 	
  20.  
  21. 	private int pageSize = 10;
  22. 	private int pageIndex = 1;
  23. 	
  24. 	private java.util.List<Condition> conditions = new java.util.ArrayList<Condition>();
  25. 	private java.util.List<Order> orders = new java.util.ArrayList<Order>();
  26. 	private java.util.List<Fetch> fetchs = new java.util.ArrayList<Fetch>();
  27. 	
  28. 	public java.util.List<Fetch> getFetchs() {
  29. 		return fetchs;
  30. 	}
  31. 	public void setFetchs(java.util.List<Fetch> fetchs) {
  32. 		this.fetchs = fetchs;
  33. 	}
  34. 	
  35. 	
  36. 	/*分页结果部分*/
  37. 	private int recordCount;
  38. 	private int pageCount;
  39. 	private java.util.List<T> result;
  40. 	public Class<T> getClasszz() {
  41. 		return classzz;
  42. 	}
  43. 	public void setClasszz(Class<T> classzz) {
  44. 		this.classzz = classzz;
  45. 	}
  46. 	public int getPageSize() {
  47. 		return pageSize;
  48. 	}
  49. 	public void setPageSize(int pageSize) {
  50. 		this.pageSize = pageSize;
  51. 	}
  52. 	public int getPageIndex() {
  53. 		return pageIndex;
  54. 	}
  55. 	public void setPageIndex(int pageIndex) {
  56. 		this.pageIndex = pageIndex;
  57. 	}
  58. 	public java.util.List<Condition> getConditions() {
  59. 		return conditions;
  60. 	}
  61. 	public void setConditions(java.util.List<Condition> conditions) {
  62. 		this.conditions = conditions;
  63. 	}
  64. 	public java.util.List<Order> getOrders() {
  65. 		return orders;
  66. 	}
  67. 	public void setOrders(java.util.List<Order> orders) {
  68. 		this.orders = orders;
  69. 	}
  70. 	public int getRecordCount() {
  71. 		return recordCount;
  72. 	}
  73. 	public void setRecordCount(int recordCount) {
  74. 		this.recordCount = recordCount;
  75. 	}
  76. 	public int getPageCount() {
  77. 		return pageCount;
  78. 	}
  79. 	public void setPageCount(int pageCount) {
  80. 		this.pageCount = pageCount;
  81. 	}
  82. 	public java.util.List<T> getResult() {
  83. 		return result;
  84. 	}
  85. 	public void setResult(java.util.List<T> result) {
  86. 		this.result = result;
  87. 	}
  88. 	public PageInfo(Class<T> classzz, int pageSize, int pageIndex,
  89. 			List<Condition> conditions, List<Order> orders) {
  90. 		super();
  91. 		this.classzz = classzz;
  92. 		this.pageSize = pageSize;
  93. 		this.pageIndex = pageIndex;
  94. 		this.conditions = conditions;
  95. 		this.orders = orders;
  96. 	}
  97. 	public PageInfo(Class<T> classzz) {
  98. 		super();
  99. 		this.classzz = classzz;
  100. 	}
  101. 	
  102. 	
  103. 	
  104. 	
  105.  
  106. }


分页信息类中涉及的其它类：

筛选条件类：

  1. package org.accp.mhouse.pager;
  2.  
  3. import java.io.Serializable;
  4.  
  5. /**筛选条件类*/
  6. public class Condition implements Serializable {
  7. 	
  8. 	private String propertyName;
  9. 	
  10. 	private Compare cp = Compare.EQ;
  11. 	
  12. 	private Object propertyValue;
  13.  
  14. 	public String getPropertyName() {
  15. 		return propertyName;
  16. 	}
  17.  
  18. 	public void setPropertyName(String propertyName) {
  19. 		this.propertyName = propertyName;
  20. 	}
  21.  
  22. 	public Compare getCp() {
  23. 		return cp;
  24. 	}
  25.  
  26. 	public void setCp(Compare cp) {
  27. 		this.cp = cp;
  28. 	}
  29.  
  30. 	public Object getPropertyValue() {
  31. 		return propertyValue;
  32. 	}
  33.  
  34. 	public void setPropertyValue(Object propertyValue) {
  35. 		this.propertyValue = propertyValue;
  36. 	}
  37.  
  38. 	public Condition(String propertyName, Compare cp, Object propertyValue) {
  39. 		super();
  40. 		this.propertyName = propertyName;
  41. 		this.cp = cp;
  42. 		this.propertyValue = propertyValue;
  43. 	}
  44.  
  45. 	public Condition() {
  46. 		super();
  47. 	}
  48. 	
  49. 	
  50.  
  51. }


多表连接抓取策略类：

  1. package org.accp.mhouse.pager;
  2.  
  3. import java.io.Serializable;
  4.  
  5. /**多表连接抓取策略类*/
  6. public class Fetch implements Serializable {
  7. 	
  8. 	/**属性名*/
  9. 	private String fetchPropertyName;
  10. 	/**别名*/
  11. 	private String aliasName;
  12. 	/**抓取方式*/
  13. 	private FetchMode fetchMode = FetchMode.INNER_JOIN;
  14. 	
  15. 	public FetchMode getFetchMode() {
  16. 		return fetchMode;
  17. 	}
  18. 	public void setFetchMode(FetchMode fetchMode) {
  19. 		this.fetchMode = fetchMode;
  20. 	}
  21. 	public String getFetchPropertyName() {
  22. 		return fetchPropertyName;
  23. 	}
  24. 	public void setFetchPropertyName(String fetchPropertyName) {
  25. 		this.fetchPropertyName = fetchPropertyName;
  26. 	}
  27. 	public String getAliasName() {
  28. 		return aliasName;
  29. 	}
  30. 	public void setAliasName(String aliasName) {
  31. 		this.aliasName = aliasName;
  32. 	}
  33. 	public Fetch(String fetchPropertyName, String aliasName) {
  34. 		super();
  35. 		this.fetchPropertyName = fetchPropertyName;
  36. 		this.aliasName = aliasName;
  37. 	}
  38. 	public Fetch() {
  39. 		super();
  40. 	}
  41. 	public Fetch(String fetchPropertyName, String aliasName, FetchMode fetchMode) {
  42. 		super();
  43. 		this.fetchPropertyName = fetchPropertyName;
  44. 		this.aliasName = aliasName;
  45. 		this.fetchMode = fetchMode;
  46. 	}
  47. 	
  48. 	
  49. 	
  50. 	
  51.  
  52. }


排序类：

  1. package org.accp.mhouse.pager;
  2.  
  3. import java.io.Serializable;
  4.  
  5. /**排序*/
  6. public class Order implements Serializable {
  7. 	
  8. 	private String propertyName;
  9. 	private Direct direct = Direct.ASC;
  10. 	
  11. 	public String getPropertyName() {
  12. 		return propertyName;
  13. 	}
  14. 	public void setPropertyName(String propertyName) {
  15. 		this.propertyName = propertyName;
  16. 	}
  17. 	public Direct getDirect() {
  18. 		return direct;
  19. 	}
  20. 	public void setDirect(Direct direct) {
  21. 		this.direct = direct;
  22. 	}
  23. 	public Order(String propertyName, Direct direct) {
  24. 		super();
  25. 		this.propertyName = propertyName;
  26. 		this.direct = direct;
  27. 	}
  28. 	public Order() {
  29. 		super();
  30. 	}
  31. 	public Order(String propertyName) {
  32. 		super();
  33. 		this.propertyName = propertyName;
  34. 	}
  35. 	
  36. 	
  37. 	
  38. 	
  39.  
  40. }


以上类中用到的一些枚举类型：

条件比较操作枚举：

  1. package org.accp.mhouse.pager;
  2.  
  3. /**条件比较操作符【时间关系没有封装完】*/
  4. public enum Compare {
  5. 	
  6. 	EQ,
  7. 	GT,
  8. 	LT,
  9. 	GE,
  10. 	LE,
  11. 	NE,
  12. 	LIKE
  13.  
  14. }


排序方式：

  1. package org.accp.mhouse.pager;
  2.  
  3. /**排序方式*/
  4. public enum Direct {
  5. 	
  6. 	ASC,
  7. 	DESC
  8.  
  9. }


抓取模式枚举：

  1. package org.accp.mhouse.pager;
  2.  
  3. /**抓取模式*/
  4. public enum FetchMode {
  5. 	
  6. 	/**内连接*/
  7. 	INNER_JOIN,
  8. 	/**左外连接*/
  9. 	LEFT_JOIN
  10.  
  11. }


分页重点实现代码：

  1. package org.accp.mhouse.dao.hbimpl;
  2.  
  3. import java.io.Serializable;
  4. import java.util.List;
  5.  
  6. import org.accp.mhouse.dao.HibernateSessionFactory;
  7. import org.accp.mhouse.dao.IHibernateCallback;
  8. import org.accp.mhouse.pager.Condition;
  9. import org.accp.mhouse.pager.Direct;
  10. import org.accp.mhouse.pager.Fetch;
  11. import org.accp.mhouse.pager.Order;
  12. import org.accp.mhouse.pager.PageInfo;
  13. import org.hibernate.Criteria;
  14. import org.hibernate.FetchMode;
  15. import org.hibernate.Session;
  16. import org.hibernate.Transaction;
  17. import org.hibernate.criterion.CriteriaSpecification;
  18. import org.hibernate.criterion.MatchMode;
  19. import org.hibernate.criterion.Projection;
  20. import org.hibernate.criterion.ProjectionList;
  21. import org.hibernate.criterion.Projections;
  22. import org.hibernate.criterion.Restrictions;
  23. import org.hibernate.transform.ResultTransformer;
  24.  
  25. @SuppressWarnings("unchecked")
  26. public class CommonDao<T extends Serializable> {
  27. 	
  28. 	private Class<T> classzz;
  29. 	
  30. 	public CommonDao() {
  31. 		// TODO Auto-generated constructor stub
  32. 	}
  33. 	
  34. 	public CommonDao(Class<T> classzz) {
  35. 		// TODO Auto-generated constructor stub
  36. 		this.classzz = classzz;
  37. 	}
  38. 	
  39. 	/**分页方法*/
  40. 	public void pager(final PageInfo pi){
  41. 		if (pi==null || pi.getClasszz()==null){
  42. 			throw new RuntimeException("分页基本条件不全");
  43. 		}
  44. 		
  45. 		execute(new IHibernateCallback() {
  46. 			
  47. 			@Override
  48. 			public Object doInHibernate(Session session) {
  49. 				Criteria qbc = session.createCriteria(pi.getClasszz());
  50. 				
  51. 				//0.处理抓取策略
  52. 				prepareFetch(qbc,pi.getFetchs());
  53. 				
  54. 				//1.设置条件
  55. 				List<Condition> list = pi.getConditions();
  56. 				
  57. 				prepareCondition(qbc,list.toArray(new Condition[]{}));
  58. 				
  59. 				//2.计算总条数
  60. 				qbc.setProjection(Projections.rowCount());
  61. 				pi.setRecordCount(
  62. 						(Integer)qbc.uniqueResult()
  63. 				);
  64. 				//3.总页数
  65. 				pi.setPageCount(
  66. 						pi.getRecordCount()%pi.getPageSize()==0?
  67. 								pi.getRecordCount()/pi.getPageSize():
  68. 									pi.getRecordCount()/pi.getPageSize()+1
  69. 				);
  70. 				//4.清空投影查询的设置
  71. 				qbc.setProjection(null);
  72. 				qbc.setResultTransformer(CriteriaSpecification.DISTINCT_ROOT_ENTITY);
  73. 				//5.处理排序
  74. 				prepareOrder(qbc,((List<Order>)pi.getOrders()).toArray(new Order[]{}));			
  75.  
  76. 							
  77. 				//6.获得分页结果
  78. 				pi.setResult(
  79. 						qbc
  80. 							.setFirstResult((pi.getPageIndex()-1)*pi.getPageSize())
  81. 							.setMaxResults(pi.getPageSize())
  82. 							.list()
  83. 				);
  84. 				return null;
  85. 			}
  86. 		});		
  87. 	}
  88. 	
  89. 	/**处理分页条件*/
  90. 	private void prepareCondition(Criteria qbc,Condition...conditions){
  91. 		if (conditions==null || conditions.length==0)
  92. 			return;
  93. 		
  94. 		for (Condition cdt : conditions) {
  95. 			switch (cdt.getCp()) {
  96. 			case EQ:
  97. 				qbc.add(Restrictions.eq(cdt.getPropertyName(), cdt.getPropertyValue()));
  98. 				break;					
  99. 			case GT:
  100. 				qbc.add(Restrictions.gt(cdt.getPropertyName(), cdt.getPropertyValue()));
  101. 				break;					
  102. 			case LT:
  103. 				qbc.add(Restrictions.lt(cdt.getPropertyName(), cdt.getPropertyValue()));
  104. 				break;
  105. 			case GE:
  106. 				qbc.add(Restrictions.ge(cdt.getPropertyName(), cdt.getPropertyValue()));
  107. 				break;
  108. 			case LE:
  109. 				qbc.add(Restrictions.le(cdt.getPropertyName(), cdt.getPropertyValue()));
  110. 				break;
  111. 			case LIKE:
  112. 				qbc.add(Restrictions.like(cdt.getPropertyName(), cdt.getPropertyValue().toString(), MatchMode.ANYWHERE));
  113. 				break;
  114. 			default:
  115. 				break;
  116. 			}
  117. 		}
  118. 	}
  119. 	/**处理排序*/
  120. 	private void prepareOrder(Criteria qbc,Order...orders){
  121. 		
  122. 		if (orders==null || orders.length==0)
  123. 			return;
  124. 		
  125. 		for (Order ord : orders) {
  126. 			qbc.addOrder(
  127. 					ord.getDirect()==Direct.ASC?
  128. 							org.hibernate.criterion.Order.asc(ord.getPropertyName()):
  129. 								org.hibernate.criterion.Order.desc(ord.getPropertyName())
  130. 				);
  131. 		}
  132. 	}
  133. 	
  134. 	/**处理抓取策略*/
  135. 	private void prepareFetch(Criteria qbc,java.util.List<Fetch> fetchList){
  136. 		if (fetchList==null)
  137. 			return;
  138. 		for (Fetch fetch : fetchList) {
  139. 			if (null!=fetch.getAliasName() && !"".equals(fetch.getAliasName())){				
  140. 				qbc.createAlias(
  141. 						fetch.getFetchPropertyName(), 
  142. 						fetch.getAliasName(), 
  143. 						fetch.getFetchMode()==org.accp.mhouse.pager.FetchMode.INNER_JOIN?CriteriaSpecification.INNER_JOIN:CriteriaSpecification.LEFT_JOIN
  144. 				);				
  145. 			}
  146. 		}
  147. 	}
  148. 	
  149. 	/**通过回调执行任何Hibernate操作*/
  150. 	public Object execute(IHibernateCallback hibernateCallback){
  151. 		Session session = null;
  152. 		Transaction ts = null;
  153. 		Object result = null;
  154. 		try {
  155. 			session = HibernateSessionFactory.getSession();
  156. 			ts = session.beginTransaction();
  157. 			
  158. 			if (hibernateCallback!=null)
  159. 				result = hibernateCallback.doInHibernate(session);
  160. 			
  161. 			ts.commit();
  162. 		} catch(Exception e){
  163. 			ts.rollback();
  164. 			throw new RuntimeException(e.getMessage());
  165. 		} finally {
  166. 			if (session!=null) session.close();
  167. 		}
  168. 		
  169. 		return result;
  170. 	}
  171. 	
  172. 	/**多条件查询*/
  173. 	public List<T> findByProperties(Condition...conditions){
  174. 		if (conditions==null || conditions.length==0){
  175. 			return findAll();
  176. 		}
  177. 		
  178. 		Session session = null;
  179. 		try {
  180. 			session = HibernateSessionFactory.getSession();
  181. 			Criteria qbc = session.createCriteria(classzz);
  182. 			prepareCondition(qbc,conditions);
  183. 			return qbc.list();
  184. 		} catch (Exception e) {
  185. 			throw new RuntimeException(e.getMessage());
  186. 		} finally {
  187. 			if (session!=null) session.close();
  188. 		}
  189. 	}
  190. }


 测试代码：

  1. public static void main(String[] args) {
  2. 		
  3. 		CommonDao<House> cdao = new CommonDao<House>();
  4. 		PageInfo<House> pi = new PageInfo<House>(House.class);
  5. 		pi.getFetchs().add(new Fetch("street", "st"));
  6. 		pi.getFetchs().add(new Fetch("st.district","d"));
  7. 		pi.getFetchs().add(new Fetch("users","u"));
  8. 		pi.getFetchs().add(new Fetch("type","t"));
  9. 		pi.getConditions().add(new Condition("d.name", Compare.EQ, "青羊区"));
  10. 		pi.getOrders().add(new Order("id", Direct.ASC));
  11. 		
  12. 		cdao.pager(pi);
  13. 		
  14. 		System.out.printf("共%d条 %d页 当前第%d页\n",pi.getRecordCount(),pi.getPageCount(),pi.getPageIndex());
  15. 		for (House h : pi.getResult()) {
  16. 			System.out.println(h.getTitle()+"\t\t"+
  17. 					h.getStreet().getName()+"\t\t"+
  18. 					h.getStreet().getDistrict().getName()+"\t\t"+
  19. 					h.getUsers().getName()+"\t\t"+
  20. 					h.getType().getName()
  21. 			);
  22. 		}
  23. 	}


控制台输出:

  1. Hibernate: 
  2.     select
  3.         count(*) as y0_ 
  4.     from
  5.         house.house this_ 
  6.     inner join
  7.         house.street st1_ 
  8.             on this_.street_id=st1_.ID 
  9.     inner join
  10.         house.district d2_ 
  11.             on st1_.district_id=d2_.ID 
  12.     inner join
  13.         house.type t4_ 
  14.             on this_.type_id=t4_.ID 
  15.     inner join
  16.         house.users u3_ 
  17.             on this_.user_id=u3_.id 
  18.     where
  19.         d2_.name=?
  20. Hibernate: 
  21.     select
  22.         this_.ID as ID2_4_,
  23.         this_.contact as contact2_4_,
  24.         this_.description as descript3_2_4_,
  25.         this_.floorage as floorage2_4_,
  26.         this_.price as price2_4_,
  27.         this_.pubdate as pubdate2_4_,
  28.         this_.street_id as street8_2_4_,
  29.         this_.title as title2_4_,
  30.         this_.type_id as type9_2_4_,
  31.         this_.user_id as user10_2_4_,
  32.         st1_.ID as ID1_0_,
  33.         st1_.district_id as district3_1_0_,
  34.         st1_.name as name1_0_,
  35.         d2_.ID as ID4_1_,
  36.         d2_.name as name4_1_,
  37.         t4_.ID as ID3_2_,
  38.         t4_.name as name3_2_,
  39.         u3_.id as id0_3_,
  40.         u3_.idAdmin as idAdmin0_3_,
  41.         u3_.name as name0_3_,
  42.         u3_.password as password0_3_,
  43.         u3_.telephone as telephone0_3_,
  44.         u3_.userName as userName0_3_ 
  45.     from
  46.         house.house this_ 
  47.     inner join
  48.         house.street st1_ 
  49.             on this_.street_id=st1_.ID 
  50.     inner join
  51.         house.district d2_ 
  52.             on st1_.district_id=d2_.ID 
  53.     inner join
  54.         house.type t4_ 
  55.             on this_.type_id=t4_.ID 
  56.     inner join
  57.         house.users u3_ 
  58.             on this_.user_id=u3_.id 
  59.     where
  60.         d2_.name=? 
  61.     order by
  62.         this_.ID asc limit ?
  63. 共6条 1页 当前第1页
  64. 第一个房子  东南路  青羊区  admin  一室一厅
  65. 第七间房  东南路  青羊区  luo  两室一厅
  66. wrwegrhtrhgh  东南路  青羊区  admin  四室一厅
  67. gfdgggggggggggggg  东南路  青羊区  admin  两室一厅
  68. dfegggg  东南路  青羊区  admin  两室一厅
  69. rrrrr  知春路  青羊区  zhang  两室一厅
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/凡人多烦事01/article/detail/529029
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号