MongoDB Kotlin同步驱动$addFields聚合阶段表达式报错排查

先明确核心问题：MongoDB 4.4不支持$getField表达式，且查询用的Filters.elemMatch不适用于聚合管道的数组筛选逻辑，以下是对应Compass管道逻辑的正确实现：

代码示例 #

import org.mongodb.kotlin.sync.driver.MongoCollection
import org.mongodb.kotlin.sync.driver.aggregation.Aggregates.addFields
import org.mongodb.kotlin.sync.driver.aggregation.Expressions.*

// 替换成你的集合对象和文档类型
val pipeline = listOf(
    addFields(
        mapOf(
            "newField" to filter(
                input = field("existingField"), // 指向要筛选的原数组字段
                `as` = "item", // 数组元素的别名，对应Compass里的as参数
                cond = eq(field("$$item.primary"), value(true)) // 筛选条件：元素的primary字段为true
            )
        )
    )
)

// 执行聚合查询
val result = collection.aggregate<YourResultType>(pipeline).toList()

关键细节说明 #

• 用Expressions.filter构建聚合专用的$filter逻辑，和查询阶段的Filters.elemMatch完全不是一回事，后者是用来匹配包含指定元素的文档，而非筛选数组生成新字段。
• 引用数组元素字段时用field("$$item.primary")，通过$$标识聚合变量（这里的item是as定义的别名），这种写法MongoDB 4.4完全兼容，不会生成不支持的$getField表达式。
• 条件判断用Expressions.eq对应MongoDB的$eq操作符，和你在Compass里的逻辑完全一致。

之前写法失败的原因 #

1. Filters.elemMatch的误区：这个方法是查询阶段用来匹配包含符合条件元素的文档，不是聚合里筛选数组元素生成新字段的工具，逻辑不对自然得不到正确结果。
2. current()报错的根源：Kotlin驱动的current().get("primary")会生成$getField表达式，但这个操作符是MongoDB 5.0才引入的，4.4版本不支持，所以触发了"Unrecognized expression '$getField'"错误。

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