ビルダ

Overview

このセクションには、利用可能な各ビルダの使用方法に関するガイドと、Java Reactive Streams ドライバー ビルダ クラスが提供するユーティリティを示します。

Java Reactive Streamsドライバーには、CRUD操作と集計APIのビルダクラスが含まれています。静的ユーティリティメソッドを使用すると、クエリやその他のドキュメントをより効率的にビルドできます。

ビルダを使用する理由

ビルダ クラスを使用する場合は、次の機能を活用します。

• 開発中にエラーを検出するための Java コンパイラー

• 検出とコード完了のための IDE

ビルダー クラスにより、Java コンパイラーと IDE は、スペルの間違いのある演算子やパラメータの不足などのエラーを早期に検出できます。代わりに MongoDB shell またはプレーン Java を使用する場合、演算子を文字列として書き込みますが、問題の視覚的な指示は得られません。このため、これらのエラーはコンパイル時ではなく、ランタイムにプッシュされます。

ビルダ クラスを使用すると、演算子をメソッドとして書込むことができ、IDE はコードにエラーがあるかどうかを即座に示すようになります。 開発中に、IDE は使用できるメソッドを表示することも、プレースホルダー パラメーターを使用してコードを完了することもできます。

サンプルシナリオ

次の条件を満たす usersコレクション内のすべてのユーザーにマーケティングメールを送信するとします。

• genderフィールドの値が "female" のユーザー

• ageフィールドの値が 29 より大きいユーザー

また、メールアドレスのみを返すクエリも必要です。

users コレクション内のドキュメントは、次のクラスによってモデル化されます。

record User(
    @BsonId ObjectId id,
    String gender,
    int age,
    String email
)

collection.find({ "gender": "female", "age" : { "$gt": 29 }}, { "_id": 0, "email": 1 })

Bson filter = new Document().append("gender", "female").append("age", new Document().append("$gt", 29));
Bson projection = new Document().append("_id", 0).append("email", 1);
Flux.from(collection.find(filter).projection(projection))
        .doOnNext(doc -> System.out.println(doc.toJson()))
        .blockLast();

import static com.mongodb.client.model.Filters.*;
import static com.mongodb.client.model.Projections.*;

Bson filter = and(eq("gender", "female"), gt("age", 29));
Bson projection = fields(excludeId(), include("email"));
Flux.from(collection.find(filter).projection(projection))
        .doOnNext(doc -> System.out.println(doc.toJson()))
        .blockLast();

利用可能なビルダ

• 集計パイプラインを構築するための集計

• クエリフィルターを構築するためのフィルター

• インデックスキーを作成するためのインデックス

• プロジェクションを構築するためのプロジェクション

• ソート基準を構築するためのソート

• 更新を構築するための更新