如何使用C#驱动程序在MongoDB中更新和升级多个文档

Question

我正在使用MongoDB 2,我想更新多个文档并将一个值processed:true 插入到集合中.但MongoDB c#api只允许我们更新多个记录或Upsert一条记录.

如何使用C#api解决这个问题？

Answer 1

之后Mongo 2.6,你可以做批量更新/ Upserts.以下示例使用c#驱动程序进行批量更新

MongoCollection<foo> collection = database.GetCollection<foo>(collectionName);
      var bulk = collection.InitializeUnorderedBulkOperation();
      foreach (FooDoc fooDoc in fooDocsList)
      {
        var update = new UpdateDocument { {fooDoc.ToBsonDocument() } };
        bulk.Find(Query.EQ("_id", fooDoc.Id)).Upsert().UpdateOne(update);
      }
      BulkWriteResult bwr =  bulk.Execute();

Answer 2

你不能在一个声明中做到这一点.

你有两个选择

1)遍历所有对象并进行upsert

2)确定哪些对象必须更新以及哪些对象必须插入然后执行批量插入和多次更新

Answer 3

对于使用MongoDB.Driver 2.0版的用户,可以使用BulkWriteAsync方法.

<!-- language: c# -->
// our example list
List<Products> products = GetProductsFromSomewhere();  

var collection = YourDatabase.GetCollection<BsonDocument>("products"); 

// initialise write model to hold list of our upsert tasks
var models = new WriteModel<BsonDocument>[products.Count];

// use ReplaceOneModel with property IsUpsert set to true to upsert whole documents
for (var i = 0; i < products.Count; i++){
    var bsonDoc = products[i].ToBsonDocument();
    models[i] = new ReplaceOneModel<BsonDocument>(new BsonDocument("aw_product_id", products[i].aw_product_id), bsonDoc) { IsUpsert = true };
};

await collection.BulkWriteAsync(models);