如何通过单次操作批量更新MongoDB多文档的子嵌入文档（C#驱动）

现有MongoDB文档结构如下（用户列表）：

[
   { 
       "UserId": 100,
       // 其他字段
       "Statistics": { /* 原有统计数据 */ }
   },
   { 
       "UserId": 200,
       // 其他字段
       "Statistics": { /* 原有统计数据 */ }
   },
   { 
       "UserId": 300,
       // 其他字段
       "Statistics": { /* 原有统计数据 */ }
   },
]

需求：无需逐个循环用户执行更新，通过单次非原子、高性能操作，用C# MongoDB驱动为每个用户替换对应的Statistics嵌入文档，同时保留其他字段，不考虑会话/事务。

可以使用MongoDB驱动的BulkWrite方法实现。该方法允许一次性提交多个更新操作，客户端只需发起一次网络请求，大幅提升性能；同时属于非原子操作，无需会话支持。

代码示例 #

假设你已经有包含每个用户新Statistics数据的列表（比如List<UserUpdateDto>，其中UserUpdateDto包含UserId和新的Statistics对象），实现代码如下：

// 假设你的集合类型为IMongoCollection<User>，User是对应文档的实体类
var collection = mongoDatabase.GetCollection<User>("users");

// 构造批量更新操作列表
var bulkOps = new List<WriteModel<User>>();
foreach (var updateDto in userUpdateDtos)
{
    // 匹配指定UserId的文档
    var filter = Builders<User>.Filter.Eq(u => u.UserId, updateDto.UserId);
    // 替换Statistics字段，保留其他字段
    var update = Builders<User>.Update.Set(u => u.Statistics, updateDto.NewStatistics);
    // 添加单个更新操作到批量列表
    bulkOps.Add(new UpdateOneModel<User>(filter, update));
}

// 执行批量写入操作
var result = await collection.BulkWriteAsync(bulkOps, new BulkWriteOptions
{
    // 可选：设置为false时，遇到错误会继续执行后续操作，根据需求调整
    IsOrdered = false
});

// 可通过result获取操作结果，比如更新成功的文档数量
Console.WriteLine($"成功更新 {result.ModifiedCount} 条文档");

关键说明 #

• 非原子性：IsOrdered=false时，操作会并行执行，若部分操作失败，其他操作仍可能成功，无事务级原子性保障，符合需求。
• 性能优势：相比循环逐个发起更新请求，BulkWrite将所有操作打包为单次请求发送，减少了网络往返开销，性能提升明显。
• 字段保留：使用Set方法仅更新Statistics字段，文档中的其他字段会被完整保留。

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