Spring Data JPA使用Specification查询如何实现每个fooId仅返回1条结果

逐条查询属于典型的坏实践，不建议使用：

• 当入参fooIds数量较大时，会产生N次数据库查询请求，相比单次查询会大幅增加数据库连接开销、网络IO开销，性能下降明显
• 若fooIds规模达到几十上百级别，会直接拉高数据库QPS，容易引发生产环境性能瓶颈

你之前的Specification未实现去重，是因为没有在查询对象中配置去重/分组规则，同时原有代码中还存在笔误：idSpec中IN子句的取值用了未定义的clientPoses，应该替换为入参fooIds。

方案1：在Specification中配置分组/去重（推荐） #

直接在单次查询中完成去重逻辑，示例代码如下：

private Specification<Result> buildSpec(Set<UUID> fooIds, long olderThanMilis)
{
    Specification<Result> idSpec = (root, query, builder) -> {
        // 基础去重配置
        query.distinct(true);
        // 按fooId分组，保证每个fooId仅返回一条
        query.groupBy(root.get("fooId"));
        // 若要求返回每个fooId下最新的符合条件的记录，可补充having条件
        query.having(builder.equal(root.get("created"), builder.max(root.get("created"))));
        return root.get("fooId").in(fooIds);
    };
    Specification<Result> olderThanSpec = (root, query, builder) -> 
        builder.lessThanOrEqualTo(root.get("created"), olderThanMilis);

    return idSpec.and(olderThanSpec);
}

注意：如果你的数据库开启了ONLY_FULL_GROUP_BY配置，查询非分组/非聚合字段会报错，这种场景建议改用窗口函数ROW_NUMBER()实现，或者选择下面的内存去重方案。

方案2：单次查询后内存去重（适合数据量不大的场景） #

如果不想修改Specification，也可以单次查询所有符合条件的记录后，在内存中按fooId去重，性能远优于逐条查询：

List<Result> allResults = resultRepository.findAll(buildSpec(fooIds, olderThanMilis));
// 按fooId去重，冲突时取created时间最新的记录
List<Result> distinctResults = new ArrayList<>(allResults.stream()
    .sorted(Comparator.comparing(Result::getCreated).reversed())
    .collect(Collectors.toMap(
        Result::getFooId,
        Function.identity(),
        (oldVal, newVal) -> oldVal
    )).values());

• 如果fooIds的数量超过1000，部分数据库会对IN子句的参数数量有限制，可以拆分为多批查询，每批1000个id，性能依然远高于单条逐条查询
• 如果对返回的单条记录有明确的筛选规则（比如取最新、取最早），优先在数据库查询层面完成规则过滤，减少无效数据传输

内容的提问来源于stack exchange，提问作者petr