如何使用C#驱动高效更新MongoDB中10万+依赖其他集合计算结果的记录

算力阿峰

2026-10-16

解决方案

核心思路

不要逐行循环查询，通过单次MongoDB聚合操作批量计算所有产品的报价统计值，再通过批量写入接口一次性完成更新，全程只需要2次数据库交互，性能提升数个数量级。

实现步骤

为productOffers集合添加联合索引，大幅提升聚合效率：

// MongoDB 索引创建语句，C# driver也可直接调用对应API创建
db.productOffers.createIndex({ productId: 1, price: 1 })

这个索引可以直接覆盖聚合计算的所有字段，不需要回表查询完整文档。

小提示：如果需要处理无报价的产品，可提前查询所有产品ID，和聚合结果做匹配，为无报价的产品构造对应更新操作即可。

对productOffers集合执行聚合查询，一次性算出所有产品的最低报价和报价数量：
聚合逻辑：

用$group按productId分组
用$min运算符取每组最低价格
用$sum运算符统计每组的报价总数
C# 代码示例：

var aggregate = await productOffersCollection.Aggregate()
    .Group(
        p => p.ProductId,
        g => new {
            ProductId = g.Key,
            MinPrice = g.Min(x => x.Price),
            OfferCount = g.Count()
        }
    ).ToListAsync();

构造批量更新操作，一次性提交所有更新请求：

var bulkOps = new List<WriteModel<Product>>();
foreach (var stat in aggregate)
{
    var update = Builders<Product>.Update
        .Set(p => p.MinPrice, stat.MinPrice.ToString())
        .Set(p => p.NumberOfOffers, stat.OfferCount.ToString());
    bulkOps.Add(new UpdateOneModel<Product>(Builders<Product>.Filter.Eq(p => p.Id, stat.ProductId), update));
}
// 执行批量更新，数据量过大可拆分为每1万条提交一次，避免单次请求体积超限
await productsCollection.BulkWriteAsync(bulkOps);