请求MongoDB聚合查询及对应Java代码：按指定字段查找seqNo=4的数组元素

MongoDB聚合查询语句 #

以下聚合管道会先筛选符合顶层字段条件的文档，再保留transactions数组中seqNo=4的元素：

db.collectionA.aggregate([
  // 第一步：筛选符合顶层字段要求且包含目标数组元素的文档
  {
    $match: {
      aC: "你的目标值",
      aI: "你的目标值",
      aN: "你的目标值",
      aT: "你的目标值",
      bID: "你的目标值",
      pD: "你的目标值",
      transactions: {
        $elemMatch: { seqNo: 4 }
      }
    }
  },
  // 第二步：过滤transactions数组，仅保留seqNo=4的元素
  {
    $addFields: {
      transactions: {
        $filter: {
          input: "$transactions",
          as: "tx",
          cond: { $eq: ["$$tx.seqNo", 4] }
        }
      }
    }
  }
])

Java代码实现（基于MongoDB Java驱动4.x+） #

import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.MongoCollection;
import org.bson.Document;
import static com.mongodb.client.model.Aggregates.*;
import static com.mongodb.client.model.Filters.*;
import java.util.Arrays;

public class MongoCollectionQuery {
    public static void main(String[] args) {
        // 建立MongoDB连接（自动关闭资源）
        try (MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017")) {
            MongoDatabase db = mongoClient.getDatabase("你的数据库名");
            MongoCollection<Document> collection = db.getCollection("collectionA");

            // 构造顶层字段的筛选条件
            Document matchConditions = new Document()
                    .append("aC", "你的目标值")
                    .append("aI", "你的目标值")
                    .append("aN", "你的目标值")
                    .append("aT", "你的目标值")
                    .append("bID", "你的目标值")
                    .append("pD", "你的目标值")
                    .append("transactions", elemMatch(eq("seqNo", 4)));

            // 构造数组过滤的表达式
            Document filterTxExpr = new Document("$filter", new Document()
                    .append("input", "$transactions")
                    .append("as", "tx")
                    .append("cond", new Document("$eq", Arrays.asList("$$tx.seqNo", 4))));

            // 执行聚合查询并遍历结果
            collection.aggregate(Arrays.asList(
                    match(matchConditions),
                    addFields(new Document("transactions", filterTxExpr))
            )).forEach(doc -> System.out.println(doc.toJson()));
        }
    }
}

详细说明 #

聚合管道逻辑 #

1. $match阶段
   • 同时完成两层筛选：匹配aC/aI/aN/aT/bID/pD的指定值，以及通过$elemMatch确保transactions数组中存在seqNo=4的元素，快速缩小结果集范围。
2. $addFields阶段
   • 使用$filter遍历数组，仅保留符合seqNo=4的元素。如果数组中有多个符合条件的元素，都会被保留；若只需单个元素，可搭配$arrayElemAt直接取出第一个匹配项。

Java代码关键点 #

• 采用try-with-resources模式自动管理MongoDB连接，避免资源泄漏；
• 用静态导入Aggregates和Filters类的方法，简化条件构造；
• 管道阶段与MongoDB原生查询一一对应，逻辑清晰易维护。

可选调整 #

• 若无需过滤数组内容，仅需确认文档存在目标元素，可直接去掉$addFields阶段；
• 如需分页，可在管道末尾添加$skip和$limit阶段；
• 若seqNo在数组中唯一，可将$addFields替换为取出单个元素的逻辑：

  {
    $addFields: {
      targetTx: {
        $arrayElemAt: [
          { $filter: { input: "$transactions", as: "tx", cond: { $eq: ["$$tx.seqNo", 4] } } },
          0
        ]
      }
    }
  }
  

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