Retrieve Data

Overview

このガイドでは、MongoDB database からデータを取得する方法を学びます。 データを検索するには、 読み取り操作 を使用します。

読み取り操作では、次の操作を実行できます。

• 検索操作を使用してコレクションからドキュメントのサブセットを取得

• 集計操作を使用して、コレクションから取得されたドキュメントを変換するの実行

• 変更ストリームを使用してデータベースへのリアルタイム変更をモニタリング

{ "_id": 1, "color": "purple", "qty": 10 }
{ "_id": 2, "color": "green", "qty": 8 }
{ "_id": 3, "color": "purple", "qty": 4 }
{ "_id": 4, "color": "green", "qty": 11 }

data class PaintOrder(
    @BsonId val id: Int,
    val qty: Int,
    val color: String
)

find 操作

検索操作を使用して、MongoDB 内の既存のデータのサブセットを取得します。 取得するドキュメント、取得する順序、取得する数など、返すデータを指定できます。

検索操作を実行するには、 MongoCollectionのインスタンスでfind()メソッドを呼び出します。 このメソッドは、指定したクエリフィルターに一致するドキュメントをコレクションから検索します。 クエリを指定する方法の詳細については、「 クエリの指定」ガイドを参照してください。

val filter = Filters.and(Filters.gt("qty", 3), Filters.lt("qty", 9))
val resultsFlow = collection.find(filter)
resultsFlow.collect { println(it) }

PaintOrder(id=2, qty=8, color=green)
PaintOrder(id=3, qty=4, color=purple)

集計操作

集計操作を使用して、 集計パイプライン のステージを実行します。 集計パイプラインは、集計結果を生成する複数段階の変換です。

集計操作を実行するには、 MongoCollectionのインスタンスでaggregate()メソッドを呼び出します。 このメソッドは、順番に実行される集計式を受け入れます。 集計を実行するために、ドキュメントを一致させる方法、フィールドの名前を変更する方法、値をグループ化する方法を指定する 集計ステージ を定義できます。 詳細については、集計ガイド を参照してください。

data class AggregationResult(@BsonId val id: String, val qty: Int)
val filter = Filters.empty()
val pipeline = listOf(
    Aggregates.match(filter),
    Aggregates.group(
        "\$color",
        Accumulators.sum("qty", "\$qty")
    ),
    Aggregates.sort(Sorts.descending("qty"))
)
val resultsFlow = collection.aggregate<AggregationResult>(pipeline)
resultsFlow.collect { println(it) }

PaintOrder(id=2, qty=8, color=green)
PaintOrder(id=3, qty=4, color=purple)