spring data jpa分页查询示例代码

 更新时间:2017年03月03日 15:35:56   作者:码农的天空  
本篇文章主要介绍了spring data jpa分页查询示例代码,分页在很多项目中都能使用,具有一定的参考价值,有兴趣的可以了解一下。

最近项目上用就hibernate+spring data jpa,一开始感觉还不错,但是随着对业务的复杂,要求处理一些复杂的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 = ?1") 
  public List<CameraInfoPO> findCamerasByDeviceId(String listDeviceInfoId); 
   
  //更新之后不清空缓存,在一个事务里查询到旧数据(hibernate) 
  @Modifying 
  @Query(value = "update CameraInfoPO c set c.isEnabled = 1 where c.id = ?1") 
  public void updateEnabled(String cameraId); 
   
  //更新之后清空缓存,不保留旧对象(hibernate) 
  @Modifying(clearAutomatically = true) 
  @Query(value = "update CameraInfoPO c set c.isEnabled = 0 where c.id = ?1") 
  public void updateUnEnabled(String cameraId); 
   
  //带条件的分页查询    
  public Page<CameraInfoPO> findByIsEnabled(Integer isEnabled, Pageable pageable); 
   
} 

DAO实现层

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); 
       
    } 
     
    //格式化参数 
    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); 
     
    //分页参数 
    Integer pageSize = pageable.getPageSize(); 
    Integer pageNo = pageable.getPageNumber(); 
     
    //计数查询结果条数 
    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<?> q, CriteriaBuilder cb) { 
        Predicate predicate = cb.conjunction(); 
        if (null != isEnabled) { 
           
          predicate = cb.equal(r.get("isEnabled").as(Integer.class), isEnabled); 
        } 
         
        return predicate; 
      } 
    }; 
  } 
   
  //单表根据查询条件的分页 
  public Page<CameraInfoPO> findCameraInfoByPageForJpa(Pageable pageable, Integer isEnabled) { 
     
    Specification<CameraInfoPO> spec = getWhereClause(isEnabled); 
     
    Page<CameraInfoPO> pageRst = cameraInfoRepo.findAll(spec, pageable); 
     
    return pageRst; 
     
  } 
   
} 

还有另外一种就更简单了,如果只是根据表里面的一个或者几个字段,可以直接写jpa实现,不用复杂

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

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • JAVA的反射机制你了解多少

    JAVA的反射机制你了解多少

    这篇文章主要为大家详细介绍了JAVA的反射机制,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下,希望能够给你带来帮助
    2022-02-02
  • spring data jpa查询一个实体类的部分属性方式

    spring data jpa查询一个实体类的部分属性方式

    这篇文章主要介绍了spring data jpa查询一个实体类的部分属性方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-02-02
  • Java中如何自定义一个类加载器

    Java中如何自定义一个类加载器

    这篇文章主要介绍了Java中如何自定义一个类加载器,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-11-11
  • Spring超详细讲解AOP面向切面

    Spring超详细讲解AOP面向切面

    面向对象编程是一种编程方式,此编程方式的落地需要使用“类”和 “对象”来实现,所以,面向对象编程其实就是对 “类”和“对象” 的使用,面向切面编程,简单的说,就是动态地将代码切入到类的指定方法、指定位置上的编程思想就是面向切面的编程
    2022-10-10
  • SpringBoot实现分库分表

    SpringBoot实现分库分表

    这篇文章主要介绍了SpringBoot实现分库分表,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-02-02
  • 关于mybatis3中几个@Provider的使用方式

    关于mybatis3中几个@Provider的使用方式

    这篇文章主要介绍了关于mybatis3中几个@Provider的使用方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-07-07
  • 探索分析Redis AOF日志与数据持久性

    探索分析Redis AOF日志与数据持久性

    这篇文章主要为大家介绍了探索分析Redis AOF日志与数据持久性详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-12-12
  • Java聊天室之解决连接超时问题

    Java聊天室之解决连接超时问题

    这篇文章主要为大家详细介绍了Java简易聊天室之解决连接超时问题的方法,文中的示例代码讲解详细,具有一定的借鉴价值,需要的可以了解一下
    2022-10-10
  • Java RandomAccessFile 指定位置实现文件读取与写入

    Java RandomAccessFile 指定位置实现文件读取与写入

    这篇文章主要介绍了Java RandomAccessFile 指定位置实现文件读取与写入的相关资料,需要的朋友可以参考下
    2017-01-01
  • SpringBoot访问请求404解决方法

    SpringBoot访问请求404解决方法

    这篇文章主要介绍了SpringBoot访问请求404解决方法,文中有详细的解决方法供大家参考,对我们学习或工作有一定的帮助,需要的朋友跟着小编一起来学习吧
    2023-07-07

最新评论