一.不帶有動態條件的查詢 分頁的實現

 例項程式碼：

controller：返回的是Page<>物件

1. @Controller
2. @RequestMapping(value = "/egg")  
3. publicclass EggController {  
4.  @ResponseBody
5.     @RequestMapping(value = "/statisticsList")  
6.     public Page<StatisticsDto> statisticsList(@RequestParam("actId") Long actId,HttpServletRequest request,  
7.                                               Pageable pageable){  
8.         Long entId = CasUtils.getEntId(request);  
9.         return eggService.findStatisticsWithPage(entId,actId,pageable) ;  
10.     }  
11. }  

                    Page 的實現類是PageImpl          Pageable 的實現類是PagerRequest

1. public Page<StatisticsDto> findStatisticsWithPage(Long entId, Long actId, Pageable pageable) {  
2.         int total = wactPlayRecordDao.findDistinctPlayRecordTotal(entId, actId);  
3. //        List<String> openIdList = wactPlayRecordDao.findDistinctPlayRecordList(entId, actId);
4.         List<WactPlayRecord> wactPlayRecordList = wactPlayRecordDao.findDistinctPlayRecordList(entId,actId);  
5.         List<StatisticsDto> statisticsDtoList = new ArrayList<>();  
6.         if (wactPlayRecordList.size()>0){  
7. //            statisticsDtoList = new ArrayList<>(wactPlayRecordList.size());
8.             for (WactPlayRecord wactPlayRecord:wactPlayRecordList){  
9.                 StatisticsDto statisticsDto = new StatisticsDto();  
10.                 String openid = wactPlayRecord.getOpenid();  
11.                 Long playRecordId = wactPlayRecord.getId();  
12.                 Mpuser mpuser = mpuserDao.findMpUserByOpenId(openid);  
13.                 List<CustomerCollItemInfo> customerCollItemInfoList = customerCollitemInfoDao.findCustomerCollItemInfoByOpenId(openid,entId,actId,playRecordId);  
14.                 List<CustCollItemsInfoDto> custCollItemsInfoDtoList = new ArrayList<>();  
15.                 if (customerCollItemInfoList.size()>0){  
16.                     statisticsDto.setDetailIsShow("able");  
17.                     custCollItemsInfoDtoList = new ArrayList<>(customerCollItemInfoList.size());  
18.                     for (CustomerCollItemInfo customerCollItemInfo:customerCollItemInfoList){  
19.                         CustCollItemsInfoDto custCollItemsInfoDto = new CustCollItemsInfoDto(customerCollItemInfo);  
20.                         custCollItemsInfoDtoList.add(custCollItemsInfoDto);  
21.                     }  
22.                 }else{  
23.                     //已中獎但是未填寫&&未中獎
24.                     statisticsDto.setDetailIsShow("unable");  
25.                 }  
26.                 if (wactPlayRecord.getIsWin()==0){  
27.                     wactPlayRecord.setIsUse(2);  
28.                 }  
29.                 WactPlayRecordDto wactPlayRecordDto = new WactPlayRecordDto(wactPlayRecord);  
30.                 MpuserDto mpuserDto = null;  
31.                 if (mpuser!= null){  
32.                     mpuserDto = new MpuserDto(mpuser);  
33.                 }  
34.                 statisticsDto.setWactPlayRecordDto(wactPlayRecordDto);  
35.                 statisticsDto.setCustCollItemsInfoDtoList(custCollItemsInfoDtoList);  
36.                 statisticsDto.setMpuserDto(mpuserDto);  
37.                 statisticsDtoList.add(statisticsDto);  
38.             }  
39.         }  
40.         returnnew PageImpl(statisticsDtoList,pageable,total);  
41.     }  

