溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

在spring中使用 data jpa實現(xiàn)分頁查詢功能

發(fā)布時間:2020-11-11 15:54:36 來源:億速云 閱讀:708 作者:Leah 欄目:編程語言

在spring中使用 data jpa實現(xiàn)分頁查詢功能?針對這個問題,這篇文章詳細介紹了相對應的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

最近項目上用就hibernate+spring data jpa,一開始感覺還不錯,但是隨著對業(yè)務的復雜,要求處理一些復雜的sql,就順便研究了下,把結果記錄下,以便日后查看。用到Specification,需要繼承JpaSpecificationExecutor接口。(下面代碼有的分頁從0開始作為第一頁,有的從1開始作為作為第一頁,我也忘記,請自己測試)

DAO層:

import java.util.List;  
import org.springframework.data.domain.Page; 
import org.springframework.data.domain.Pageable; 
import org.springframework.data.jpa.repository.JpaRepository; 
import org.springframework.data.jpa.repository.JpaSpecificationExecutor; 
import org.springframework.data.jpa.repository.Modifying; 
import org.springframework.data.jpa.repository.Query; 
import org.springframework.stereotype.Repository; 
 
 
@Repository 
public interface CameraInfoRepo extends JpaRepository<CameraInfoPO, String>, JpaSpecificationExecutor<CameraInfoPO> { 
   
  @Query("select c from CameraInfoPO c where c.deviceInfo.id = &#63;1") 
  public List<CameraInfoPO> findCamerasByDeviceId(String listDeviceInfoId); 
   
  //更新之后不清空緩存,在一個事務里查詢到舊數(shù)據(jù)(hibernate) 
  @Modifying 
  @Query(value = "update CameraInfoPO c set c.isEnabled = 1 where c.id = &#63;1") 
  public void updateEnabled(String cameraId); 
   
  //更新之后清空緩存,不保留舊對象(hibernate) 
  @Modifying(clearAutomatically = true) 
  @Query(value = "update CameraInfoPO c set c.isEnabled = 0 where c.id = &#63;1") 
  public void updateUnEnabled(String cameraId); 
   
  //帶條件的分頁查詢    
  public Page<CameraInfoPO> findByIsEnabled(Integer isEnabled, Pageable pageable); 
   
} 

DAO實現(xiàn)層

import java.util.ArrayList; 
import java.util.List; 
 
import javax.annotation.Resource; 
import javax.persistence.EntityManager; 
import javax.persistence.PersistenceContext; 
import javax.persistence.TypedQuery; 
import javax.persistence.criteria.CriteriaBuilder; 
import javax.persistence.criteria.CriteriaQuery; 
import javax.persistence.criteria.Predicate; 
import javax.persistence.criteria.Root; 
 
import org.springframework.data.domain.Page; 
import org.springframework.data.domain.PageImpl; 
import org.springframework.data.domain.Pageable; 
import org.springframework.data.jpa.domain.Specification; 
import org.springframework.stereotype.Repository; 
 
@Repository 
public class CameraInfoRepoImpl { 
   
  @PersistenceContext 
  private EntityManager em; 
   
  @Resource 
  private CameraInfoRepo cameraInfoRepo; 
   
  public Page<CameraInfoPO> findCameraInfoByPage(Pageable pageable, Integer isEnabled) { 
     
    //CriteriaBuilder,用來構建CritiaQuery的構建器對象 
    CriteriaBuilder criteriaBuilder = em.getCriteriaBuilder(); 
     
    //CriteriaQuery,它包含著查詢語句的條件各個部分,比如:select 、from、where、group by、order by等 
    CriteriaQuery<CameraInfoPO> criteriaQuery = criteriaBuilder.createQuery(CameraInfoPO.class); 
     
    //查詢根,用于獲取查詢實例的屬性,通過CriteriaQuery的from方法獲取 
    Root<CameraInfoPO> rootFrom = criteriaQuery.from(CameraInfoPO.class); 
     
    //查詢條件 
    List<Predicate> predicates = new ArrayList<Predicate>(); 
     
    if (null != isEnabled) { 
      Predicate predicate = criteriaBuilder.equal(rootFrom.get("isEnabled").as(Integer.class), isEnabled); 
      predicates.add(predicate); 
       
    } 
     
    //格式化參數(shù) 
    criteriaQuery.where(criteriaBuilder.and(predicates.toArray(new Predicate[predicates.size()]))); 
     
    //默認按照id排序(從小到大) 
    criteriaQuery.orderBy(criteriaBuilder.asc(rootFrom.get("id"))); 
     
    //SQL查詢對象 
    TypedQuery<CameraInfoPO> createQuery = em.createQuery(criteriaQuery); 
     
    //分頁參數(shù) 
    Integer pageSize = pageable.getPageSize(); 
    Integer pageNo = pageable.getPageNumber(); 
     
    //計數(shù)查詢結果條數(shù) 
    TypedQuery<CameraInfoPO> createCountQuery = em.createQuery(criteriaQuery); 
     
    // 實際查詢返回分頁對象 
    int startIndex = pageSize * pageNo; 
    createQuery.setFirstResult(startIndex); 
    createQuery.setMaxResults(pageable.getPageSize()); 
    Page<CameraInfoPO> pageRst = 
      new PageImpl<CameraInfoPO>(createQuery.getResultList(), pageable, createCountQuery.getResultList().size()); 
    return pageRst; 
     
  } 
   
  //制造查詢條件結果(建議存放map) 
  private Specification<CameraInfoPO> getWhereClause(final Integer isEnabled) { 
    return new Specification<CameraInfoPO>() { 
      public Predicate toPredicate(Root<CameraInfoPO> r, CriteriaQuery<&#63;> q, CriteriaBuilder cb) { 
        Predicate predicate = cb.conjunction(); 
        if (null != isEnabled) { 
           
          predicate = cb.equal(r.get("isEnabled").as(Integer.class), isEnabled); 
        } 
         
        return predicate; 
      } 
    }; 
  } 
   
  //單表根據(jù)查詢條件的分頁 
  public Page<CameraInfoPO> findCameraInfoByPageForJpa(Pageable pageable, Integer isEnabled) { 
     
    Specification<CameraInfoPO> spec = getWhereClause(isEnabled); 
     
    Page<CameraInfoPO> pageRst = cameraInfoRepo.findAll(spec, pageable); 
     
    return pageRst; 
     
  } 
   
} 

還有另外一種就更簡單了,如果只是根據(jù)表里面的一個或者幾個字段,可以直接寫jpa實現(xiàn),不用復雜

Pageable pageable = new PageRequest(1, 1); 
Page<CameraInfoPO> page = cameraInfoRepo.findByIsEnabled(1, pageable); 

關于在spring中使用 data jpa實現(xiàn)分頁查詢功能問題的解答就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關注億速云行業(yè)資訊頻道了解更多相關知識。

向AI問一下細節(jié)

免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內(nèi)容。

AI