数据库与集合

概述

本指南介绍了如何使用C++驱动程序与MongoDB数据库和集合进行交互。

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

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

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

• 文档：存储诸如字符串、数字、日期和其他嵌入文档等字面数据的单元。有关文档字段类型和结构的更多信息，请参阅MongoDB服务器手册中的文档指南。

访问数据库

您可以通过调用一个名为mongocxx::client的对象上的database()函数，并传递数据库名称作为参数来访问数据库。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" 的集合。

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

您可以通过将它们作为 BSON 文档的第二个参数传递给 create_collection() 函数来指定集合选项，例如最大大小和文档验证规则。有关所有可选参数的完整列表，请参阅 MongoDB 服务器手册中的 create 命令 文档。

获取集合列表

您可以通过调用 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服务器手册中的以下指南

• 读取偏好

• 读取关注

• 写入关注

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