Вставка/обновление нескольких записей

Question

У меня есть исходный файл записей ~ 100000, некоторые из этих записей находятся в db, а некоторые - новые. Какой самый быстрый способ проверить каждый документ, если он существует, обновить его, если он есть, или вставить его, если его новый использует драйвер MongoDb C#.

Я использовал FindOneAndUpdateAsync для каждого документа, но это занимает много времени. Я не могу найти способ запустить несколько из них с помощью драйвера MongoDb. Мне пришлось бы запускать эти параллели в async кода?

Answer 1

Для проблемы с обновлением/вставкой ReplaceOne принимает параметр UpdateOptions в качестве параметра, здесь вы можете указать, должно ли оно быть upsert. Upsert inserts if not existing, обновления, если существует. Пример кода (Там один асинхронной а):

collection.ReplaceOne(query, model, new UpdateOptions() {IsUpsert = upsert}); 

Alt:

var options = new UpdateOptions { IsUpsert = true }; 
var result = await collection.UpdateManyAsync(filter, update, options); 

Answer 2

Вы можете использовать upsert для вашей потребности, как показано ниже (пример цитируемый из MongoDB документации)

var bulk = db.items.initializeUnorderedBulkOp(); 
bulk.find({ item: "abc123" }).upsert().replaceOne(
    { 
    item: "abc123", 
    status: "P", 
    points: 100, 
    } 
); 
bulk.execute(); 

На вашем C# водителе вы можете использовать UpdateManyAsync() ИЛИ ReplaceOneAsync() с IsUpsert update opt ион установлен true

Answer 3

Вы можете сделать что-то вроде этого:

var builder = Builders<yourType>.Filter; 
var filter = builder.Eq("something", something); 
var update = Builders<youType>.Update 
    .Set("something", someNewThing) 
    .SetOnInsert("something2", someNewThing2); 
yourContext.yourCollection.UpdateManyAsync(filter, update, new UpdateOption {IsUpsert = true}).Result.IsAcknowledged;