数据库和集合

Overview

在本指南中，您可以学习如何使用C++驱动程序与MongoDB数据库和集合进行交互。

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

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

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

• Documents: Units that store literal data such as string, numbers, dates, and other embedded documents. For more information about document field types and structure, see the Documents guide in the MongoDB Server manual.

访问数据库

您可以通过对 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");

You can specify collection options, such as maximum size and document validation rules, by passing them inside a BSON document as the second parameter to the create_collection() function. For a full list of optional parameters, see the create command documentation in the MongoDB Server manual.

获取集合列表

您可以通过调用 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();

删除数据库

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

以下示例删除 test_database数据库：

auto db = client["test_database"];
db.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()