数据库和集合

Overview

在本指南中，您可以学习；了解如何使用C++驾驶员与MongoDB数据库和集合进行交互。

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

• 数据库： MongoDB 部署中用于存储集合的顶级数据结构。

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

• 文档：存储字面数据（例如string 、数字、日期和其他嵌入式文档）的单位。 有关文档字段类型和结构的更多信息，请参阅MongoDB Server手册中的文档指南。

访问数据库

您可以通过在 mongocxx::client对象上调用 database() 函数并将数据库名称作为参数传递来访问权限数据库。

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

auto db = client.database("test_database");

或者，您可以使用 mongocxx::client 上的 []操作符作为 database() 函数的简写，如以下代码所示：

auto db = client["test_database"];

访问集合

您可以通过对 mongocxx::database对象调用 collection() 函数并将集合名称作为参数传递来访问权限集合。

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

auto coll = database.collection("test_collection");

或者，您可以使用 mongocxx::database 上的 []操作符作为 collection() 函数的简写，如以下代码所示：

auto coll = database["test_collection"];

创建集合

您可以使用 create_collection() 函数在MongoDB 数据库中显式创建集合。

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

auto coll = database.create_collection("example_collection");

您可以指定集合选项，例如最大大小和文档验证规则，方法是将它们在BSON文档中作为create_collection() 函数的第二个参数传递。有关可选参数的完整列表，请参阅MongoDB Server手册中的创建命令文档。

获取集合列表

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

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

auto cursor = database.list_collections();
for(auto&& doc : cursor) {
    std::cout << bsoncxx::to_json(doc) << std::endl;
}

Collection: { "name" : "test_collection", "type" : "collection", ...}
Collection: { "name" : "example_collection", "type" : "collection", ... }

要仅查询数据库中集合的名称，请调用 list_collection_names() 函数，如以下示例所示：

auto list = database.list_collection_names();
for(auto&& name : list) {
    std::cout << name << std::endl;
}

test_collection
example_collection

有关遍历游标的更多信息，请参阅 《从游标访问数据》指南。

删除集合

您可以使用 drop() 函数从数据库中删除集合。

以下示例删除"test_collection"集合：

auto coll = database["test_collection"];
coll.drop();

配置读取和写入操作

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

默认，数据库从 mongocxx::client对象继承这些设置，集合从数据库继承这些设置。但是，您可以在数据库或集合上使用以下函数之一来更改这些设置：

• read_preference()

• read_concern()

• write_concern()

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

• 读取偏好

• 读关注 (read concern)

• 写关注

auto db = client["test_database"];
mongocxx::read_preference rp;
rp.mode(mongocxx::read_preference::read_mode::k_secondary);
mongocxx::read_concern rc;
rc.acknowledge_level(mongocxx::read_concern::level::k_majority);
db.read_preference(rp);
db.read_concern(rc);

auto coll = client["test_database"]["test_collection"];
mongocxx::read_concern rc;
rc.acknowledge_level(mongocxx::read_concern::level::k_local);
mongocxx::write_concern wc;
wc.acknowledge_level(mongocxx::write_concern::level::k_acknowledged);
coll.read_concern(rc);
coll.write_concern(wc);

auto tag_set_ny = make_document(kvp("dc", "ny"));
auto tag_set_sf = make_document(kvp("dc", "sf"));
mongocxx::read_preference rp;
rp.mode(mongocxx::read_preference::read_mode::k_secondary);
rp.tags(make_array(tag_set_ny, tag_set_sf).view());

mongocxx::uri uri("mongodb://localhost:27017/?localThresholdMS=35");
mongocxx::client client(uri);

API 文档

要学习；了解有关本指南中讨论的任何函数的更多信息，请参阅以下API文档：

• database()

• collection()

• create_collection()

• list_collections()

• list_collection_names()

• Drop()

• read_preference()

• read_concern()

• write_concern()