1. publicinterface WactPlayRecordDao extends JpaRepository<WactPlayRecord, Long>{  
2.  @Query("FROM WactPlayRecord w WHERE w.entId = :endId AND w.actId = :actId AND w.status = 1")  
3.     List<WactPlayRecord> findDistinctPlayRecordList(@Param("endId") Long endId,@Param("actId") Long actId);  
4. <pre name="code"class="java">@Query("SELECT count(w.openid) FROM WactPlayRecord w WHERE w.entId = :endId AND w.actId = :actId AND w.status = 1")  
5.     int findDistinctPlayRecordTotal(@Param("endId") Long endId,@Param("actId") Long actId);  

    方式1（使用與查詢條件在一個實體類中）.：

       controller：同樣是返回的Page<>物件 ，增加了表單提交的資料物件

1. @Controller
2. @RequestMapping("/news")  
3. publicclass NewsController {  
4.     private NewsService newsService;  
5.     private NewsCategoryService newsCategoryService;  

1. @RequestMapping("/list")  
2. @ResponseBody
3. public Page<NewsDto> list(Pageable pageable, NewsCondition newsCondition) {  
4.     Long id = AppUtils.getBean("loginInfo", LoginInfo.class).getEntId();  
5.     newsCondition.setEntId(id);  
6.     return newsService.find(newsCondition, pageable);  
7. }  

1. @Service
2. publicclass NewsServiceImpl implements NewsService {  
3. @Override
4.     @Transactional(readOnly = true)  
5.     public Page<NewsDto> find(final NewsCondition condition, Pageable pageable) {  
6.         Page<NewsEntity> page = newsDao.findAll(new Specification<NewsEntity>() {  
7.             @Override
8.             public Predicate toPredicate(Root<NewsEntity> root, CriteriaQuery<?> query, CriteriaBuilder cb) {  
9.                 List<Predicate> list = new ArrayList<>();  
10.                 list.add(cb.equal(root.get("entId").as(Long.class), condition.getEntId()));  
11.                 list.add(cb.equal(root.get("deleted").as(Boolean.class), false));  
12.                 Join<NewsEntity, NewsCategoryEntity> newsCategoryJoin = root.join("newsCategory");  
13.                 list.add(cb.equal(newsCategoryJoin.get("enable").as(Boolean.class), true));  
14.                 list.add(cb.equal(newsCategoryJoin.get("deleted").as(Boolean.class), false));  
15.                 if (condition.getCategoryId() != null) {  
16.                     list.add(cb.equal(newsCategoryJoin.get("id").as(Long.class), condition.getCategoryId()));  
17.                 }  
18.                 if (StringUtils.isNotBlank(condition.getTitle())) {  
19.                     list.add(cb.like(root.get("title").as(String.class), "%" + condition.getTitle() + "%"));  
20.                 }  
21.                 if (condition.getFromDate() != null) {  
22.                     list.add(cb.greaterThanOrEqualTo(root.get("createdDate").as(Date.class), DateUtils.getDateWithStartSecond(condition.getFromDate())));  
23.                 }  
24.                 if (condition.getToDate() != null) {  
25.                     list.add(cb.lessThanOrEqualTo(root.get("createdDate").as(Date.class), DateUtils.getDateWithLastSecond(condition.getToDate())));  
26.                 }  
27.                 query.orderBy(cb.desc(root.get("top")), cb.desc(root.get("id")));  
28.                 Predicate[] predicates = new Predicate[list.size()];  
29.                 predicates = list.toArray(predicates);  
30.                 return cb.and(predicates);  
31.             }  
32.         }, pageable);  
33.         if (page.hasContent()) {  
34.             List<NewsEntity> newsEntities = page.getContent();  
35.             List<NewsDto> newsDtos = new ArrayList<>(newsEntities.size());  
36.             List<Long> pids = new ArrayList<>();  
37.             for (NewsEntity newsEntity : newsEntities) {  
38.                 if (newsEntity.getTitleImage() != null) {  
39.                     pids.add(newsEntity.getTitleImage());  
40.                 }  
41.             }  
42.             Map<Long, MediaFileEntity> map = null;  
43.             if (CollectionUtils.isNotEmpty(pids)) {  
44.                 map = mediaFileDao.findWithMap(pids);  
45.             }  
46.             for (NewsEntity newsEntity : newsEntities) {  
47.                 newsDtos.add(new NewsDto(newsEntity, map != null ? map.get(newsEntity.getTitleImage()) : null));  
48.             }  
49.             returnnew PageImpl(newsDtos, pageable, page.getTotalElements());  
50.         }  
51.         returnnull;  
52.     }  
53. }  

dao:這裡一定要繼承JpasSpecificationExecutor,然後使用其中的findAll（）方法,其中封裝了分頁方法，排序方法等

1. publicinterface NewsDao extends JpaRepository<NewsEntity, Long>, JpaSpecificationExecutor<NewsEntity> {  
2.  }  

      controller

1. @Controller
2. @RequestMapping(value = "/egg")  
3. publicclass EggController {  
4.     @ResponseBody
5.     @RequestMapping(value = "/statisticsList")  
6.     public Page<StatisticsDto> statisticsList(@RequestParam("actId") Long actId,HttpServletRequest request,  
7.                                               Pageable pageable,StatisticsCondition statisticsCondition){  
8.         Long entId = CasUtils.getEntId(request);  
9.         return eggService.findStatisticsWithPage(entId,actId,pageable,statisticsCondition) ;  
10.     }  

1. @Override
2.     @Transactional
3.     public Page<StatisticsDto> findStatisticsWithPage(Long entId, Long actId, Pageable pageable, StatisticsCondition statisticsCondition) {  
4.         Long total = wactPlayRecordDao.findTotalByCondition(entId,actId,  
5.                 statisticsCondition.getParticipateBegin(),statisticsCondition.getParticipateEnd()  
6.                 ,statisticsCondition.getTelephone(),statisticsCondition.getIsWin(),statisticsCondition.getIsUse());  
7.         List<StatisticsDto> statisticsDtoList = new ArrayList<>();  
8.         if (total >0){  
9.             List<Object[]> objectList = wactPlayRecordDao.findStatisticsByConditionWithPage(entId,actId,  
10.                     statisticsCondition.getParticipateBegin(),statisticsCondition.getParticipateEnd()  
11.                     ,statisticsCondition.getTelephone(),statisticsCondition.getIsWin(),statisticsCondition.getIsUse(),pageable);  
12.             for (Object[] obj:objectList){  
13.                 StatisticsDto statisticsDto = new StatisticsDto();  
14.                 Long id = new BigInteger(obj[0].toString()).longValue();  
15.                 Integer isWin = new Short(obj[1].toString()).intValue();  
16.                 Integer isUse = new Short(obj[2].toString()).intValue();  
17.                 String createdDateStr = com.raipeng.micro.core.utils.DateUtils.format((Date)obj[4], com.raipeng.micro.core.utils.DateUtils.PATTERN_2);  
18.                 WactAwards wactAwards = new WactAwards();  
19.                 Long awardsId = new BigInteger(obj[5].toString()).longValue();  
20.                 if (awardsId != 0l){  
21.                     wactAwards = wactAwardsDao.findAwardByAwardId(awardsId);  
22.                 }  
23.                 if (isWin == 0){  
24.                     isUse = 2;  
25.                 }  
26.                 WactPlayRecordDto wactPlayRecordDto = new WactPlayRecordDto(id,isWin,isUse,(String)obj[3],wactAwards.getName(),wactAwards.getGradeName(),createdDateStr);  
27.                 String openid = (String)obj[3];  
28.                 Long playRecordId = wactPlayRecordDto.getId();  
29.                 List<CustomerCollItemInfo> customerCollItemInfoList = customerCollitemInfoDao.findCustomerCollItemInfoByPlayRecordId(playRecordId);  
30.                 List<CustCollItemsInfoDto> custCollItemsInfoDtoList = new ArrayList<>();  
31.                 if (customerCollItemInfoList.size()>0){  
32.                     statisticsDto.setDetailIsShow("able");  
33.                     custCollItemsInfoDtoList = new ArrayList<>(customerCollItemInfoList.size());  
34.                     for (CustomerCollItemInfo customerCollItemInfo:customerCollItemInfoList){  
35. //                        customerCollItemsIds +=customerCollItemInfo.getCustomerCollectitemsId()+"#";
36.                         CustCollItemsInfoDto custCollItemsInfoDto = new CustCollItemsInfoDto(customerCollItemInfo);  
37.                         custCollItemsInfoDtoList.add(custCollItemsInfoDto);  
38.                     }  
39.                 }else{  
40.                     //已中獎但是未填寫&&未中獎
41.                     statisticsDto.setDetailIsShow("unable");  
42.                 }  
43.                 Object[] object = wactPlayRecordDao.findUserInfoByOpenId(openid);  
44.                 MpuserDto mpuserDto = new MpuserDto();  
45.                 if (object[1] != null){  
46.                     mpuserDto.setHeadImg((String)object[1]);  
47.                 }elseif (object[3] != null){  
48.                     mpuserDto.setHeadImg((String)object[3]);  
49.                 }else {  
50.                     mpuserDto.setHeadImg("");  
51.                 }  
52.                 if (object[2] != null){  
53.                     mpuserDto.setNickName((String)object[2]);  
54.                 }elseif (object[4] != null){  
55.                     mpuserDto.setNickName((String)object[4]);  
56.                 }else {  
57.                     mpuserDto.setNickName("");  
58.                 }  
59.                 if (wactPlayRecordDto.getIsWin()=="已中獎" && custCollItemsInfoDtoList.size()==0){  
60.                     wactPlayRecordDto.setIsUse("");  
61.                 }  
62.                 if (mpuserDto.getHeadImg()==""){  
63.                     statisticsDto.setHeadImg("unable");  
64.                 }else{  
65.                     statisticsDto.setHeadImg("able");  
66.                 }  
67.                 if (wactPlayRecordDto.getIsUse()=="已領取"){  
68.                     statisticsDto.setHaveReceived("able");  
69.                 }else {  
70.                     statisticsDto.setHaveReceived("unable");  
71.                 }  
72.                 statisticsDto.setWactPlayRecordDto(wactPlayRecordDto);  
73.                 statisticsDto.setCustCollItemsInfoDtoList(custCollItemsInfoDtoList);  
74.                 statisticsDto.setMpuserDto(mpuserDto);  
75.                 if (wactPlayRecordDto.getIsUse()=="未領取"){  
76.                     statisticsDto.setSetReceive("able");  
77.                 }else {  
78.                     statisticsDto.setSetReceive("unable");  
79.                 }  
80.                 String customerCollItemsIds = "";  
81.                 List<CustomerCollectItems> customerCollectItemsList = customerCollectItemsDao.findListByActivityId(actId);  
82.                 if (customerCollectItemsList != null && customerCollectItemsList.size()>0){  
83.                     for (CustomerCollectItems customerCollectItems:customerCollectItemsList){  
84.                         customerCollItemsIds += customerCollectItems.getCollectItemsId()+"#";  
85.                     }  
86.                 }  
87.                 statisticsDto.setCustomerCollectItemsIds(customerCollItemsIds);  
88.                 statisticsDtoList.add(statisticsDto);  
89.             }  
90.         }  
91.         returnnew PageImpl<StatisticsDto>(statisticsDtoList,pageable,total);  
92.     }  

daoplus

1. publicinterface WactPlayRecordPlusDao {  
2.  Long findTotalByCondition(Long entId,Long actId,Date participateBegin,Date participateEnd,String telephone,Integer isWin,Integer isUse);  
3. List<Object[]> findStatisticsByConditionWithPage(Long entId, Long actId, Date participateBegin, Date participateEnd, String telephone, Integer isWin, Integer isUse,Pageable pageable);  
4. }  

1. publicclass WactPlayRecordDaoImpl implements WactPlayRecordPlusDao {  
2. @PersistenceContext
3.     private EntityManager entityManager;  
4.     publicvoid setEntityManager(EntityManager entityManager) {  
5.         this.entityManager = entityManager;  
6.     }  
7.     @Override
8.     public Long findTotalByCondition(Long entId, Long actId, Date participateBegin, Date participateEnd, String telephone, Integer isWin, Integer isUse) {  
9.         StringBuffer sql = null;  
10.         if (telephone != null && !"".equals(telephone)){  
11. //            hql = new StringBuffer("SELECT w.id,w.isWin,w.isUse,W.openid " +//表沒有關聯所以不能使用面向物件語句的left outer join inner join 等
12. //                    "FROM WactPlayRecord w inner join CustomerCollItemInfo c " +
13. //                    "ON w.id = c.playRecordId" +
14. //                    "WHERE w.entId = :entId AND w.actId = :actId AND w.status = 1 " +
15. //                    "AND c.entId = :entId AND c.actId = :actId AND c.status = 1 And c.val = :telephone ");
16.             sql =new StringBuffer("SELECT count(p.id)" +  
17.                     "FROM rp_act_play_record p inner join rp_act_customer_collitem_info c " +  
18.                     "ON p.id = c.play_record_id " +  
19.                     "WHERE p.ent_id = :entId AND p.act_id = :actId AND p.status = 1 " +  
20.                     "AND c.ent_id = :entId AND c.act_id = :actId AND c.status = 1 And c.val = :telephone ");  
21.         }else {  
22. //            hql = new StringBuffer("SELECT w.id,w.isWin,w.isUse,w.openid " +
23. //                    "FROM WactPlayRecord w " +
24. //                    "WHERE w.entId = :entId AND w.actId = :actId AND w.status = 1 " );
25.             sql = new StringBuffer("SELECT count(p.id) " +  
26.                     "FROM rp_act_play_record p " +  
27.                     "WHERE p.ent_id = :entId AND p.act_id = :actId AND p.status = 1 " );  
28.         }  
29.         if (participateBegin != null){  
30.             sql.append("AND p.created_date >= :participateBegin ");  
31.         }  
32.         if (participateEnd != null){  
33.             sql.append("AND p.created_date <= :participateEnd ");  
34.         }  
35.         if (isWin == 0){  
36.             sql.append("AND p.is_win = 0 ");  
37.         }elseif (isWin ==1){  
38.             sql.append("AND p.is_win = 1 ");  
39.         }  
40.         if (isUse == 0){  
41.             sql.append("AND p.is_use = 0 ");  
42.         }elseif (isUse == 1){  
43.             sql.append("AND p.is_use = 1 ");  
44.         }  
45.         sql.append("order by p.created_date ASC");  
46.         Query query = entityManager.createNativeQuery(sql.toString());  
47.         query.setParameter("entId", entId).setParameter("actId", actId);  
48.         if (participateBegin != null){  
49.             query.setParameter("participateBegin", participateBegin);  
50.         }  
51.         if (participateEnd != null){  
52.             query.setParameter("participateEnd", participateEnd);  
53.         }  
54.         if (telephone != null && !"".equals(telephone)){  
55.             query.setParameter("telephone",telephone);  
56.         }  
57.         Long total = new BigInteger(query.getSingleResult().toString()).longValue();  
58.         return total;  
59.     }  
60.     @Override
61.     public List<Object[]> findStatisticsByConditionWithPage(Long entId, Long actId, Date participateBegin, Date participateEnd, String telephone, Integer isWin, Integer isUse,Pageable pageable) {  
62.         StringBuffer sql = null;  
63.         if (telephone != null && !"".equals(telephone)){  
64. //            hql = new StringBuffer("SELECT w.id,w.isWin,w.isUse,W.openid " +
65. //                    "FROM WactPlayRecord w inner join CustomerCollItemInfo c " +
66. //                    "ON w.id = c.playRecordId" +
67. //                    "WHERE w.entId = :entId AND w.actId = :actId AND w.status = 1 " +
68. //                    "AND c.entId = :entId AND c.actId = :actId AND c.status = 1 And c.val = :telephone ");
69.            sql =new StringBuffer("SELECT p.id,p.is_win,p.is_use,p.openid,p.created_date,p.awards_id " +  
70.                     "FROM rp_act_play_record p inner join rp_act_customer_collitem_info c " +  
71.                     "ON p.id = c.play_record_id " +  
72.                     "WHERE p.ent_id = :entId AND p.act_id = :actId AND p.status = 1 " +  
73.                     "AND c.ent_id = :entId AND c.act_id = :actId AND c.status = 1 And c.val = :telephone ");  
74.         }else {  
75. //            hql = new StringBuffer("SELECT w.id,w.isWin,w.isUse,w.openid " +
76. //                    "FROM WactPlayRecord w " +
77. //                    "WHERE w.entId = :entId AND w.actId = :actId AND w.status = 1 " );
78.             sql = new StringBuffer("SELECT p.id,p.is_win,p.is_use,p.openid,p.created_date,p.awards_id " +  
79.                     "FROM rp_act_play_record p " +  
80.                     "WHERE p.ent_id = :entId AND p.act_id = :actId AND p.status = 1 " );  
81.         }  
82.         if (participateBegin != null){  
83.             sql.append("AND p.created_date >= :participateBegin ");  
84.         }  
85.         if (participateEnd != null){  
86.             sql.append("AND p.created_date <= :participateEnd ");  
87.         }  
88.         if (isWin == 0){  
89.             sql.append("AND p.is_win = 0 ");  
90.         }elseif (isWin ==1){  
91.             sql.append("AND p.is_win = 1 ");  
92.         }  
93.         if (isUse == 0){  
94.             sql.append("AND p.is_use = 0 ");  
95.         }elseif (isUse == 1){  
96.             sql.append("AND p.is_use = 1 ");  
97.         }  
98.         sql.append("order by p.created_date DESC");  
99.         Query query = entityManager.createNativeQuery(sql.toString());  
100.         query.setParameter("entId", entId).setParameter("actId", actId);  
101.         if (participateBegin != null){  
102.             query.setParameter("participateBegin", participateBegin);  
103.         }  
104.         if (participateEnd != null){  
105.             query.setParameter("participateEnd", participateEnd);  
106.         }  
107.         if (telephone != null && !"".equals(telephone)){  
108.             query.setParameter("telephone",telephone);  
109.         }  
110.         query.setFirstResult(pageable.getPageNumber() * pageable.getPageSize());  
111.         query.setMaxResults(pageable.getPageSize());  
112.         List<Object[]> objectList = query.getResultList();  
113.         return objectList;  
114.     }