栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

springboot整合jpa之Specification

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

springboot整合jpa之Specification

springboot整合jpa,sql查询

springboot整合jpa,查询sql的时候,可能会出现以下情况:

  1. sql条件无法在repository中进行多重执行(当其中一个条件为空的时候,必须新写一条sql)
  2. 时间范围查询的格式转换

最近在实际项目中遇到的情况,令人头大,于是,找到了提供的工具方法
比如我们的数据库设计为:(以Oracle为例)

id           主键
name         名称
score        分数
data         数据状态
createTime   创建时间

实体类
Score参数同上,不详细说了

实现要求:

  1. 按照name模糊查询,score精确查询,创建时间范围查询,数据状态类型查询
  2. 按照时间排序
  3. 分页

直接上代码:

//涉及部分包引入,其余包已经去除
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.Predicate;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.domain.Specification;

@Service
public class ScoreServiceImpl {
	@Autowired
 	private SocreRepository socreRepository;
 	
	//分页,以及排序方式
	//注意点:pageNo 是从0开始的,pageSize是当前页查询个数
	Pageable pageable = PageRequest.of(pageNo, pageSize, Sort.by(Sort.Direction.DESC, "createTime"));
	List dataList = Arrays.asList(dataTypes);
	Specification specification = (root, criteriaQuery, criteriaBuilder) -> {
        //增加筛选条件
        Predicate predicate = criteriaBuilder.conjunction();
        //name不为空
        if (StringUtils.isNotBlank(name)) {
            predicate.getexpressions().add(criteriaBuilder.like(root.get("name"), "%" + name+ "%"));
        }
        if (StringUtils.isNotBlank(score)) {
            predicate.getexpressions().add(criteriaBuilder.equal(root.get("score"), score));
        }
        //in集合查询
        if (!dataList.isEmpty()) {
            CriteriaBuilder.In in = criteriaBuilder.in(root.get("data"));
            for (Integer integer : dataList) {
                in.value(integer);
            }
            predicate.getexpressions().add(in);
        }
        //时间范围查询
        if (StringUtils.isNotBlank(createTime)) {
        	//例子时间格式 createTime=“2021-12-18 00:00:00,2021-12-30 23:59:59”
            String[] split = createTime.split(",");
            String createTimeStart = split[0];
            String createTimeEnd = split[1];
            LocalDateTime start = DateUtils.stringToLocalDate(createTimeStart);
            LocalDateTime end = DateUtils.stringToLocalDate(createTimeEnd);
            predicate.getexpressions().add(criteriaBuilder.between(root.get("createTime"), start, end));
    }
    return predicate;
    };
    Page all = socreRepository.findAll(specification, pageable);
}



public class DateUtils {
	
public static LocalDateTime stringToLocalDate(String date){
    try {
        return LocalDateTime.parse(date ,formatDateTimeLine);
    } catch (Exception e) {
        //异常操作,自定义即可
    }
}
}
 

Specification以上是简单的条件查询的实现功能了,最后根据返回的信息,选择你需要的数据信息即可;

注意:

  1. 注意点:pageNo 是从0开始的,pageSize是当前页查询个数
  2. root.get(“column”) 其中不是数据库字段,而是你映射实体类的字段,本例中也就是Score中的属性名字
  3. 时间格式转换,重要的是统一时间格式,本列子中的数据库时间是Date类型,数据库 映射类是LocalDateTime类型
转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号