MongoDB Java驱动3.12.12中$toObjectId聚合函数使用异常排查

我使用MongoDB Java驱动3.12.12版本执行聚合操作连接两个集合，左集合的foreignKey字段是右集合_id字段的字符串形式，文档示例如下：

leftCollection文档：

{"foreignKey" : "5a43b24cb4eac10001dbafba"}

rightCollection文档：

{"_id" : ObjectId("5a43b24cb4eac10001dbafba"), "rightsideField": "some right side stuff"}

需要将leftCollection.foreignKey的字符串转换为ObjectId，用于后续$lookup阶段的关联。尝试使用$toObjectId聚合函数实现转换，但当前代码无法生成预期的foreignKeyObjId字段：

错误代码实现 #

Bson addForeignKeyObjectId = Aggregates.addFields(new Field("foreignKeyObjId", "$toObjectId:\"$foreignKey\""));

List<BsonDocument> foo = ImmutableList.copyOf(leftCollection.aggregate(
      ImmutableList.of(
        addForeignKeyObjectId,
      )
))

输出对比 #

• 预期输出：

{"foreignKey":"5a43b24cb4eac10001dbafba", "foreignKeyObjId":ObjectId("5a43b24cb4eac10001dbafba")}

• 实际输出：

{"foreignKey":"5a43b24cb4eac10001dbafba"}

替换为字面量时能正常添加字段，说明addFields步骤本身无问题，问题出在$toObjectId的语法写法上。

问题根源是直接将聚合表达式拼接成字符串传递，Java驱动无法识别这种格式的聚合操作符。正确做法是使用Document或驱动提供的辅助方法构建$toObjectId表达式。

修正后的代码（方式一：使用Document构建） #

// 构建$toObjectId表达式，将foreignKey字段转换为ObjectId
Bson addForeignKeyObjectId = Aggregates.addFields(
    new Field("foreignKeyObjId", new Document("$toObjectId", "$foreignKey"))
);

List<BsonDocument> foo = ImmutableList.copyOf(leftCollection.aggregate(
    ImmutableList.of(addForeignKeyObjectId)
));

修正后的代码（方式二：使用驱动辅助方法） #

如果使用MongoDB驱动的Aggregates工具类提供的toObjectId方法，代码会更简洁：

Bson addForeignKeyObjectId = Aggregates.addFields(
    Fields.field("foreignKeyObjId", Aggregates.toObjectId("$foreignKey"))
);

List<BsonDocument> foo = ImmutableList.copyOf(leftCollection.aggregate(
    ImmutableList.of(addForeignKeyObjectId)
));

原理说明 #

• 直接传递字符串"$toObjectId:\"$foreignKey\""时，驱动会将其视为普通字符串字面量，而非聚合操作符，因此不会执行转换逻辑。
• 用Document("$toObjectId", "$foreignKey")或Aggregates.toObjectId("$foreignKey")构建表达式，驱动能正确识别这是一个$toObjectId操作，将指定字段的字符串值转换为ObjectId类型。

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