数据库和集合

Overview

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

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

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

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

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

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

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

访问数据库

Use the getDatabase() method on a MongoClient instance to access a MongoDatabase in a MongoDB instance.

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

val database = client.getDatabase("testDatabase")

访问集合

Use the getCollection() method of a MongoDatabase instance to access a MongoCollection in a database of your connected MongoDB instance.

以下示例从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])

创建集合

Use the createCollection() method of a MongoDatabase instance to create a collection in a database of your connected MongoDB instance.

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

database.createCollection("exampleCollection")

You can specify collection options like maximum size and document validation rules using the CreateCollectionOptions class. The createCollection() method accepts an instance of CreateCollectionOptions as an optional second parameter.

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()

删除数据库

您可以使用 MongoDatabase.drop() 从您的 MongoDB 部署中删除数据库方法，如以下示例所示：

val database = mongoClient.getDatabase("testDatabase")
database.drop()

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

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

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

• MongoDatabase.withReadConcern()

• MongoDatabase.withReadPreference()

• MongoDatabase.withWriteConcern()

• MongoCollection.withReadConcern()

• MongoCollection.withReadPreference()

• MongoCollection.withWriteConcern()

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

• 读取偏好

• 读关注 (read concern)

• 写关注