Как обновить и обновить несколько документов в MongoDB с помощью драйверов C#

После Mongo 2.6 вы можете выполнять массовые обновления/обновления. Пример ниже выполняет массовое обновление с использованием драйвера 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();

Вы не можете сделать это в одном заявлении.

У вас есть два варианта

1) перебираем все объекты и делаем upserts

2) выяснить, какие объекты должны быть обновлены, а какие должны быть вставлены, затем выполните пакетную вставку и множественное обновление.

Для тех, кто использует версию 2.0 MongoDB.Driver, вы можете использовать метод 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); 

Попробуйте сначала удалить все вставляемые элементы из коллекции, а затем вызвать вставку:

        var search = [];
        arrayToInsert.forEach(function(v, k) {
            search.push(v.hash); // my unique key is hash. you could use _id or whatever
        })
        collection.remove({
            'hash' : {
                $in : search
            }
        }, function(e, docs) {

            collection.insert(arrayToInsert, function(e, docs) {
                if (e) {
                    console.log("data failed to update ", e);
                }
                else {
                    console.log("data updated ");
                }
            });
        })

UpdateFlags — это перечисление в драйвере C#, которое позволяет указать оба сразу. Как и любое другое перечисление флагов, вы делаете это с помощью битового «или».

var flags = UpdateFlags.Upsert | UpdateFlags.Multi;

Вы можете прочитать документы по перечислениям здесь (http://msdn.microsoft.com/en-us/library/cc138362.aspx), уделив особое внимание разделу о типах перечислений как битовых флагах.

Работа с [email protected] — попробуйте initializeUnorderedBulkOp():

export const InfoFunc = (Infos: Infos[]) => {

  const bulk = InfoResult.collection.initializeUnorderedBulkOp();
  Infos.forEach((info: Infos) => bulk.find({ "Id": info.Id}).upsert().updateOne(info));
  bulk.execute();
}