MongoDB Search クエリの実行

Overview

このガイドでは、 Scalaドライバーを使用してコレクションに対してMongoDB Search クエリを実行する方法を学習できます。 MongoDB Search を使用すると、コレクションに対して全文検索を実行できます。 MongoDB Search インデックスは、検索の動作とインデックスを作成するフィールド を指定します。

Scalaドライバーを使用してMongoDB Search インデックスを作成および管理する方法については、「 MongoDB Search とMongoDB ベクトル検索インデックスのガイド 」を参照してください。

MongoDB 検索クエリを実行する

全文検索を実行するには、$searchパイプラインステージで aggregate() メソッドを呼び出します。 Scalaドライバーは、このステージを作成するための Aggregates.search()ヘルパーメソッドを提供します。 search() メソッドには次の引数が必要です。

• SearchOperator 検索するフィールドとテキストを指定するインスタンス

• SearchOptions インスタンス。使用するMongoDB Searchインデックスの名前など、検索をカスタマイズするためのオプションを指定します

次の例では、 titleフィールドでテキスト "Alabama" を検索し、デフォルトで含まれる _idフィールドと、一致するドキュメントの titleフィールドのみをプロジェクションします。

val operator = SearchOperator.text(
  SearchPath.fieldPath("title"), "Alabama")
val options = searchOptions().index("<search index name>")
val pipeline = Seq(
  Aggregates.search(operator, options),
  Aggregates.project(Projections.include("title"))
)
try {
  Await
    .result(collection.aggregate(pipeline).toFuture(), 20.seconds)
    .foreach((doc: Document) => println(doc.toJson()))
} catch {
  case e: Throwable => println(s"There was an error: $e")
}

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

MongoDB 検索する メタデータ

MongoDB Search クエリからメタデータのみを検索結果を返さずに検索するには、Aggregates.searchMeta()ヘルパーメソッドを使用します。次の例では、yearフィールドで 2010 の近くの値を検索するクエリのメタデータを返します。

try {
  Await
    .result(
      collection.aggregate(Seq(
        Aggregates.searchMeta(
          SearchOperator.near(2010, 1, SearchPath.fieldPath("year")))
      )).toFuture(),
      20.seconds
    )
    .foreach((doc: Document) => println(doc.toJson()))
} catch {
  case e: Throwable => println(s"There was an error: $e")
}

{"count": {"lowerBound": 35}}

検索演算子を使用する

Scalaドライバーは次の演算子のヘルパーメソッドを提供します。

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

val searchStage = Aggregates.search(
  SearchOperator.compound()
    .must(
      Iterable(
        SearchOperator.in(fieldPath("genres"), List("Comedy")),
        SearchOperator.phrase(fieldPath("fullplot"), "new york"),
        SearchOperator.numberRange(fieldPath("year")).gtLt(1950, 2000),
        SearchOperator.wildcard("Love *", fieldPath("title")),
      ).asJava
    )
)
val projectStage = Aggregates.project(
  Projections.include("title", "year", "genres"))
try {
  Await
    .result(
      collection.aggregate(Seq(searchStage, projectStage)).toFuture(),
      20.seconds
    )
    .foreach((doc: Document) => println(doc.toJson()))
} catch {
  case e: Throwable => println(s"There was an error: $e")
}

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

詳細情報

MongoDB Search の詳細については、Atlas ドキュメントの「 MongoDB Search の概要 」を参照してください。

API ドキュメント

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

• Aggregate()

• 集計

• SearchOperator

• SearchOptions