如何用Spring Data Specification+Criteria实现按标签排序的无重复产品查询

问题原因 #

你直接对@ElementCollection映射的tags字段排序时，JPA底层会自动左连接关联标签表，一条标签对应一行查询结果，所以多标签产品会出现重复条目，这是一对多关联排序的典型问题。

实现代码（基于Specification + Criteria） #

自定义Specification #

import org.springframework.data.jpa.domain.Specification;
import javax.persistence.criteria.*;

public class ProductSpec {
    public static Specification<Product> orderByAggregatedTags() {
        return (Root<Product> root, CriteriaQuery<?> query, CriteriaBuilder cb) -> {
            // 去重避免返回重复产品
            query.distinct(true);
            // 左连接关联标签集合
            ListJoin<Product, String> tagsJoin = root.joinList("tags", JoinType.LEFT);
            // 按产品ID分组，对应原生SQL的group by逻辑
            query.groupBy(root.get("parentID"));
            // 调用数据库聚合函数拼接标签，和原生SQL的string_agg逻辑一致
            Expression<String> tagsStr = cb.function(
                    "string_agg",
                    String.class,
                    tagsJoin,
                    cb.literal(",")
            );
            // 按拼接后的标签字符串升序排序
            query.orderBy(cb.asc(tagsStr));
            // 无额外过滤条件返回null
            return null;
        };
    }
}

调用方式 #

// 排序逻辑已封装在Specification中，不需要额外传Sort参数
Page<Product> result = productRepository.findAll(
        Specification.where(ProductSpec.orderByAggregatedTags())
                // 拼接其他业务过滤条件
                .and(yourCustomSpecification),
        PageRequest.of(pageNum, pageSize)
);

适配说明 #

• 如果你使用MySQL数据库，将函数名string_agg替换为group_concat即可，其余参数不需要修改
• 如果需要指定标签拼接时的排序规则，可按数据库语法调整function的入参，比如PostgreSQL下可以传入排序参数：cb.function("string_agg", String.class, tagsJoin, cb.literal(","), cb.asc(tagsJoin))
• 如果需要兼容多种数据库，可以通过JPA的方言配置做适配

内容的提问来源于stack exchange，提问作者amin.al