MongoDB 提供了执行批量插入、更新和删除操作的能力。 在MongoDB C# Driver中，可以使用支持以下写操作的BulkWriteAsync()方法: UpdateOne更新一个 UpdateMany更新多个 DeleteOne删除一个 DeleteMany删除多个。我们将展示如何在 MongoDB 的 C# 驱动程序中使用这些方法。

MongoDB和C#介绍

MongoDB 提供了执行批量插入、更新和删除操作的能力。

在MongoDB C# Driver,中,我们可以使用支持以下写操作的BulkWriteAsync()方法:

• InsertOneModel
• UpdateOne
• UpdateMany
• DeleteOne
• DeleteMany

开始吧

我创建了一个包含以下字段的用户集合。

• _id
• 名称
• 邮箱
• 创建时间
• isBlocked

是的!没有_密码_!这不是这篇文章的范围。

public class User
{
    public ObjectId _id { get; set; }
    public string name { get; set; }
    public string email { get; set; }
    public DateTime createdAt { get; set; }
    public bool isBlocked { get; set; }
 }

插入操作

BulkWriteAsync 方法

此方法负责执行批量操作。BulkWriteAsync采用可变数量(列表)的WriteModel实例。

我们将 User 模型设置为WriteModel类的泛型类型参数。

var listWrites = new List<WriteModel<User>>();

创建假用户数据集

然后,我们将创建一个包含 1000 个新用户的假数据集,并将其添加到 WriteModel 类型列表中。

    var totalNewUsers = 1000;

    for (int i = 0; i < totalNewUsers; i++)
    {
        var newUser = new User
        {
            name = #34;customName-{i}",
            email = #34;customEmail-{i}@domain{i}.com",
            createdAt = DateTime.Now,
            isBlocked = false
        };

        listWrites.Add(new InsertOneModel<User>(newUser));
    }

注意InsertOneModel对象。我们告诉 MongoDB 这是一个插入操作。

执行批量插入操作

