Retrieve Data

一致するドキュメントのすべての検索

条件に一致するすべてのドキュメントを検索するには、 find()メソッドを使用します。 このメソッドは、クエリフィルターをパラメーターとして受け取ります。 クエリフィルターは、一致するドキュメントの基準を形成するフィールドと値で構成されます。

メソッドは、フィルタ条件に一致するドキュメントを検索するために反復処理できるCursorタイプを返します。

このメソッドを使用してデータを検索する例については、 find() の例 を参照してください。

クエリの指定の詳細については、「 クエリの指定」ガイドを参照してください。

1 つのドキュメントの検索

条件に一致する最初のドキュメントを検索するには、 find_one()メソッドを使用します。 このメソッドは、クエリフィルターをパラメーターとして受け取ります。 クエリフィルターは、一致するドキュメントの基準を形成するフィールドと値で構成されます。

ドキュメントがフィルタ条件に一致する場合、メソッドはSomeの値を持つResult<Option<T>>型を返します。 フィルタ条件に一致するドキュメントがない場合、 find_one()はNoneの値を持つResult<Option<T>>型を返します。

このメソッドを使用してデータを検索する例については、 find_one() の例 を参照してください。

検索動作の変更

FindOptionsインスタンスをパラメータとして渡すことでfind()の動作を変更できます。また、 FindOneOptionsインスタンスを渡すことでfind_one()の動作を変更できます。

各設定でデフォルト値を使用するには、オプション パラメータとして値Noneを指定します。

次の表では、 FindOptionsとFindOneOptionsで指定できる一般的に使用される設定について説明しています。

各タイプに指定できる設定の完全なリストについては、 FindOptions と FindOneOptions のAPIドキュメントを参照してください。

例

次のセクションには、 find()メソッドとfindOne()メソッドを使用してフィルター条件に一致するサンプル ドキュメントを取得する例が含まれています。

let opts = FindOptions::builder()
    .sort(doc! { "unit_price": -1 })
    .build();
let mut cursor = my_coll.find(
    doc! { "$and": vec!
        [
            doc! { "unit_price": doc! { "$lt": 12.00 } },
            doc! { "category": doc! { "$ne": "kitchen" } }
        ] },
    opts
).await?;
while let Some(result) = cursor.try_next().await? {
    println!("{:?}", result);
};

Inventory { item: "watering can", category: "garden", unit_price: 11.99 }
Inventory { item: "candle", category: "decor", unit_price: 2.89 }

let opts = FindOneOptions::builder().skip(2).build();
let result = my_coll.find_one(
    doc! { "unit_price":
        doc! { "$lte": 20.00 } },
    opts
).await?;
println!("{:#?}", result);

Some(
    Inventory {
        item: "watering can",
        category: "garden",
        unit_price: 11.99,
    },
)

ドキュメント データの集計

aggregate()メソッドは、集計パイプラインをパラメーターとして受け取ります。 集計パイプラインには、データの変換方法を指定する 1 つ以上のステージが含まれます。 ステージには、集計演算子（プレフィックスとして$ ）と、その演算子に必要なパラメータが含まれます。

集計の詳細と集計の例については、集計ガイドを参照してください。

このメソッドでは、 Cursorタイプの結果ドキュメントが返されます。 集計パイプラインに$matchステージが含まれていない場合、パイプラインはコレクション内のすべてのドキュメントを処理します。

集計動作を変更する

任意のパラメータとしてAggregateOptionsインスタンスを渡すことで、 aggregate()の動作を変更できます。

各設定でデフォルト値を使用するには、オプション パラメータとして値Noneを指定します。

次の表では、 AggregateOptionsで指定できる一般的に使用される設定について説明しています。

設定の完全なリストについては、AggregateOptions のAPIドキュメントを参照してください。

例

この例では、次のステージを含むパイプラインでaggregate()メソッドを呼び出す方法を示しています。

• ドキュメントをcategoryフィールドでグループ化し、 categoryによりunit_priceフィールドの平均を計算する$groupステージ

• $sortステージから昇順のavg_priceへ

let pipeline = vec![
    doc! { "$group": doc! { "_id" : doc! {"category": "$category"} ,
                            "avg_price" : doc! { "$avg" : "$unit_price" } } },
    doc! { "$sort": { "_id.avg_price" : 1 } }
];
let mut cursor = my_coll.aggregate(pipeline, None).await?;
while let Some(result) = cursor.try_next().await? {
    println!("{:?}", result);
};

Document({"_id": Document({"category": String("decor")}), "avg_price": Double(2.890000104904175)})
Document({"_id": Document({"category": String("kitchen")}), "avg_price": Double(20.840000867843628)})
Document({"_id": Document({"category": String("garden")}), "avg_price": Double(11.989999771118164)})

API ドキュメント

このガイドで言及されているメソッドとタイプの詳細については、次のAPIドキュメントを参照してください。

• find_one()

• find()

• FindOptions

• FindOneOptions

• Cursor

• Aggregate()

• AggregateOptions