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 検索する メタデータ

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

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

• 検索オプション