読み取り操作

前提条件

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

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

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

import com.mongodb.*;
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.Projections;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.Sorts;
import java.util.Arrays;
import org.bson.Document;
import static com.mongodb.client.model.Filters.*;
import static com.mongodb.client.model.Projections.*;

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 への接続」チュートリアルを参照してください。

コレクションのクエリ

コレクションをクエリするには、コレクションのfind()メソッドを使用できます。

引数なしで メソッドを呼び出して、コレクション内のすべてのドキュメントをクエリできます。

collection.find().subscribe(new PrintDocumentSubscriber());

または、フィルターを渡して、フィルター条件に一致するドキュメントをクエリすることもできます。

collection.find(eq("name", "456 Cookies Shop"))
    .subscribe(new PrintDocumentSubscriber());

クエリフィルター

特定の条件に一致するドキュメントをクエリするには、フィルター ドキュメントをfind()メソッドに渡します。

collection.find(new Document()).subscribe(new PrintDocumentSubscriber());

collection.find().subscribe(new PrintDocumentSubscriber());

collection.find(
    new Document("stars", new Document("$gte", 2)
        .append("$lt", 5))
        .append("categories", "Bakery")).subscribe(new PrintDocumentSubscriber());

collection.find(and(gte("stars", 2), lt("stars", 5), eq("categories", "Bakery")))
    .subscribe(new PrintDocumentSubscriber());

FindPublisher

find()メソッドはFindPublisherインターフェースのインスタンスを返します。 インターフェースは、 find()メソッドに連結して、 sort()やprojection()などのクエリの出力や動作を変更したり、 subscribe()メソッドを介して結果を反復処理したりするためのさまざまなメソッドを提供します。

collection.find(and(gte("stars", 2), lt("stars", 5), eq("categories", "Bakery")))
    .projection(new Document("name", 1)
        .append("stars", 1)
        .append("categories",1)
        .append("_id", 0))
    .subscribe(new PrintDocumentSubscriber());

collection.find(and(gte("stars", 2), lt("stars", 5), eq("categories", "Bakery")))
    .projection(fields(include("name", "stars", "categories"), excludeId()))
    .subscribe(new PrintDocumentSubscriber());

collection.find(and(gte("stars", 2), lt("stars", 5), eq("categories", "Bakery")))
    .sort(Sorts.ascending("name"))
    .subscribe(new PrintDocumentSubscriber());

collection.find(and(gte("stars", 2), lt("stars", 5), eq("categories", "Bakery")))
    .sort(Sorts.ascending("name"))
    .projection(fields(include("name", "stars", "categories"), excludeId()))
    .subscribe(new PrintDocumentSubscriber());

collection.find(and(gte("stars", 2), lt("stars", 5), eq("categories", "Bakery")))
    .explain()
    .subscribe(new PrintDocumentSubscriber());

読み込み設定 (read preference)

レプリカセットまたはシャーディングされたクラスターに対する読み取り操作の場合、次のレベルで読み込み設定（read preference）を構成できます。

• 次の方法でMongoClientで実行されます。

  • MongoClientSettingsインスタンスを作成する方法

    MongoClient mongoClient = MongoClients.create(MongoClientSettings.builder()
        .applyConnectionString(new ConnectionString("mongodb://host1,host2"))
        .readPreference(ReadPreference.secondary())
        .build());

  • ConnectionStringインスタンスを作成する方法

    MongoClient mongoClient = MongoClients.create("mongodb://host1:27017,host2:27017/?readPreference=secondary");

• MongoDatabaseでwithReadPreference()メソッドを使用することで、

  MongoDatabase database = mongoClient.getDatabase("test")
      .withReadPreference(ReadPreference.secondary());

• MongoCollectionでwithReadPreference()メソッドを使用することで、

  MongoCollection<Document> collection = database.getCollection("restaurants")
      .withReadPreference(ReadPreference.secondary());

MongoDatabase とMongoCollectionインスタンスは不変です。 既存のMongoDatabaseまたはMongoCollectionインスタンスでwithReadPreference()を呼び出すと、新しい インスタンスが返されますが、メソッドが呼び出されるインスタンスには影響しません。

次の例では、 collectionWithReadPrefインスタンスの読み込み設定（read preference）はprimaryPreferredですが、 collectionの読み込み設定（read preference）は影響を受けません。

MongoCollection<Document> collectionWithReadPref = collection.withReadPreference(ReadPreference.primaryPreferred());

読み取り保証（read concern）

レプリカセットまたはシャーディングされたクラスターに対する読み取り操作の場合、アプリケーションは次のレベルで読み取り保証を構成できます。

• 次の方法でMongoClientで実行されます。

  • MongoClientSettingsインスタンスを作成する方法

    MongoClient mongoClient = MongoClients.create(MongoClientSettings.builder()
        .applyConnectionString(new ConnectionString("mongodb://host1,host2"))
        .readConcern(ReadConcern.MAJORITY)
        .build());

  • ConnectionStringインスタンスを作成する方法

    MongoClient mongoClient = MongoClients.create("mongodb://host1:27017,host2:27017/?readConcernLevel=majority");

• MongoDatabaseでwithReadConcern()メソッドを使用することで、

  MongoDatabase database = mongoClient.getDatabase("test")
      .withReadConcern(ReadConcern.MAJORITY);

• MongoCollectionでwithReadConcern()メソッドを使用することで、

  MongoCollection<Document> collection = database.getCollection("restaurants")
      .withReadConcern(ReadConcern.MAJORITY);

MongoDatabase とMongoCollectionインスタンスは不変です。 既存のMongoDatabaseまたはMongoCollectionインスタンスでwithReadConcern()を呼び出すと、新しい インスタンスが返されますが、メソッドが呼び出されるインスタンスには影響しません。

次の例では、 collWithReadConcernインスタンスにはAVAILABLEの読み取り保証がありますが、 collectionの読み取り保証には影響がありません。

MongoCollection<Document> collWithReadConcern = collection.withReadConcern(ReadConcern.AVAILABLE);

MongoClientSettings 、 MongoDatabase 、またはMongoCollectionインスタンスをビルドすると、読み取り保証、読み込み設定（read preference）、書込み保証（write concern）の組み合わせを含めることができます。

たとえば、次のコードでは、コレクション レベルで 3 つすべてを設定します。

collection = database.getCollection("restaurants")
    .withReadPreference(ReadPreference.primary())
    .withReadConcern(ReadConcern.MAJORITY)
    .withWriteConcern(WriteConcern.MAJORITY);