MongoDB Java驱动过滤文档内嵌数组对象失效问题求助

你的查询条件仅筛选出了包含目标子分类的父文档，但MongoDB默认会返回父文档的全部内容，包括subCategory数组里的所有元素。后续代码中用stream().findFirst()直接取数组第一个元素，自然得不到目标的子分类。

以下两种方式可以实现只返回匹配的子分类元素：

方法一：用投影配合$elemMatch #

通过投影指定仅返回subCategory数组中匹配条件的元素，这样父文档返回时，subCategory数组就只有符合条件的那一项。

修改后的查询逻辑：

@Override
public Mono<SubCategoryModel> find(String categoryId, String id) {
    // 筛选父文档的条件
    Bson query = and(eq("_id", new ObjectId(categoryId)), eq("subCategory._id", new ObjectId(id)));
    // 投影：只保留匹配的subCategory元素
    Bson projection = fields(elemMatch("subCategory", eq("_id", new ObjectId(id))));
    
    return Mono.from(iMongoRepository.getCollection(ConstantValues.PRODUCT_CATEGORY_COLLECTION_NAME, Category.class)
                    .find(query)
                    .projection(projection))
            .map(item -> {
                // 此时subCategory数组仅包含匹配的元素
                var element = item.getSubCategory().get(0);
                return new SubCategoryModel(element.get("_id").toString(), element.get("name").toString(), element.get("description").toString());
            });
}

方法二：用聚合管道 #

通过聚合操作更灵活地筛选提取目标子元素，适合复杂场景：

@Override
public Mono<SubCategoryModel> find(String categoryId, String id) {
    ObjectId categoryObjectId = new ObjectId(categoryId);
    ObjectId subCatObjectId = new ObjectId(id);
    
    AggregateIterable<Document> aggregate = iMongoRepository.getCollection(ConstantValues.PRODUCT_CATEGORY_COLLECTION_NAME, Document.class)
            .aggregate(Arrays.asList(
                    // 筛选目标父文档
                    match(eq("_id", categoryObjectId)),
                    // 过滤subCategory数组，仅保留匹配元素
                    addFields(new Field("subCategory", Filters.filter("subCategory", eq("_id", subCatObjectId)))),
                    // 展开数组（过滤后数组仅有一个元素，可选操作）
                    unwind("$subCategory"),
                    // 投影出需要的字段
                    project(fields(
                            include("subCategory._id", "subCategory.name", "subCategory.description"),
                            excludeId()
                    ))
            ));
    
    return Mono.from(aggregate)
            .map(doc -> {
                Document subCatDoc = doc.get("subCategory", Document.class);
                return new SubCategoryModel(
                        subCatDoc.get("_id").toString(),
                        subCatDoc.get("name").toString(),
                        subCatDoc.get("description").toString()
                );
            });
}

• $elemMatch投影会返回数组中第一个匹配条件的元素，适合你的场景（子分类_id唯一）。
• 聚合管道方式灵活性更高，若需处理多条件匹配、复杂数组过滤，优先选用。
• 建议在代码中添加空值判断，避免因subCategory数组为空出现IndexOutOfBoundsException或NoSuchElementException。

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