Spring Data JPA中的动态查询实例

spring Data JPA大大的简化了我们持久层的开发，但是实际应用中，我们还是需要动态查询的。

比如，前端有多个条件，这些条件很多都是可选的，那么后端的SQL，就应该是可以定制的，在使用hibernate的时候，可以通过判断条件来拼接SQL(HQL)，当然，Spring Data JPA在简化我们开发的同时，也是提供了支持的。

通过实现Criteria二实现的动态查询，需要我们的Repo接口继承JpaSpecificationExecutor接口，这是个泛型接口。

然后查询的时候，传入动态查询参数，分页参数等即可。

使用起来很简单，不过为了知其所以然，先介绍一下Criteria API。

Criteria API

如果编译器能够对查询执行语法正确性检查，那么对于 Java 对象而言该查询就是类型安全的。Java™Persistence API (JPA) 的 2.0 版本引入了 Criteria API，这个 API 首次将类型安全查询引入到 Java 应用程序中，并为在运行时动态地构造查询提供一种机制。本文介绍如何使用 Criteria API 和与之密切相关的 Metamodel API 编写动态的类型安全查询。

在使用Spring Data JPA的时候，只要我们的Repo层继承JpaSpecificationExecutor接口就可以使用Specification进行动态查询了，我们先看下JpaSpecificationExecutor接口：

public interface JpaSpecificationExecutor<T> { 
 T findOne(Specification<T> spec); 
 List<T> findAll(Specification<T> spec); 
 Page<T> findAll(Specification<T> spec, Pageable pageable); 
 List<T> findAll(Specification<T> spec, Sort sort); 
 long count(Specification<T> spec); 
} 

可以看到提供了5个方法，方法的参数和返回值已经很明显的表达了其意图。其中的参数，Pageable和Sort应该是比较简单的，分别是分页参数和排序参数，而重点就是Specification参数，先看下这个接口的定义：

public interface Specification<T> { 
 Predicate toPredicate(Root<T> root, CriteriaQuery<?> query, CriteriaBuilder cb); 
} 

其中就一个方法，返回的是动态查询的数据结构。

javax.persistence.criteria.Predicate toPredicate(javax.persistence.criteria.Root<T> root,
javax.persistence.criteria.CriteriaQuery<?> query,
javax.persistence.criteria.CriteriaBuilder cb);

这里使用的都是Java EE中的规范，具体实现本人采用的是Hibernate，当然也可以选择其他实现了JPA规范的数据持久层框架。
这里需要再次回过头看看Criteria API中的一些东西：

Criteria 查询是以元模型的概念为基础的，元模型是为具体持久化单元的受管实体定义的，这些实体可以是实体类，嵌入类或者映射的父类。

CriteriaQuery接口：代表一个specific的顶层查询对象，它包含着查询的各个部分，比如：select 、from、where、group by、order by等注意：CriteriaQuery对象只对实体类型或嵌入式类型的Criteria查询起作用

Root接口：代表Criteria查询的根对象，Criteria查询的查询根定义了实体类型，能为将来导航获得想要的结果，它与SQL查询中的FROM子句类似

1：Root实例是类型化的，且定义了查询的FROM子句中能够出现的类型。

2：查询根实例能通过传入一个实体类型给 AbstractQuery.from方法获得。

3：Criteria查询，可以有多个查询根。

4：AbstractQuery是CriteriaQuery 接口的父类，它提供得到查询根的方法。CriteriaBuilder接口：用来构建CritiaQuery的构建器对象Predicate：一个简单或复杂的谓词类型，其实就相当于条件或者是条件组合

其中支持的方法非常之强大，下面给出一个示例，大家可以参考一下，同样的，可以根据示例，自己可以写出更为复杂的查询：

Repo接口：

public interface DevHREmpConstrastDao 
 extends JpaRepository<DevHREmpConstrast, Long>,JpaSpecificationExecutor<DevHREmpConstrast> 

查询实例1：

/** 
 * 条件查询时动态组装条件 
 */ 
