MongoDB Java驱动中嵌入文档$or条件语法及子文档游标获取问题

首先得纠正你给出的示例文档格式——你写的结构有小问题，正确的嵌套数组文档应该是这样的（每个子文档是完整的键值对集合）：

{
  "statuses": [
    { "streamName": "A", "statusA": 0, "statusB": 1 },
    { "streamName": "B", "statusA": 0, "statusB": 1 }
  ]
}

一、$or条件查询的正确写法 #

你之前的代码无效，核心问题是没有正确定位数组中子文档的字段：你直接把statuses作为查询键，这相当于要求整个statuses数组完全等于你指定的子文档，而不是数组中存在某个子文档满足条件。

1. 匹配包含符合条件子文档的父文档 #

如果你的需求是找出所有statuses数组里至少有一个子文档满足statusA>0或statusB>0的父文档，正确的Java代码应该是这样的：

// 构造$or的两个条件
List<BasicDBObject> orConditions = new ArrayList<>();
// 匹配statuses数组中存在子文档的statusA大于0
orConditions.add(new BasicDBObject("statuses.statusA", new BasicDBObject("$gt", 0)));
// 匹配statuses数组中存在子文档的statusB大于0
orConditions.add(new BasicDBObject("statuses.statusB", new BasicDBObject("$gt", 0)));

// 组装完整查询条件
DBObject query = new BasicDBObject("$or", orConditions);

// 执行查询获取父文档游标
DBCursor parentDocCursor = db.getCollection(collectionName).find(query);

这里用**点符号statuses.statusA**来精准定位数组中子文档的字段，这是MongoDB查询嵌入文档的核心语法。

2. 直接获取符合条件的子文档 #

如果你的目标是直接拿到statuses数组里满足条件的子文档（而不是整个父文档），单纯的find查询有局限，分两种情况处理：

情况1：只需要数组中第一个匹配的子文档

用$elemMatch配合投影就能实现，它会返回数组里第一个符合条件的子文档：

// 先构造和之前一样的$or条件
List<BasicDBObject> orConditions = new ArrayList<>();
orConditions.add(new BasicDBObject("statuses.statusA", new BasicDBObject("$gt", 0)));
orConditions.add(new BasicDBObject("statuses.statusB", new BasicDBObject("$gt", 0)));
DBObject query = new BasicDBObject("$or", orConditions);

// 投影：只返回匹配的子文档，不返回_id
DBObject projection = new BasicDBObject("statuses", new BasicDBObject("$elemMatch", 
    new BasicDBObject("$or", orConditions)
));
projection.put("_id", 0);

// 执行查询
DBCursor cursor = db.getCollection(collectionName).find(query, projection);

情况2：需要数组中所有匹配的子文档

这种情况必须用聚合框架，通过$unwind展开数组，再$match过滤，最后提取需要的字段：

// 构造聚合管道步骤
List<DBObject> pipeline = new ArrayList<>();

// 第一步：把statuses数组展开，每个子文档变成独立的临时文档
pipeline.add(new BasicDBObject("$unwind", "$statuses"));

// 第二步：过滤出满足statusA>0或statusB>0的临时文档
List<BasicDBObject> matchConditions = new ArrayList<>();
matchConditions.add(new BasicDBObject("statuses.statusA", new BasicDBObject("$gt", 0)));
matchConditions.add(new BasicDBObject("statuses.statusB", new BasicDBObject("$gt", 0)));
pipeline.add(new BasicDBObject("$match", new BasicDBObject("$or", matchConditions)));

// 第三步：可选，只保留子文档的字段，去掉冗余内容
pipeline.add(new BasicDBObject("$project", new BasicDBObject() {{
    put("streamName", "$statuses.streamName");
    put("statusA", "$statuses.statusA");
    put("statusB", "$statuses.statusB");
    put("_id", 0);
}}));

// 执行聚合获取结果
AggregationOutput output = db.getCollection(collectionName).aggregate(pipeline);
// 遍历结果，这里的每个doc就是符合条件的子文档
for (DBObject subDoc : output.results()) {
    // 处理子文档逻辑
    System.out.println(subDoc);
}

二、关于嵌入文档的游标问题 #

当然可以获取嵌入文档的游标，分两种场景：

• 如果是想先拿到父文档游标，再从中提取子文档：直接遍历find返回的DBCursor，每个父文档的statuses字段是List<DBObject>类型，你可以逐个取出子文档处理。
• 如果是想直接拿到符合条件的子文档游标：用聚合框架的话，在MongoDB 3.x及以上的驱动中，MongoCollection.aggregate()会返回MongoCursor<Document>，完全可以像传统游标一样遍历操作；如果是旧版本驱动，AggregationOutput.results()是可迭代集合，也能实现类似游标的遍历效果。

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