Retrieve Data

Overview

このガイドでは、Kotlinドライバーを使用してMongoDBデータベースからデータを取得する方法を学びます。読み取り操作を実行して、MongoDBからデータを取得できます。

読み取り操作を使用すると、次のタスクを実行できます。

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

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

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

{ "_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 内の既存のデータのサブセットを取得します。 取得するドキュメント、取得する順序、取得する数など、返すデータを指定できます。

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

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)

集計操作

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

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

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=19, color=green)
PaintOrder(id=3, qty=14, color=purple)