运行数据库命令

Overview

在本指南中，您可以学习；了解如何使用Scala驾驶员运行数据库命令。您可以使用数据库命令执行各种管理和诊断任务，例如获取服务器统计信息、初始化副本集或运行聚合管道。

val database: MongoDatabase = mongoClient.getDatabase("sample_restaurants")

执行命令

要运行数据库命令，请创建指定该命令的 Document对象，并将其作为参数传递给 runCommand() 方法。此方法返回一个 SingleObservable实例，您可以订阅此可观察量以执行命令并访问权限命令结果。

以下示例对数据库调用 runCommand() 方法来运行hello 命令，该命令会返回有关服务器的信息：

database.runCommand(Document("hello" -> 1))
        .subscribe((doc: Document) => ())

设置读取偏好

runCommand() 方法不会继承您可能在 MongoDatabase实例上设立的读取偏好（read preference）。默认，runCommand() 使用 primary读取偏好（read preference）。

您可以通过将 ReadPreference实例作为参数传递给 runCommand()设立命令执行的读取偏好（read preference），如以下代码所示：

database.runCommand(Document("hello" -> 1), ReadPreference.secondary())
        .subscribe((doc: Document) => ())

响应

runCommand() 方法返回 SingleObservable，其中包含数据库对给定命令的响应。您可以对可观察量调用 subscribe() 方法来运行命令并以文档形式访问权限响应。

原始命令响应文档包含以下字段：

database.runCommand(Document("dbStats" -> 1))
        .subscribe((doc: Document) => println(doc.toJson()),
                  (e: Throwable) => println(s"There was an error: $e"))

{"db": "sample_restaurants", "collections": 4, "views": 0, "objects":
18767, "avgObjSize": 596.1911866574306, "dataSize": 11188720,
"storageSize": 7528448, "totalFreeStorageSize": 0, "numExtents": 0,
"indexes": 6, "indexSize": 1519616, "indexFreeStorageSize": 0,
"fileSize": 0, "nsSizeMB": 0, "ok": 1}

更多信息

有关本指南中概念的更多信息，请参阅MongoDB Server手册中的以下文档：

• db.runCommand()

• 数据库命令

• hello 命令

• dbStats 命令