如何通过Java驱动批量执行MongoDB多字段distinct查询？

当然可以一次性批量获取多个字段的唯一值，不用反复调用distinct。核心方案是利用MongoDB的聚合框架，通过一次聚合查询完成多字段去重值的收集，减少网络往返次数，提升效率。

实现思路 #

1. 用$match阶段过滤符合条件的文档（对应你原来distinct里的query条件）；
2. 用$group阶段结合$addToSet操作符，一次性收集多个字段的唯一值；
3. 可选：用$project阶段优化返回结果的格式。

Java驱动代码示例 #

假设你已经初始化好MongoDatabase实例，且有现成的查询条件query，代码如下：

import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Aggregates;
import com.mongodb.client.model.Projections;
import com.mongodb.client.model.Accumulators;
import org.bson.Document;
import java.util.Arrays;
import java.util.List;

// 获取目标集合
MongoCollection<Document> storesCollection = mongoDatabase.getCollection("stores");

// 构建聚合管道
List<Document> pipeline = Arrays.asList(
    // 过滤符合条件的文档，和原distinct的query逻辑一致
    Aggregates.match(query),
    // 全局分组，收集多字段的唯一值
    Aggregates.group(
        null, // _id设为null表示不按字段分组，全局聚合
        Accumulators.addToSet("ownershipNames", "$ownership_name"),
        Accumulators.addToSet("statuses", "$status"),
        Accumulators.addToSet("entityNames", "$entity_name")
        // 可继续添加更多字段，格式为：Accumulators.addToSet("返回别名", "$字段名")
    ),
    // 移除默认的_id字段，让结果更简洁
    Aggregates.project(Projections.excludeId())
);

// 执行聚合查询
AggregateIterable<Document> aggregateResult = storesCollection.aggregate(pipeline);

// 提取结果
Document uniqueValues = aggregateResult.first();
if (uniqueValues != null) {
    List<String> ownershipNames = uniqueValues.getList("ownershipNames", String.class);
    List<String> statuses = uniqueValues.getList("statuses", String.class);
    List<String> entityNames = uniqueValues.getList("entityNames", String.class);
    // 后续处理这些唯一值列表
}

关键细节说明 #

• $addToSet：自动为指定字段收集唯一值，重复值会被自动忽略，最终返回的是无重复的数组；
• 全局分组：将$group的_id设为null，表示对所有符合$match条件的文档进行全局聚合，而不是按某个字段分组；
• 字段缺失处理：如果部分文档不存在目标字段，$addToSet会直接忽略这些文档。如果需要统一处理缺失值，可以结合$ifNull，例如：

  Accumulators.addToSet("ownershipNames", new Document("$ifNull", Arrays.asList("$ownership_name", "无数据")))
  

这种方式相比多次调用distinct，只需要一次网络请求，在数据量较大时性能优势明显。

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