如何通过Spring Data聚合操作无循环获取MongoDB内嵌地址列表

没问题！我刚好做过类似的需求，不用手动循环客户列表，直接用Spring Data MongoDB的聚合管道就能一步到位拿到目标地址列表，下面是具体的实现方案和代码解析：

核心思路 #

通过MongoDB的聚合管道，依次完成数据筛选→客户过滤→数组拆分→地址提取这几个步骤，让数据库帮我们完成所有数组处理逻辑，不用在业务代码里做循环。

完整代码实现 #

首先确保你已经注入了MongoTemplate，然后编写以下聚合操作：

import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.*;
import org.springframework.data.mongodb.core.query.Criteria;
import java.util.List;

// 注入MongoTemplate
// @Autowired
// private MongoTemplate mongoTemplate;

public List<String> getAnnAddressesForChair() {
    // 1. 第一步：匹配产品名称为"CHAIR"的文档，缩小数据范围
    MatchOperation matchProduct = Aggregation.match(Criteria.where("productName").is("CHAIR"));

    // 2. 第二步：从customers数组中过滤出firstName为"Ann"的客户，存入新字段filteredCustomers
    AddFieldsOperation filterCustomers = Aggregation.addFields()
            .addFieldWithValue("filteredCustomers", AggregationExpression.from(MongoExpression.create(
                    "{ $filter: { input: '$customers', as: 'c', cond: { $eq: ['$$c.firstName', 'Ann'] } } }"
            )))
            .build();

    // 3. 第三步：展开筛选后的客户数组，将每个客户转为单独文档
    UnwindOperation unwindCustomers = Aggregation.unwind("filteredCustomers");

    // 4. 第四步：展开客户的地址数组，将每个地址转为单独文档
    UnwindOperation unwindAddresses = Aggregation.unwind("filteredCustomers.addresses");

    // 5. 第五步：只投影出地址字段，排除默认的_id
    ProjectionOperation projectAddress = Aggregation.project()
            .and("filteredCustomers.addresses.address").as("address")
            .andExclude("_id");

    // 组装聚合管道
    Aggregation aggregation = Aggregation.newAggregation(
            matchProduct,
            filterCustomers,
            unwindCustomers,
            unwindAddresses,
            projectAddress
    );

    // 执行聚合查询，直接得到地址字符串列表
    return mongoTemplate.aggregate(aggregation, Product.class, String.class).getMappedResults();
}

代码解析 #

• MatchOperation：先把查询范围缩小到产品名为"CHAIR"的文档，避免后续处理无关数据，提升查询效率。
• AddFieldsOperation：使用MongoDB的$filter操作符，精准筛选出customers数组中firstName等于"Ann"的客户，结果存入filteredCustomers字段，这样我们就只处理符合条件的客户了。
• UnwindOperation（两次）：第一次拆分客户数组，把每个符合条件的客户拆成独立文档；第二次拆分地址数组，把每个地址拆成独立文档，这一步是为了后续能直接提取单个地址。
• ProjectionOperation：只保留我们需要的address字段，排除不需要的_id，最终返回的就是纯地址字符串的列表。

注意事项 #

如果你的Spring Data MongoDB版本比较新，也可以用更简洁的lambda写法编写$filter表达式，但上面的写法兼容性更好，适配大多数版本。

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