MongoDB如何从POJO文档中获取唯一marketId列表？

先针对你遇到的三个错误逐一说明原因，再给出对应解决方案：

错误原因解析 #

• distinct方法报错"CurrentBSONType is DOCUMENT..."：说明你查询的marketId字段并非单纯的字符串类型，要么是嵌套在文档里，要么存在于数组中，distinct默认无法直接处理这类非顶层单值字段。
• aggregate报错"Unrecognized pipeline stage name: 'marketId'"：属于聚合管道语法错误——你把字段名当成了管道阶段（比如错误地写了{ marketId: 1 }，而非$project/$group这类合法阶段）。
• 带group的aggregate返回空结果：大概率是marketId的字段路径写错了，或者字段存在于数组中但未先展开数组，导致$group阶段无法匹配到有效数据。

正确实现方案 #

根据你的POJO文档结构分三种常见情况处理：

情况1：marketId是顶层单值字段 #

如果你的POJO结构类似：

public class Trade {
    private String marketId;
    // 其他业务字段...
}

直接使用distinct方法，确保字段路径正确：

List<String> uniqueMarketIds = mongoCollection.distinct("marketId", String.class).into(new ArrayList<>());

若仍报错，检查POJO与MongoDB文档的映射是否正确，确认marketId在数据库中确实是字符串类型（而非嵌套文档）。

情况2：marketId存在于数组字段中 #

如果你的POJO包含数组嵌套，比如：

public class Trade {
    private List<MarketItem> markets;
    // 其他业务字段...
}

public class MarketItem {
    private String marketId;
    // 其他字段...
}

需要先展开数组，再分组去重，用聚合管道实现：

AggregateIterable<Document> aggResults = mongoCollection.aggregate(Arrays.asList(
    // 展开markets数组，将数组内每个元素转为独立文档
    Aggregates.unwind("$markets"),
    // 按marketId分组实现去重
    Aggregates.group("$markets.marketId"),
    // 重新投影字段，得到清晰的结构
    Aggregates.project(Projections.fields(
        Projections.excludeId(),
        Projections.computed("marketId", "$_id")
    ))
));

// 转换为目标列表
List<String> uniqueMarketIds = new ArrayList<>();
aggResults.forEach(doc -> uniqueMarketIds.add(doc.getString("marketId")));

情况3：marketId是嵌套文档中的字段 #

如果marketId嵌套在某个子文档里，比如：

public class Trade {
    private MarketDetail marketDetail;
    // 其他业务字段...
}

public class MarketDetail {
    private String marketId;
    // 其他字段...
}

使用distinct时指定完整字段路径：

List<String> uniqueMarketIds = mongoCollection.distinct("marketDetail.marketId", String.class).into(new ArrayList<>());

或者用聚合管道实现：

AggregateIterable<Document> aggResults = mongoCollection.aggregate(Arrays.asList(
    Aggregates.group("$marketDetail.marketId"),
    Aggregates.project(Projections.fields(
        Projections.excludeId(),
        Projections.computed("marketId", "$_id")
    ))
));

List<String> uniqueMarketIds = new ArrayList<>();
aggResults.forEach(doc -> uniqueMarketIds.add(doc.getString("marketId")));

验证技巧 #

可以先在MongoDB Compass中执行原生查询/聚合语句，确认结果正确后再转成Java代码：

• 对应distinct的原生语句：

db.yourCollection.distinct("markets.marketId")

• 对应数组展开聚合的原生语句：

db.yourCollection.aggregate([
    {$unwind: "$markets"},
    {$group: {_id: "$markets.marketId"}},
    {$project: {_id: 0, marketId: "$_id"}}
])

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