Java聚合查询skip丢失记录、order排序失效问题求助

核心问题 #

你的聚合管道顺序和字段引用存在两个关键错误，直接导致skip丢记录、排序失效：

• 排序阶段位置错误：把sort放在skip和limit之后，只会对分页截取后的小范围数据排序，而非对整个分组后的数据集做全局排序，自然得不到正确的排序结果；同时错误的顺序会让分页逻辑混乱，出现丢记录的情况。
• 字段引用错误：分组后原文档的salePrice字段被嵌套在data子文档中，直接用"salePrice"作为排序字段会找不到对应值。

修正后的代码 #

AggregateIterable<Document> propertiesDoc = collection.aggregate(Arrays.asList(
        Aggregates.match(queryNew),
        Aggregates.group("$similarGroup", 
                Accumulators.sum("count", 1),
                Accumulators.first("data", "$$ROOT")),
        Aggregates.sort(descending("data.salePrice")), // 先对全部分组结果做全局排序
        Aggregates.skip(skipCount), // 再跳过指定数量的记录
        Aggregates.limit(searchRequest.getItemsPerPage()) // 最后截取分页数据
));

关键修正说明 #

• 调整管道顺序：sort必须放在skip和limit之前，确保先完成全量数据的排序，再执行分页操作，这样分页结果连续且正确，不会出现丢记录的问题。
• 修改排序字段路径：使用"data.salePrice"引用嵌套在data子文档中的salePrice字段，让排序逻辑能正确定位目标字段。

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