最后,我们获取用户集合并执行批量插入。

    var userCollection = db.GetCollection<User>("users");
    var resultWrites = await userCollection.BulkWriteAsync(listWrites);

    Console.WriteLine(#34;OK?: {resultWrites.IsAcknowledged} - Inserted Count: {resultWrites.InsertedCount}");

默认情况下,MongoDB 使用有序的方法执行批量插入。这意味着串行执行操作。如果其中一个插入操作发生错误,MongoDB 结束批量插入。如果希望 MongoDB 继续进行批量插入,则需要指定传递BulkWriteOptions对象的无序方法:

    var resultWrites = await userCollection.BulkWriteAsync(listWrites, new BulkWriteOptions
    {
        IsOrdered = false
    });

完整代码

    public static async Task BulkInsertMongoDb()
    {
        IMongoDatabase db = _client.GetDatabase("sample_blog");

        var listWrites = new List<WriteModel<User>>();
        var totalNewUsers = 1000;

        for (int i = 0; i < totalNewUsers; i++)
        {
            var newUser = new User
            {
                name = #34;customName-{i}",
                email = #34;customEmail-{i}@domain{i}.com",
                createdAt = DateTime.Now,
                isBlocked = false
            };

            listWrites.Add(new InsertOneModel<User>(newUser));
        }

        var userCollection = db.GetCollection<User>("users");
        var resultWrites = await userCollection.BulkWriteAsync(listWrites);

        Console.WriteLine(#34;OK?: {resultWrites.IsAcknowledged} - Inserted Count: {resultWrites.InsertedCount}");
    }

更新操作

插入 1000 个新用户后,我们将更新其中的一些用户

更新一个

此类 (UpdateOneModel) 为我们提供了一种仅更新与特定条件匹配的文档的方法。

我们需要设置过滤器定义(条件)和更新定义(要更新哪些字段)

    var filterDefinition = Builders<User>.Filter.Eq(p => p.email, "customEmail-0@domain0.com");
    var updateDefinition = Builders<User>.Update.Set(p => p.isBlocked, true);

然后,将这些定义添加到我们的UpdateOneModel实例中。

    listWrites.Add(new UpdateOneModel<User>(filterDefinition, updateDefinition));

UpdateOne 完整代码

    public static async Task BulkUpdateOneMongoDb()
    {
        IMongoDatabase db = _client.GetDatabase("sample_blog");
        var userCollection = db.GetCollection<User>("users");

        var listWrites = new List<WriteModel<User>>();

        var filterDefinition = Builders<User>.Filter.Eq(p => p.email, "customEmail-0@domain0.com");
        var updateDefinition = Builders<User>.Update.Set(p => p.isBlocked, true);

        listWrites.Add(new UpdateOneModel<User>(filterDefinition, updateDefinition));

        await userCollection.BulkWriteAsync(listWrites);
    }

更新多个

这个类(UpdateManyModel)允许我们更新匹配特定条件的多个文档。

正如我们对 UpdateOne 所做的那样,我们需要设置过滤器定义和更新后的定义。

    var filterDefinition = Builders<User>.Filter.Eq(p => p.isBlocked, false);
    var updateDefinition = Builders<User>.Update.Set(p => p.isBlocked, true);

在这种情况下,我们将阻止所有尚未被阻止的用户。

UpdateMany 的完整代码

    public static async Task BulkUpdateManyMongoDb()
    {
        IMongoDatabase db = _client.GetDatabase("sample_blog");
        var userCollection = db.GetCollection<User>("users");

        var listWrites = new List<WriteModel<User>>();

        var filterDefinition = Builders<User>.Filter.Eq(p => p.isBlocked, false);
        var updateDefinition = Builders<User>.Update.Set(p => p.isBlocked, true);

        listWrites.Add(new UpdateManyModel<User>(filterDefinition, updateDefinition));

        await userCollection.BulkWriteAsync(listWrites);
    }

UpdateOne 和 UpdateMany

正如我们所看到的,这些方法的实现是相同的。主要区别在于,如果条件匹配多个文档,UpdateOne 将仅更新第一个匹配的文档,而 UpdateMany 更新所有文档。

删除操作

它与更新操作非常相似,但在这种情况下,我们将删除用户集合中的一些文档。

删除一个

此类 (DeleteOneModel) 为我们提供了一种仅删除与特定条件匹配的文档的方法

我们需要设置一个过滤器定义(条件)

    var filterDefinition = Builders<User>.Filter.Eq(p => p.email, "customEmail-0@domain0.com");

在这种情况下,我们将删除第一个与等于customEmail-0@domain0.com的电子邮件匹配的文档。

DeleteOne的完整代码

    public static async Task BulkDeleteOneMongoDb()
    {
        IMongoDatabase db = _client.GetDatabase("sample_blog");
        var userCollection = db.GetCollection<User>("users");

        var listWrites = new List<WriteModel<User>>();

        var filterDefinition = Builders<User>.Filter.Eq(p => p.email, "customEmail-0@domain0.com");
        listWrites.Add(new DeleteOneModel<User>(filterDefinition));

        await userCollection.BulkWriteAsync(listWrites);
    }

DeleteMany

这个类(DeleteManyModel)允许我们删除多个匹配特定条件的文档。

正如我们对 DeleteOne 所做的那样,我们需要设置一个过滤器定义。

    var filterDefinition = Builders<User>.Filter.Eq(p => p.isBlocked, true);

在这种情况下,我们将删除所有被阻止的用户。

DeleteMany 的完整代码

    public static async Task BulkDeleteManyMongoDb()
    {
        IMongoDatabase db = _client.GetDatabase("sample_blog");
        var userCollection = db.GetCollection<User>("users");

        var listWrites = new List<WriteModel<User>>();

        var filterDefinition = Builders<User>.Filter.Eq(p => p.isBlocked, true);
        listWrites.Add(new DeleteManyModel<User>(filterDefinition));

        await userCollection.BulkWriteAsync(listWrites);
    }

DeleteOne 和 DeleteMany

正如我们所说的 UpdateOne 和 UpdateMany,这些方法的实现是相同的。主要区别在于,如果条件匹配多个文档,DeleteOne 将仅删除第一个匹配的文档,而 DeleteMany 删除所有文档。

放在一起

我们将把之前的所有操作分组到同一个批量写入操作中,这样我们将创建 1,000 个新用户,然后按顺序在同一个批量中执行 UpdateOne、UpdateMany、DeleteOne 和 DeleteMany 操作。

    public static async Task BulkAllTogetherMongoDb()
    {
        IMongoDatabase db = _client.GetDatabase("sample_blog");

        var listWrites = new List<WriteModel<User>>();
        var totalNewUsers = 1000;

        //InsertOne
        for (int i = 0; i < totalNewUsers; i++)
        {
            var newUser = new User
            {
                name = #34;customName-{i}",
                email = #34;customEmail-{i}@domain{i}.com",
                createdAt = DateTime.Now,
                isBlocked = false
            };

            listWrites.Add(new InsertOneModel<User>(newUser));
        }

        //UpdateOne
        var filterDefinition = Builders<User>.Filter.Eq(p => p.email, "customEmail-0@domain0.com");
        var updateDefinition = Builders<User>.Update.Set(p => p.isBlocked, true);

        listWrites.Add(new UpdateOneModel<User>(filterDefinition, updateDefinition));

        //UpdateMany
        var filterDefinitionUpdateMany = Builders<User>.Filter.Eq(p => p.isBlocked, false);
        var updateDefinitionUpdateMany = Builders<User>.Update.Set(p => p.isBlocked, true);

        listWrites.Add(new UpdateManyModel<User>(filterDefinitionUpdateMany, updateDefinitionUpdateMany));

        //DeleteOne
        var filterDefinitionDeleteOne = Builders<User>.Filter.Eq(p => p.email, "customEmail-0@domain0.com");
        listWrites.Add(new DeleteOneModel<User>(filterDefinitionDeleteOne));

        //DeleteMany
        var filterDefinitionDeleteMany = Builders<User>.Filter.Eq(p => p.isBlocked, true);
        listWrites.Add(new DeleteManyModel<User>(filterDefinitionDeleteMany));

        var userCollection = db.GetCollection<User>("users");
        var resultWrites = await userCollection.BulkWriteAsync(listWrites);

        Console.WriteLine(#34;OK?: {resultWrites.IsAcknowledged} - Inserted Count: {resultWrites.InsertedCount}");
        Console.WriteLine(#34;Updated Count: {resultWrites.ModifiedCount}");
        Console.WriteLine(#34;Deleted Count: {resultWrites.DeletedCount}");
    }

控制台输出:

OK?: True - 插入计数:1000 更新计数:1000 删除计数:1000