ドキュメントをカウント

サンプル データ

このガイドの例では、companies sample_trainingAtlasサンプルデータセット の データベースの コレクションを使用します。 Scalaアプリケーションからこのコレクションにアクセスするには、AtlasMongoClient クラスターに接続する を作成し、 変数と 変数に次の値を割り当てます。databasecollection

val database: MongoDatabase = mongoClient.getDatabase("sample_training")
val collection: MongoCollection[Document] = database.getCollection("companies")

MongoDB Atlasクラスターを無料で作成して、サンプルデータセットをロードする方法については、 「Atlas を使い始める」ガイドを参照してください。

すべてのドキュメントをカウントする

コレクション内のすべてのドキュメントの数を返すには、次の例に示すように、パラメータを渡しずに countDocuments() メソッドを呼び出します。

collection.countDocuments()
    .subscribe((count: Long) => println(s"Number of documents: $count"),
              (e: Throwable) => println(s"There was an error: $e"))

Number of documents: 9500

特定のドキュメントのカウント

特定の検索条件に一致するドキュメントの数を返すには、クエリフィルターをcountDocuments()メソッドに渡します。

次の例では、 founded_yearフィールドの値が2010であるドキュメントの数をカウントします。

collection.countDocuments(equal("founded_year", 2010))
    .subscribe((count: Long) => println(s"Companies founded in 2010: $count"),
              (e: Throwable) => println(s"There was an error: $e"))

Number of companies founded in 2010: 33

カウント動作をカスタマイズする

CountOptionsインスタンスをパラメータとして渡すことで、countDocuments() メソッドの動作を変更できます。次の表は、 カウント操作のオプションを設定するために使用できる CountOptionsクラスの一部のメンバー関数について説明しています。

次の例では、 countDocuments()メソッドを使用して、 number_of_employeesフィールドの値が50であるドキュメントの数をカウントし、最大100の結果をカウントするように操作に指示します。

val countOptions = CountOptions().limit(100)
collection.countDocuments(equal("number_of_employees", 50), countOptions)
    .subscribe((count: Long) => println(s"Companies with 50 employees: $count"),
              (e: Throwable) => println(s"There was an error: $e"))

Number of companies with 50 employees: 100

推定カウント動作をカスタマイズ

EstimatedDocumentCountOptionsインスタンスをパラメータとして渡すことで、estimatedDocumentCount() メソッドの動作を変更できます。 EstimatedDocumentCountOptionsクラスにはmaxTime() メンバー関数が含まれています。このメンバー関数を使用すると、EstimatedDocumentCountOptionsオブジェクトを構成し、カウント操作を実行できる最大時間を設定できます。

次の例では、 estimatedDocumentCount() メソッドを使用してコレクション内のドキュメント数の推定値を返し、操作のタイムアウトを 3 秒に設定します。

val estimatedOptions = EstimatedDocumentCountOptions().maxTime(3, SECONDS)
collection.estimatedDocumentCount(estimatedOptions)
    .subscribe((count: Long) => println(s"Estimated number of documents: $count"),
              (e: Throwable) => println(s"There was an error: $e"))

Estimated number of documents: 9500