集計フレームワーク

前提条件

このガイドのコード例を実行するには、次のコンポーネントを設定する必要があります。

• test.restaurantsドキュメントrestaurants.json アセットGithubの ファイルのドキュメントが入力された コレクション。

• 次のインポート ステートメントは次のとおりです。

import com.mongodb.reactivestreams.client.MongoClients;import com.mongodb.reactivestreams.client.MongoClient;import com.mongodb.reactivestreams.client.MongoCollection;import com.mongodb.reactivestreams.client.MongoDatabase;import com.mongodb.client.model.Aggregates;import com.mongodb.client.model.Accumulators;import com.mongodb.client.model.Projections;import com.mongodb.client.model.Filters;
import org.bson.Document;

MongoDB 配置への接続

まず、MongoDB 配置に接続し、 インスタンスとMongoDatabase MongoCollectionインスタンスを 宣言して定義します。

次のコードは、ポート27017のlocalhostで実行されているスタンドアロンの MongoDB 配置に接続します。 次に、 testデータベースを参照するためのdatabase変数と、 restaurantsコレクションを参照するためのcollection変数を定義します。

MongoClient mongoClient = MongoClients.create();MongoDatabase database = mongoClient.getDatabase("test");MongoCollection<Document> collection = database.getCollection("restaurants");

MongoDB 配置への接続の詳細については、「 MongoDB への接続」チュートリアルを参照してください。

集計の実行

集計を実行するには、集計ステージのリストをMongoCollection.aggregate()メソッドに渡します。 このドライバーは、集計ステージのビルダを含むAggregatesヘルパー クラスを提供します。

この例では、集計パイプラインは次のタスクを実行しています。

• $matchステージを使用して、 categories配列フィールドに要素"Bakery"を含むドキュメントをフィルタリングします。 この例では、 Aggregates.match()を使用して$matchステージを構築しています。

• $groupステージを使用して、一致するドキュメントをstarsフィールドでグループ化し、 starsの個別の値ごとにドキュメントの数を累積します。 この例では、 Aggregates.group()を使用して$groupステージを構築し、 Accumulators.sum()を使用してアキュムレータ式を構築します。 $groupステージ内で使用するアキュムレータ式の場合、ドライバーはAccumulatorsヘルパー クラスを提供します。

collection.aggregate(    Arrays.asList(        Aggregates.match(Filters.eq("categories", "Bakery")),        Aggregates.group("$stars", Accumulators.sum("count", 1))    )).subscribe(new PrintDocumentSubscriber());

collection.aggregate(    Arrays.asList(        Aggregates.project(            Projections.fields(                Projections.excludeId(),                Projections.include("name"),                Projections.computed(                    "firstCategory",                        new Document("$arrayElemAt", Arrays.asList("$categories", 0))                )            )        )    )).subscribe(new PrintDocumentSubscriber());

collection.aggregate(    Arrays.asList(        Aggregates.match(Filters.eq("categories", "Bakery")),        Aggregates.group("$stars", Accumulators.sum("count", 1))))    .explain()    .subscribe(new PrintDocumentSubscriber());

MongoDB Search

次のいずれかのパイプラインステージを含む集計パイプラインを作成して実行することで、MongoDB Search 検索クエリを実行できます。

• $search

• $searchMeta

Java Reactive Streams ドライバーは、Aggregates.search() と Aggregates.searchMeta() を提供しますメソッドを使用して、 MongoDB Search クエリを実行します。

MongoDB 検索する パイプラインの詳細については、Atlas ドキュメントの集計パイプライン ステージの選択を参照してください。

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

Bson searchStageFilters = Aggregates.search(        SearchOperator.compound()                .filter(                        List.of(                                SearchOperator.in(fieldPath("genres"), List.of("Comedy")),                                SearchOperator.phrase(fieldPath("fullplot"), "new york"),                                SearchOperator.numberRange(fieldPath("year")).gtLt(1950, 2000),                                SearchOperator.wildcard(fieldPath("title"), "Love *")                        )));
Bson projection = Aggregates.project(Projections.fields(        Projections.include("title", "year", "genres")));
List<Bson> aggregateStages = List.of(searchStageFilters, projection);
Publisher<Document> publisher = movies.aggregate(aggregateStages);publisher.subscribe(new SubscriberHelpers.PrintDocumentSubscriber());Mono.from(publisher).block();

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

詳細情報

集計ステージの完全なリストについては、MongoDB Serverマニュアルの集計ステージを参照してください。

集計パイプラインの組み立てと例については、 マニュアルの「 集計パイプライン MongoDB Server」を参照してください。

MongoDB操作の説明の詳細については、 マニュアルの「 出力 と クエリプラン の説明MongoDB Server 」を参照してください。