C#批量更新MongoDB文档嵌套数组字段未生效问题求助

问题根因 #

你的代码存在3个核心错误导致更新不生效：

• 顶层过滤器错误：现有过滤器builder.Eq("systemrecordname", ef.systemrecordname)是在文档根路径下匹配字段，而systemrecordname实际存于orders.fulfillment子数组中，根路径不存在该字段，没有匹配到任何待更新文档。
• 数组过滤器不完整：更新路径使用了$[e]（对应orders数组元素）和$[ef]（对应fulfillment数组元素）两个占位符，但仅定义了ef的过滤规则，缺少$[e]对应的数组过滤器，MongoDB会直接拒绝执行该更新语句。
• 异步方法未等待：BulkWriteAsync是异步方法，代码中未加await关键字，可能程序退出时异步写操作还未提交到MongoDB执行。

修复后的遍历更新代码 #

var bulkupdate = new List<WriteModel<EquipmentDemandPlan>>();
foreach (var item in resultFromDatabse)
{
    // 匹配当前待更新的文档_id，精准定位目标文档
    var filter = builder.Eq("_id", item._id);
    var update = Builders<EquipmentDemandPlan>.Update.Set("orders.$[e].fulfillment.$[ef].systemid", "789");

    var updateOne = new UpdateOneModel<EquipmentDemandPlan>(filter, update)
    {
        ArrayFilters = new List<ArrayFilterDefinition> 
        {
            // 补充orders数组占位符的过滤规则
            new BsonDocumentArrayFilterDefinition<BsonDocument>(new BsonDocument("e._id", BsonValue.Create(item.orders.First()._id))),
            new BsonDocumentArrayFilterDefinition<BsonDocument>(new BsonDocument("ef.systemrecordname", "source1"))
        }
    };
    bulkupdate.Add(updateOne);
}
// 等待异步写操作执行完成
await collection.BulkWriteAsync(bulkupdate);

更高效的批量更新方案（无需提前查询文档） #

不需要先查询全量文档遍历，直接通过MongoDB原生数组过滤能力一次性更新所有符合条件的文档，性能提升明显：

// 筛选所有包含systemrecordname=source1的fulfillment节点的文档
var filter = Builders<EquipmentDemandPlan>.Filter.ElemMatch(x => x.orders, 
    o => o.fulfillment.Any(f => f.systemrecordname == "source1"));
// 全量更新符合条件的嵌套字段
var update = Builders<EquipmentDemandPlan>.Update.Set("orders.$[].fulfillment.$[ef].systemid", "789");

var updateOptions = new UpdateOptions
{
    ArrayFilters = new List<ArrayFilterDefinition>
    {
        new BsonDocumentArrayFilterDefinition<BsonDocument>(new BsonDocument("ef.systemrecordname", "source1"))
    }
};
// 执行批量更新
await collection.UpdateManyAsync(filter, update, updateOptions);

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