Docs 菜单
Docs 主页
/ / /
Kotlin Sync 驱动程序

将数据写入 MongoDB

在此页面上

  • Overview
  • 示例应用程序
  • insertOne
  • 插入多个
  • updateOne
  • 更新多个
  • replaceOne
  • deleteOne
  • 删除多个
  • 批量写入

在此页面上,您可以查看可用于通过Kotlin Sync驾驶员将数据写入MongoDB的常用方法的可复制代码示例。

提示

要了解有关此页面上显示的任何方法的更多信息,请参阅每个部分中提供的链接。

要使用本页中的示例,请将代码示例复制到示例应用程序或您自己的应用程序中。 请务必将代码示例中的所有占位符(例如 <connection string URI> )替换为 MongoDB 部署的相关值。

您可以使用以下示例应用程序来测试本页上的代码示例。 要使用示例应用程序,请执行以下步骤:

  1. 确保您已在 Maven 或 Gradle项目中安装Kotlin Sync驾驶员程序。

  2. 复制以下代码并将其粘贴到新的.kt文件中。

  3. 从此页面复制代码示例,并将其粘贴到文件中的指定行。

1import com.mongodb.ConnectionString
2import com.mongodb.MongoClientSettings
3import com.mongodb.client.model.*
4import com.mongodb.kotlin.client.*
5import org.bson.Document
6
7fun main() {
8 val uri = "<connection string URI>"
9
10 val settings = MongoClientSettings.builder()
11 .applyConnectionString(ConnectionString(uri))
12 .retryWrites(true)
13 .build()
14
15 // Create a new client and connect to the server
16 val mongoClient = MongoClient.create(settings)
17 val database = mongoClient.getDatabase("<database name>")
18 val collection = database.getCollection<Document>("<collection name>")
19
20 // Start example code here
21
22 // End example code here
23}

以下代码演示如何将单个文档插入集合:

val result = collection.insertOne(Document("<field name>", "<value>"))
print(result.insertedId)

要学习;了解有关insertOne()方法的更多信息,请参阅插入文档指南。

以下代码演示了如何将多个文档插入到集合中:

val docList = listOf(
Document("<field name>", "<value>"),
Document("<field name>", "<value>")
)
val result = collection.insertMany(docList)
print(result.insertedIds)

要了解有关insertMany()方法的更多信息,请参阅“插入文档”指南。

以下代码演示如何通过创建或编辑字段来更新集合中的单个文档:

val query = Filters.eq("<field to match>", "<value to match>")
val update = Updates.set("<field name>", "<value>")
val result = collection.updateOne(query, update)
print(result.modifiedCount)

要了解有关updateOne()方法的更多信息,请参阅更新文档指南。

以下代码演示如何通过创建或编辑字段来更新集合中的多个文档:

val query = Filters.eq("<field to match>", "<value to match>")
val update = Updates.set("<field name>", "<value>")
val result = collection.updateMany(query, update)
print(result.modifiedCount)

要了解有关updateMany()方法的更多信息,请参阅更新文档指南。

以下代码演示如何用新文档替换集合中的单个文档:

val query = Filters.eq("<field to match>", "<value to match>")
val replacement = Document("<new document field name>", "<new document value>")
val result = collection.replaceOne(query, replacement)
print(result.modifiedCount)

要了解有关replaceOne()方法的更多信息,请参阅替换文档指南。

以下代码演示如何删除集合中的单个文档:

val query = Filters.eq("<field to match>", "<value to match>")
val result = collection.deleteOne(query)
print(result.deletedCount)

要了解有关deleteOne()方法的更多信息,请参阅“删除文档”指南。

以下代码演示如何删除集合中的多个文档:

val query = Filters.eq("<field to match>", "<value to match>")
val result = collection.deleteMany(query)
print(result.deletedCount)

要了解有关deleteMany()方法的更多信息,请参阅“删除文档”指南。

以下代码展示了如何在单个批量操作中执行多个写入操作:

val bulkOps = listOf(
InsertOneModel(Document("<field name>", "<value>")),
UpdateOneModel(
Filters.eq("<field to match>", "<value to match>"),
Updates.set("<field name>", "<value>")),
DeleteOneModel(Filters.eq("<field to match>", "<value to match>"))
)
val result = collection.bulkWrite(bulkOps)
print(result)

要了解有关bulkWrite()方法的更多信息,请参阅批量写入指南。

后退

Stable API