Docs 菜单
Docs 主页
/
语言
/
Kotlin
/
Kotlin 协程
/
使用示例

执行批量操作

bulkWrite() 方法对单个集合执行批量写入操作。此方法减少了从应用程序到 MongoDB 实例的网络往返次数，从而提高了应用程序的性能。由于您只有在所有操作返回后才会收到成功状态，因此如果满足您的用例的要求，我们建议您使用此状态。

您可以在 bulkWrite() 中指定以下一项或多项写入操作：

  • insertOne

  • updateOne

  • updateMany

  • deleteOne

  • deleteMany

  • replaceOne

bulkWrite() 方法接受以下参数：

  • 实现WriteModel的对象的List ：实现WriteModel的类对应于上述写入操作。 例如， InsertOneModel类包装insertOne写入操作。 有关每个类的更多信息，请参阅本页底部的 API 文档链接。

  • BulkWriteOptions：可选对象，指定相关设置，例如是否确保 MongoDB 实例对写入操作进行排序。

注意

可重试写入在 MongoDB Server 版本 3.6 或更高版本上以批量写入操作运行，除非它们包含 UpdateManyModel 或 DeleteManyModel 的一个或多个实例。

提示

默认情况下，MongoDB 会按指定顺序逐个执行批量写入操作（即连续执行）。有序批量写入期间，如果在处理某一操作期间出现错误，MongoDB 则会返回而不处理列表中的其余操作。相反，当您将 ordered 设置为 false 时，如果出现错误，MongoDB 将继续处理列表中的其余写入操作。无序操作在理论上速度更快，因为 MongoDB 可并行执行此类操作，但只应在写入操作不依赖顺序时使用。

bulkWrite() 方法返回一个 BulkWriteResult 对象，其中包含写入操作结果的有关信息，包括插入、修改和删除的文档数。

如果您的一个或多个操作尝试设置一个违反集合上唯一索引的值，则会引发异常，该异常应如下所示：

The bulk write operation failed due to an error: Bulk write operation error on server <hostname>. Write errors: [BulkWriteError{index=0, code=11000, message='E11000 duplicate key error collection: ... }].

同样，如果您尝试对使用模式验证的集合执行批量写入，并且您的一个或多个写入操作提供了意外格式，则可能会遇到异常。

例子

以下代码示例将对 sample_mflix 数据库中的 movies 集合执行有序批量写入操作。bulkWrite() 的示例调用包括 InsertOneModel、UpdateOneModel 和 DeleteOneModel 的示例。

注意

此示例使用连接 URI 连接到MongoDB实例。 要学习；了解有关连接到MongoDB实例的更多信息，请参阅连接指南。

import com.mongodb.MongoException
import com.mongodb.client.model.DeleteOneModel
import com.mongodb.client.model.Filters
import com.mongodb.client.model.InsertOneModel
import com.mongodb.client.model.ReplaceOneModel
import com.mongodb.client.model.UpdateOneModel
import com.mongodb.client.model.UpdateOptions
import com.mongodb.client.model.Updates
import com.mongodb.kotlin.client.coroutine.MongoClient
import kotlinx.coroutines.runBlocking
data class Movie(val title: String, val runtime: Int? = null)
fun main() = runBlocking {
    // Replace the uri string with your MongoDB deployment's connection string
    val uri = "<connection string uri>"
    val mongoClient = MongoClient.create(uri)
    val database = mongoClient.getDatabase("sample_mflix")
    val collection = database.getCollection<Movie>("movies")
    try {
        val result = collection.bulkWrite(
            listOf(
                InsertOneModel(Movie("A Sample Movie")),
                InsertOneModel(Movie("Another Sample Movie")),
                InsertOneModel(Movie("Yet Another Sample Movie")),
                UpdateOneModel(
                    Filters.eq(Movie::title.name,"A Sample Movie"),
                    Updates.set(Movie::title.name, "An Old Sample Movie"),
                    UpdateOptions().upsert(true)
                ),
                DeleteOneModel(Filters.eq("title", "Another Sample Movie")),
                ReplaceOneModel(
                    Filters.eq(Movie::title.name, "Yet Another Sample Movie"),
                    Movie("The Other Sample Movie", 42)
                )
            )
        )
        println(
            """
            Result statistics:
            inserted: ${result.insertedCount}
            updated: ${result.modifiedCount}
            deleted: ${result.deletedCount}
            """.trimIndent()
        )
    } catch (e: MongoException) {
        System.err.println("The bulk write operation failed due to an error: $e")
    }
    mongoClient.close()
}
Result statistics:
inserted: 3
updated: 2
deleted: 1

有关此页面上所提及的类和方法的更多信息，请参阅以下资源：

  • 唯一索引服务器手动输入

  • 模式验证服务器手册条目

  • bulkWrite () API 文档

  • BulkWriteOptions API 文档

  • BulkWriteResult API 文档

  • InsertOneModel API 文档

  • UpdateOneModel API 文档

  • UpdateManyModel API 文档

  • DeleteOneModel API 文档

  • DeleteManyModel API 文档

  • ReplaceOneModel API 文档

后退

删除多个文档

来年

注意更改