c# - MongoDB c# 驱动程序使用 upsert 和 updateMany

Question

在 MongoDB c# 驱动程序（2.0+）中，我们可以在执行和 updateManyAsync 时执行 upsert 吗？这个例子对 UpdateOne 有帮助，但我正在寻找适用于 updateMany 的东西。

Answer 1

UpdateDefinition<Phone> updateDefinition = Builders<Phone>.Update.Set(x => x.Name, "Updated Name");
MongoDb.GetCollection<Phone>("Phone").UpdateOne(x => x._id == "foo", updateDefinition); // replaces first match
MongoDb.GetCollection<Phone>("Phone").UpdateMany(x => x.SomeProp == 5, updateDefinition); // replaces all matches

假设你有一堂课：

class Phone
{
    public string _id {get; set;} // this is the primary key because Mongo uses _id as primary key
    public string Name {get;set;}
    public int SomeProp {get;set;}

    // etc...
 }

Answer 2

这是在 C# .Net 核心中使用 UpdateMany 的更完整示例：

BostadsUppgifterMongoDbContext context = new BostadsUppgifterMongoDbContext(_configuration.GetConnectionString("DefaultConnection"), _configuration["ConnectionStrings:DefaultConnectionName"]);
var residenceCollection = context.MongoDatabase.GetCollection<Residence>("Residences");
residenceCollection.UpdateMany(x =>
    x.City == "Stockholm",
    Builders<Residence>.Update.Set(p => p.Municipality, "Stoholms län"),
    new UpdateOptions { IsUpsert = false }
);

如果IsUpsert设置为 true，如果没有找到匹配项，它将插入一个文档。

Answer 3

Upsert 在使用updateMany时也能正常工作：

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

Answer 4

TModel 是你的模型

var updateBuilder = new UpdateDefinitionBuilder<TModel>();
yourContext.UpdateMany(filterExpression, update.Set(updateExpression, updateValue));