Akeneo PIM中Doctrine MongoDB查询Builder投影与过滤问题

在Akeneo PIM中，由于values是数字索引的数组，普通的elemMatch只能返回数组中第一个匹配的元素，无法满足你需要保留所有符合条件属性的需求。这里推荐使用MongoDB的聚合管道来实现精准的数组筛选和投影，同时过滤掉没有目标属性的文档。

具体实现代码 #

// 创建聚合构建器
$aggregationBuilder = $productRepository->createAggregationBuilder();

// 构建聚合管道
$pipeline = $aggregationBuilder
    // 第一步：先匹配指定ID的产品，缩小处理范围
    ->match()
    ->field('_id')->in($entityIds)

    // 第二步：筛选values数组，仅保留符合attribute和locale条件的元素
    ->addFields()
    ->field('filteredValues')
    ->expression($aggregationBuilder->expr()->filter(
        'values', // 要筛选的数组字段名
        'value',  // 迭代变量名（可以自定义）
        // 筛选条件：attribute在目标列表 且 locale在指定语言列表
        $aggregationBuilder->expr()->andX(
            $aggregationBuilder->expr()->field('value.attribute')->in([117, 110]),
            $aggregationBuilder->expr()->field('value.locale')->in(['it_IT', 'de_DE'])
        )
    ))

    // 第三步：过滤掉筛选后没有匹配元素的产品（排除无目标属性的结果）
    ->match()
    ->field('filteredValues')->notEqual([])

    // 第四步：投影需要的字段，将筛选后的数组替换原values（或保留新字段）
    ->project()
    ->includeField('normalizedData.sku')
    ->field('values')->expression('$filteredValues')

    // 分页处理
    ->skip($offset)
    ->limit($limit)
    ->getPipeline();

// 执行聚合查询
$result = $productRepository->getDocumentManager()->getDocumentCollection()
    ->aggregate($pipeline);

关键步骤解释 #

1. 初始$match：先通过_id过滤目标产品，减少后续聚合处理的数据量，提升性能。
2. $filter筛选数组：使用MongoDB的$filter操作符遍历整个values数组，保留所有满足attribute在[117,110]且locale在指定语言列表的元素，这解决了普通elemMatch只能返回第一个匹配项的问题。
3. 二次$match：确保只保留筛选后有有效元素的产品，彻底排除不包含目标attribute的结果。
4. $project投影字段：按需选择需要返回的字段，这里将原values替换为筛选后的filteredValues，保持文档结构的一致性；你也可以直接保留filteredValues字段，根据业务需求调整。
5. 分页处理：通过skip和limit实现分页，和你原有的查询逻辑保持一致。

为什么之前的方法无效？ #

• selectElemMatch和elemMatch查询条件仅会返回数组中第一个匹配的元素，无法保留所有符合条件的属性。
• 原查询没有过滤掉筛选后values为空的文档，导致仍会出现不包含目标attribute的结果。

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