データベースコマンドの実行

Overview

このガイドでは、 Scalaドライバーを使用してデータベースコマンド を実行する方法を学習できます。データベースコマンドを使用して、サーバー統計の取得、レプリカセットを初期化、集計パイプラインの実行中など、さまざまな管理および診断タスクを実行できます。

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

コマンドの実行

データベースコマンド を実行するには、コマンドを指定する Documentオブジェクトを作成し、それをパラメーターとして runCommand() メソッドに渡します。このメソッドは SingleObservableインスタンスを返します。このメソッドをサブスクライブしてコマンドを実行し、コマンド結果にアクセスできます。

次の例では、データベースで runCommand() メソッドを呼び出して hello コマンドを実行し、サーバーに関する情報を返します。

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

読み込み設定（read preference）の設定

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 コマンド