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()方法返回的参数即可。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了Java mysql数据库并进行内容查询实例代码的相关资料,需要的朋友可以参考下2016-11-11
Java注解之Retention、Documented、Inherited介绍
这篇文章主要介绍了Java注解之Retention、Documented、Inherited注解介绍,本文内容和相关文章是系列文章,需要的朋友可以参考下2014-09-09
加权无向图是一种为每条边关联一个权重值或是成本的图模型。这种图能够自然地表示许多应用。这篇文章主要介绍了加权无向图的设计与实现，感兴趣的可以了解一下2022-11-11
Java8中List转Map(Collectors.toMap) 的技巧分享
在最近的工作开发之中,慢慢习惯了很多Java8中的Stream的用法,很方便而且也可以并行的去执行这个流,这篇文章主要给大家介绍了关于Java8中List转Map(Collectors.toMap) 的相关资料,需要的朋友可以参考下2021-07-07
这篇文章主要给大家介绍了关于Https协议和HttpClient实现的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2018-05-05
这篇文章主要介绍了JAVA ImageIO.read方法报错/无效问题及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-11-11
maven打包插件的使用(maven-compiler-plugin、maven-dependency-plugin、m
本文主要介绍了maven打包插件的使用(maven-compiler-plugin、maven-dependency-plugin、maven-jar-plugin、maven-resources-plugin)，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-06-06
详解mybatis中association和collection的column传入多个参数问题
这篇文章主要介绍了详解mybatis中association和collection的column传入多个参数问题，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-10-10
这篇文章主要介绍了史上最全的java随机数生成算法,我分享一个最全的随机数的生成算法,最代码的找回密码的随机数就是用的这个方法2014-01-01
Springboot中如何使用Redisson实现分布式锁浅析
redisson是redis的java客户端程序，国内外很多公司都有在用,下面这篇文章主要给大家介绍了关于Springboot中如何使用Redisson实现分布式锁的相关资料,需要的朋友可以参考下2021-10-10
最新评论