private Specification<DevHREmpConstrast> where( 
  final String corg,final String name,final String type,final String date,final String checker){ 
 return new Specification<DevHREmpConstrast>() { 
  @Override 
  public Predicate toPredicate(Root<DevHREmpConstrast> root, CriteriaQuery<?> query, CriteriaBuilder cb) { 
   List<Predicate> predicates = new ArrayList<Predicate>(); 
   //机构 
   if(corg!=null&&!corg.equals("")){ 
    List<String> orgIds = organizationDao.findByName("%"+corg+"%"); 
    if(orgIds.size()>0&&orgIds.size()<1000) 
     predicates.add(root.<String>get("confirmOrgNo").in(orgIds));//confirmOrgNo 
   } 
   //名字 
   if(name!=null&&!name.equals("")){ 
    List<String> userIds = userDao.findByName(name); 
    if(userIds.size()>0&&userIds.size()<1000)//如果太多就不管了这个条件了 
     predicates.add(root.<String>get("hrUserName").in(userIds)); 
   } 
   //类型 
   if(type!=null&&!type.equals("")) 
    predicates.add(cb.equal(root.<String>get("hrUpdateType"),type)); 
   //日期 
   if(date!=null&&!date.equals("")){ 
    //处理时间 
    SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); 
    Date startDate; 
    Date endDate; 
    try { 
     startDate = format.parse(date); 
    } catch (ParseException e) { 
     startDate = new Date(946656000000L);//2000 01 01 
    } 
    endDate = startDate; 
    Calendar calendar = Calendar.getInstance() ; 
    calendar.setTime(endDate); 
    calendar.add(Calendar.DATE, 1); 
    endDate = calendar.getTime(); 
    calendar = null; 
    predicates.add(cb.between(root.<Date>get("insDate"),startDate,endDate)); 
   } 
   //审核人 
   if(checker!=null&&!checker.equals("")){ 
    List<String> userIds = userDao.findByName(checker); 
    if(userIds.size()>0&&userIds.size()<1000)//如果太多就不管了这个条件了 
     predicates.add(root.<String>get("confirmUserId").in(userIds)); 
   } 
   return query.where(predicates.toArray(new Predicate[predicates.size()])).getRestriction(); 
  } 
 }; 
} 

查询实例2：

/** 
 * 条件查询时动态组装条件 
 */ 
 private Specification<DevHREmpConstrast> where( 
   final String corg,final String name,final String type,final String date,final String checker){ 
  return new Specification<DevHREmpConstrast>() { 
   @Override 
   public Predicate toPredicate(Root<DevHREmpConstrast> root, CriteriaQuery<?> query, CriteriaBuilder cb) { 
    List<Predicate> predicates = new ArrayList<Predicate>(); 
    //机构 
    if(corg!=null&&!corg.equals("")){ 
     List<String> orgIds = organizationDao.findByName("%"+corg+"%"); 
     if(orgIds.size()>0&&orgIds.size()<1000) 
      predicates.add(root.<String>get("confirmOrgNo").in(orgIds));//confirmOrgNo 
    } 
    //名字 
    if(name!=null&&!name.equals("")){ 
     List<String> userIds = userDao.findByName(name); 
     if(userIds.size()>0&&userIds.size()<1000)//如果太多就不管了这个条件了 
      predicates.add(root.<String>get("hrUserName").in(userIds)); 
    } 
    //类型 
    if(type!=null&&!type.equals("")) 
     predicates.add(cb.equal(root.<String>get("hrUpdateType"),type)); 
    //日期 
    if(date!=null&&!date.equals("")){ 
     //处理时间 
     SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); 
     Date startDate; 
     Date endDate; 
     try { 
      startDate = format.parse(date); 
     } catch (ParseException e) { 
      startDate = new Date(946656000000L);//2000 01 01 
     } 
     endDate = startDate; 
     Calendar calendar = Calendar.getInstance() ; 
     calendar.setTime(endDate); 
     calendar.add(Calendar.DATE, 1); 
     endDate = calendar.getTime(); 
     calendar = null; 
     predicates.add(cb.between(root.<Date>get("insDate"),startDate,endDate)); 
    } 
    //审核人 
    if(checker!=null&&!checker.equals("")){ 
     List<String> userIds = userDao.findByName(checker); 
     if(userIds.size()>0&&userIds.size()<1000)//如果太多就不管了这个条件了 
      predicates.add(root.<String>get("confirmUserId").in(userIds)); 
    } 
    return query.where(predicates.toArray(new Predicate[predicates.size()])).getRestriction(); 
   } 
  }; 
 } 

