Spring Data JPA中的动态查询实例

2024-02-26 09:17:03 160

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

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

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

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

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

CriteriaAPI

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

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

publicinterfaceJpaSpecificationExecutor{
TfindOne(Specificationspec);
ListfindAll(Specificationspec);
PagefindAll(Specificationspec,Pageablepageable);
ListfindAll(Specificationspec,Sortsort);
longcount(Specificationspec);
}

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

publicinterfaceSpecification{
PredicatetoPredicate(Rootroot,CriteriaQueryquery,CriteriaBuildercb);
}

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

javax.persistence.criteria.PredicatetoPredicate(javax.persistence.criteria.Rootroot,
javax.persistence.criteria.CriteriaQueryquery,
javax.persistence.criteria.CriteriaBuildercb);

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

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

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

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

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

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

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

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

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

Repo接口：

publicinterfaceDevHREmpConstrastDao
extendsJpaRepository,JpaSpecificationExecutor

查询实例1：

/**
*条件查询时动态组装条件
*/
privateSpecificationwhere(
finalStringcorg,finalStringname,finalStringtype,finalStringdate,finalStringchecker){
returnnewSpecification(){
@Override
publicPredicatetoPredicate(Rootroot,CriteriaQueryquery,CriteriaBuildercb){
Listpredicates=newArrayList();
//机构
if(corg!=null&&!corg.equals("")){
ListorgIds=organizationDao.findByName("%"+corg+"%");
if(orgIds.size()>0&&orgIds.size()<1000)
predicates.add(root.get("confirmOrgNo").in(orgIds));//confirmOrgNo
}
//名字
if(name!=null&&!name.equals("")){
ListuserIds=userDao.findByName(name);
if(userIds.size()>0&&userIds.size()<1000)//如果太多就不管了这个条件了
predicates.add(root.get("hrUserName").in(userIds));
}
//类型
if(type!=null&&!type.equals(""))
predicates.add(cb.equal(root.get("hrUpdateType"),type));
//日期
if(date!=null&&!date.equals("")){
//处理时间
SimpleDateFormatformat=newSimpleDateFormat("yyyy-MM-dd");
DatestartDate;
DateendDate;
try{
startDate=format.parse(date);
}catch(ParseExceptione){
startDate=newDate(946656000000L);//20000101
}
endDate=startDate;
Calendarcalendar=Calendar.getInstance();
calendar.setTime(endDate);
calendar.add(Calendar.DATE,1);
endDate=calendar.getTime();
calendar=null;
predicates.add(cb.between(root.get("insDate"),startDate,endDate));
}
//审核人
if(checker!=null&&!checker.equals("")){
ListuserIds=userDao.findByName(checker);
if(userIds.size()>0&&userIds.size()<1000)//如果太多就不管了这个条件了
predicates.add(root.get("confirmUserId").in(userIds));
}
returnquery.where(predicates.toArray(newPredicate[predicates.size()])).getRestriction();
}
};
}

查询实例2：

/**
*条件查询时动态组装条件
*/
privateSpecificationwhere(
finalStringcorg,finalStringname,finalStringtype,finalStringdate,finalStringchecker){
returnnewSpecification(){
@Override
publicPredicatetoPredicate(Rootroot,CriteriaQueryquery,CriteriaBuildercb){
Listpredicates=newArrayList();
//机构
if(corg!=null&&!corg.equals("")){
ListorgIds=organizationDao.findByName("%"+corg+"%");
if(orgIds.size()>0&&orgIds.size()<1000)
predicates.add(root.get("confirmOrgNo").in(orgIds));//confirmOrgNo
}
//名字
if(name!=null&&!name.equals("")){
ListuserIds=userDao.findByName(name);
if(userIds.size()>0&&userIds.size()<1000)//如果太多就不管了这个条件了
predicates.add(root.get("hrUserName").in(userIds));
}
//类型
if(type!=null&&!type.equals(""))
predicates.add(cb.equal(root.get("hrUpdateType"),type));
//日期
if(date!=null&&!date.equals("")){
//处理时间
SimpleDateFormatformat=newSimpleDateFormat("yyyy-MM-dd");
DatestartDate;
DateendDate;
try{
startDate=format.parse(date);
}catch(ParseExceptione){
startDate=newDate(946656000000L);//20000101
}
endDate=startDate;
Calendarcalendar=Calendar.getInstance();
calendar.setTime(endDate);
calendar.add(Calendar.DATE,1);
endDate=calendar.getTime();
calendar=null;
predicates.add(cb.between(root.get("insDate"),startDate,endDate));
}
//审核人
if(checker!=null&&!checker.equals("")){
ListuserIds=userDao.findByName(checker);
if(userIds.size()>0&&userIds.size()<1000)//如果太多就不管了这个条件了
predicates.add(root.get("confirmUserId").in(userIds));
}
returnquery.where(predicates.toArray(newPredicate[predicates.size()])).getRestriction();
}
};
}

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

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

Spring Data JPA中的动态查询实例

热门推荐

随机推荐