数据库和集合

Overview

在本指南中，您可以了解如何通过 PyMongo 使用 MongoDB 数据库和集合。

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

• 数据库：MongoDB 实例中数据组织的顶层。

• 集合：MongoDB 将文档存储在集合中。 它们类似于关系数据库中的表。

• 文档：包含字面数据，例如string 、数字、日期和其他嵌入式文档。

有关文档字段类型和结构的更多信息，请参阅 MongoDB Server 手册中的文档指南。

访问数据库

在MongoClient实例上使用字典式访问来访问数据库。

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

database = client["test_database"]

访问集合

通过对数据库实例使用字典式访问来访问集合。

以下示例访问名为 test_collection 的集合：

database = client["test_database"]
collection = database["test_collection"]

创建集合

使用 create_collection() 方法在MongoDB database中显式创建集合。

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

database = client["test_database"]
database.create_collection("example_collection")

您可以通过将集合选项（例如最大大小和文档验证规则）作为关键字参数传递来指定这些选项。 有关可选参数的完整列表，请参阅 create_collection() API 文档。

database = client["test_database"]
database.create_collection("example_ts_collection", timeseries={"timeField": "timestamp"})

database = client["test_database"]
database.create_collection("example_capped_collection", capped=True, size=1000)

获取集合列表

您可以通过调用list_collections()方法来查询数据库中的集合列表。 该方法返回一个游标，其中包含数据库中的所有集合及其关联的元数据。

以下示例调用list_collections()方法并对游标进行迭代以打印结果：

collection_list = database.list_collections()
for c in collection_list:
    print(c)

要仅查询数据库中集合的名称，请调用list_collection_name()方法，如下所示：

collection_list = database.list_collection_names()
for c in collection_list:
    print(c)

有关迭代游标的更多信息，请参阅从游标访问数据。

删除集合

您可以使用drop_collection()方法从数据库中删除集合。

以下示例删除test_collection集合：

collection = database["test_collection"];
collection.drop();

配置读取和写入操作

您可以通过设置读取偏好来控制驱动程序路由读取操作的方式。 您还可以通过设置读关注和写关注来控制驱动程序如何等待副本集上读写操作确认的选项。

默认情况下，数据库从MongoClient实例继承这些设置，集合从数据库继承这些设置。 但是，您可以使用以下方法之一更改数据库或集合的这些设置：

• get_database() ：获取数据库并应用客户端的读取偏好（read preference）、读关注（read concern）和写入偏好。

• database.with_options() ：获取数据库并应用其当前的读取偏好（read preference）、读关注（read concern）和写入偏好。

• get_collection() ：获取集合并应用其当前的读取偏好（read preference）、读关注（read concern）和写入偏好。

• collection.with_options() ：获取集合并应用数据库的读取偏好（read preference）、读关注（read concern）和写入偏好。

若要使用上述方法更改读取或写入设置，请调用该方法并传入集合或数据库名称以及新的读取偏好、读关注或写入偏好。

以下示例展示了如何使用get_database()方法更改名为test-database的数据库的读取偏好、读关注和写入偏好：

client.get_database("test-database",
                    read_preference=ReadPreference.SECONDARY,
                    read_concern="local",
                    write_concern="majority")

以下示例展示了如何使用get_collection()方法更改名为test-collection的集合的读取和写入设置：

database.get_collection("test-collection",
                    read_preference=ReadPreference.SECONDARY,
                    read_concern="local",
                    write_concern="majority")

以下示例展示了如何使用with_options()方法更改名为test-collection的集合的读取和写入设置：

collection.with_options(read_preference=ReadPreference.SECONDARY,
                        read_concern="local",
                        write_concern="majority")

要了解有关读取和写入设置的更多信息，请参阅 MongoDB Server 手册中的以下指南：

• 读取偏好

• 读关注 (read concern)

• 写关注

db = client.get_database(
     'test', read_preference=Secondary([{'dc': 'ny'}, {'dc': 'sf'}]))

client = MongoClient(replicaSet='repl0',
                     readPreference=ReadPreference.SECONDARY_PREFERRED,
                     localThresholdMS=35)

client = MongoClient("<connection string>",
                     retryReads=False, retryWrites=False)

故障排除

API 文档

要进一步了解本指南所讨论的任何方法或类型，请参阅以下 API 文档：

• create_collection()

• list_collections()

• list_collection_names()

• get_database()

• get_collection()

• database.with_options()

• collection.with_options()