数据库和集合

Overview

在本指南中，您可以了解如何通过 MongoDB Kotlin 驱动程序使用 MongoDB 数据库和 collection。

MongoDB 将数据组织成以下级别的层次结构：

1. 数据库：数据库是 MongoDB 实例中数据组织的最高级别。

2. collection：数据库被组织成包含文档的collection。

3. 文档：文档包含字符串、数字和日期等字面数据以及其他嵌入式文档。 有关文档字段类型和结构的更多信息，请参阅有关文档的服务器文档。

借助MongoDB Kotlin驾驶员，您可以使用Kotlin数据类或使用文档 类对数据进行建模，以便在MongoDB中存储和检索数据。

要学习；了解有关使用数据类的更多信息，请参阅数据类数据格式指南。 要学习；了解有关使用 Document类的更多信息，请参阅文档数据格式指南。

访问数据库

使用 getDatabase() MongoClientMongoDatabase实例的方法来访问权限MongoDB实例中的 。

以下示例将访问名为testDatabase的数据库：

val database = client.getDatabase("testDatabase")

访问集合

使用 getCollection() MongoDatabase实例的方法，用于访问已连接MongoCollection MongoDB 实例的数据库中的 。

以下示例从MongoDatabase访问名为testCollection的collection，其中包含类型为ExampleDataClass的文档：

data class ExampleDataClass(
    @BsonId val id: ObjectId = ObjectId(),
    val exampleProperty: String,
)

val collection = database.getCollection<ExampleDataClass>("testCollection")

data class Fruit(
    @BsonId val id: Int,
    val name: String,
    val qty: Int,
    val seasons: List<String>
)

val collection =
    database.getCollection<Fruit>("fruits")
// Define a data class for returned documents
data class NewFruit(
    @BsonId val id: Int,
    val name: String,
    val quantity: Int,
    val seasons: List<String>
)
val filter = Filters.eq(Fruit::name.name, "strawberry")
val update = Updates.combine(
    Updates.rename(Fruit::qty.name, "quantity"),
    Updates.push(Fruit::seasons.name, "fall"),
)
val options = FindOneAndUpdateOptions()
    .returnDocument(ReturnDocument.AFTER)
// Specify the class for returned documents as the type parameter in withDocumentClass()
val result = collection
    .withDocumentClass<NewFruit>()
    .findOneAndUpdate(filter, update, options)
println(result)

NewFruit(id=1, name=strawberry, quantity=205, seasons=[summer, fall])

创建集合

使用 createCollection() MongoDatabase实例的方法，用于在已连接MongoDB实例的数据库中创建集合。

以下示例创建了一个名为exampleCollection的collection：

database.createCollection("exampleCollection")

您可以使用 CreateCollectionOptions 指定集合选项，例如最大大小和文档验证规则。 类。createCollection()方法接受CreateCollectionOptions实例作为可选的第二个参数。

val collOptions: ValidationOptions = ValidationOptions().validator(
    Filters.or(
        Filters.exists("title"),
        Filters.exists("name")
    )
)
database.createCollection(
    "movies",
    CreateCollectionOptions().validationOptions(collOptions)
)

获取集合列表

你可以使用 MongoDatabase.listCollectionNames() 方法查询数据库中的集合列表：

val collectionList = database.listCollectionNames().toList()
println(collectionList)

[movies, exampleCollection]

删除集合

您可以使用 MongoCollection.drop() 方法从数据库中删除一个集合：

val collection =
    database.getCollection<ExampleDataClass>("movies")
collection.drop()

指定读取偏好、读关注和写关注

读取偏好、读关注和写关注可控制驱动程序如何路由读操作，以及在连接 MongoDB 副本集时如何等待读写操作的确认。读取偏好和读关注适用于所有读操作；写关注适用于所有写操作。

MongoDatabase 实例从创建它们的 MongoClient 继承写关注、读关注和写入偏好设置。MongoCollection 实例从创建它们的 MongoDatabase 继承写关注、读关注和写入偏好设置。不过，您可以使用以下方法获取 MongoDatabase 或 MongoCollection 的实例，该实例的读取偏好、读关注或写关注与其通常继承的设置有所不同：

• MongoDatabase.withReadConcern()

• MongoDatabase.withReadPreference()

• MongoDatabase.withWriteConcern()

• MongoCollection.withReadConcern()

• MongoCollection.withReadPreference()

• MongoCollection.withWriteConcern()

有关这些主题的更多信息，请参阅服务器手册中的以下页面：

• 读取偏好

• 读关注 (read concern)

• 写关注