Atlas Search クエリの実行

サンプル データ

このガイドの例では、Atlasサンプルデータセット の sample_mflixデータベース内の moviesコレクションを使用します。MongoDB Atlasクラスターを無料で作成して、サンプルデータセットをロードする方法については、 「Atlas を使い始める」ガイドを参照してください。集計操作とビルダの詳細については、 集計操作ガイド をご覧ください。

Atlas Search の例

この例では、次のアクションを実行して Atlas Search クエリを実行します。

• Aggregates.search() ビルダ メソッドを使用して $search ステージを構築し、ドライバーに title フィールドに "Alabama" という単語が含まれているドキュメントをクエリするよう指示します。

• Aggregates.project()ビルダ メソッドを使用して $project ステージを構築し、クエリ結果に titleフィールドを含めるようにドライバーに指示します

• パイプラインのステージをaggregate()メソッドに渡し、結果を出力します。

val pipeline: List<Bson> = listOf(
    search(SearchOperator.text(
        fieldPath("title"), "Alabama")),
    project(Projections.include("title"))
)
val results = collection.aggregate(pipeline)
results.forEach { doc ->
    println(doc.toJson())
}

{"_id": {"$oid": "..."}, "title": "Alabama Moon"}
{"_id": {"$oid": "..."}, "title": "Crazy in Alabama"}
{"_id": {"$oid": "..."}, "title": "Sweet Home Alabama"}

パイプライン検索ステージの例

この例を実行する前に、次の定義を持つ Atlas Searchインデックスを moviesコレクションに作成する必要があります。

{
  "mappings": {
    "dynamic": true,
    "fields": {
      "title": {
        "analyzer": "lucene.keyword",
        "type": "string"
      },
      "genres": {
        "normalizer": "lowercase",
        "type": "token"
      }
    }
  }
}

Atlas Search インデックスの作成の詳細については、 インデックスガイドの「検索インデックスの作成」セクションを参照してください。

次のコードでは、次の仕様を持つ $search ステージが作成されます。

• genres 配列に "Comedy" が含まれていることを確認

• fullplotフィールドでフレーズ "new york" を検索します

• 1950 から 2000 までの year 値と一致します

• "Love" というタームで始まる title 値を検索します

val searchStage = Aggregates.search(
    SearchOperator.compound()
        .filter(
            listOf(
                SearchOperator.`in`(fieldPath("genres"), listOf("Comedy")),
                SearchOperator.phrase(fieldPath("fullplot"), "new york"),
                SearchOperator.numberRange(fieldPath("year")).gtLt(1950, 2000),
                SearchOperator.wildcard(fieldPath("title"), "Love *")
            )
        )
)
val projectStage = Aggregates.project(
    Projections.include("title", "year", "genres"))
val pipeline = listOf(searchStage, projectStage)
val results = collection.aggregate(pipeline)
results.forEach { result -> println(result) }

{"_id": ..., "genres": ["Comedy", "Romance"], "title": "Love at First Bite", "year": 1979}
{"_id": ..., "genres": ["Comedy", "Drama"], "title": "Love Affair", "year": 1994}

Atlas Searchヘルパーメソッドの詳細については、ドライバー コアAPIドキュメントの SearchOperator インターフェース参照を参照してください。

API ドキュメント

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

• Aggregate()

• Aggregates.search()

• Aggregates.searchMeta()

• 集計。プロジェクト（）

• SearchOperator