如何使用 C# 驱动程序更新和更新插入 MongoDB 中的多个文档

Question

我正在使用 MongoDB 2，我想更新多个文档并更新插入像 processed:true 这样的值 进入收藏。但是 MongoDB c# api 只允许我们更新多个记录或更新插入单个记录。

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

Answer 1

使用 [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();
}

Answer 2

尝试首先从集合中删除要插入的所有项目，然后调用 insert：

        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 ");
                }
            });
        })

Answer 3

更漂亮、更健壮的方法：

public interface IProjection
{
    Guid Id { get; }
    bool IsDeleted { get; }
}

public async Task UpsertManyAsync<TProjection>(IEnumerable<TProjection> replacements, CancellationToken cancellationToken)
    where TProjection : IProjection
{
    var requests = replacements.Select(replacement => new ReplaceOneModel<TProjection>(
        filter: new ExpressionFilterDefinition<TProjection>(projection => projection.Id == replacement.Id),
        replacement: replacement) { IsUpsert = true });

    await _context
        .GetCollection<TProjection>()
        .BulkWriteAsync(
            requests: requests,
            options: new BulkWriteOptions { IsOrdered = false },
            cancellationToken: cancellationToken);
}

Answer 4

UpdateFlags 是 C# 驱动程序中的一个枚举，可让您同时指定两者。就像任何其他标志枚举一样，您可以通过位“或”来完成此操作。

var flags = UpdateFlags.Upsert | UpdateFlags.Multi;

您可以在此处阅读有关枚举的文档（http://msdn.microsoft.com/en-us/library/cc138362.aspx），特别注意有关枚举类型作为位标志的部分

Answer 5

在 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 6

你不能在一份声明中做到这一点。

您有两个选择

1) 循环所有对象并进行更新插入

2) 找出哪些对象必须更新以及哪些对象必须插入，然后进行批量插入和多重更新

Answer 7

对于使用 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);