然后调用dao层方法传入where()方法返回的参数即可。

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

# spring  # data  # jpa  # 动态  # 查询  # 动态查询  # Spring Data JPA实现动态查询的两种方法  # springdata jpa使用Example快速实现动态查询功能  # 详解Spring Data JPA动态条件查询的写法  # Spring JPA使用CriteriaBuilder动态构造查询方式  # 太多  # 就不  # 的是  # 都是  # 管了  # 子句  # 多个  # 分页  # 先看  # 应该是  # 首次  # 数据结构  # 可以通过  # 很简单  # 或者是  # 可以看到  # 可选  # 大大的  # 与之  # 可以选择 

相关文章： 建站主机服务器选型指南与性能优化方案解析  如何在IIS7中新建站点？详细步骤解析  建站主机系统SEO优化与智能配置核心关键词操作指南  如何用西部建站助手快速创建专业网站？  外汇网站制作流程,如何在工商银行网站上做外汇买卖？  娃派WAP自助建站：免费模板+移动优化，快速打造专业网站  企业微网站怎么做,公司网站和公众号有什么区别？  如何在IIS服务器上快速部署高效网站？  建站之星代理平台如何选择最佳方案？  如何快速查询域名建站关键信息？  建站之星上传入口如何快速找到？  如何通过主机屋免费建站教程十分钟搭建网站？  如何零成本快速生成个人自助网站？  网页制作模板网站推荐,网页设计海报之类的素材哪里好？  头像制作网站在线制作软件,dw网页背景图像怎么设置？  韩国服务器如何优化跨境访问实现高效连接？  如何在腾讯云服务器上快速搭建个人网站？  网站制作企业,网站的banner和导航栏是指什么？  电商网站制作价格怎么算,网上拍卖流程以及规则？  官网自助建站系统：SEO优化+多语言支持，快速搭建专业网站  免费视频制作网站,更新又快又好的免费电影网站？  python的本地网站制作,如何创建本地站点？  如何批量查询域名的建站时间记录？  制作营销网站公司,淘特是干什么用的？  如何获取开源自助建站系统免费下载链接？  网站制作需要会哪些技术,建立一个网站要花费多少？  如何通过二级域名建站提升品牌影响力？  长沙做网站要多少钱,长沙国安网络怎么样？  北京企业网站设计制作公司,北京铁路集团官方网站？  Swift中循环语句中的转移语句 break 和 continue  为什么Go需要go mod文件_Go go mod文件作用说明  惠州网站建设制作推广,惠州市华视达文化传媒有限公司怎么样？  如何用狗爹虚拟主机快速搭建网站？  如何在阿里云高效完成企业建站全流程？  微网站制作教程,不会写代码，不会编程，怎么样建自己的网站？  大连网站制作费用,大连新青年网站，五年四班里的视频怎样下载啊？  建站VPS能否同时实现高效与安全翻墙？  网站微信制作软件,如何制作微信链接？  jQuery 常见小例汇总  C++ static_cast和dynamic_cast区别_C++静态转换与动态类型安全转换  如何快速生成高效建站系统源代码？  Swift开发中switch语句值绑定模式  如何在建站宝盒中设置产品搜索功能？  如何在云服务器上快速搭建个人网站？  如何快速搭建二级域名独立网站？  教学网站制作软件,学习*后期制作的网站有哪些？  专业的网站制作设计是什么,如何制作一个企业网站，建设网站的基本步骤有哪些？  建站之星在线版空间：自助建站+智能模板一键生成方案  哪家制作企业网站好,开办像阿里巴巴那样的网络公司和网站要怎么做？  免费制作小说封面的网站有哪些,怎么接网站批量的封面单？