POJO CRUD 操作例

前提条件

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

• MongoDB のデフォルトポートで実行されている MongoDB サーバー（ 27017 ）

• プロジェクトにインストールされたドライバーの依存関係

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

  import com.mongodb.client.result.InsertOneResult;
  import com.mongodb.client.result.InsertManyResult;
  import com.mongodb.client.result.DeleteResult;
  import com.mongodb.client.result.UpdateResult;
  import com.mongodb.reactivestreams.client.MongoClient;
  import com.mongodb.reactivestreams.client.MongoClients;
  import com.mongodb.reactivestreams.client.MongoCollection;
  import com.mongodb.reactivestreams.client.MongoDatabase;
  import org.bson.codecs.configuration.CodecRegistry;
  import org.bson.codecs.pojo.PojoCodecProvider;
  import java.util.List;
  import static com.mongodb.client.model.Filters.*;
  import static com.mongodb.client.model.Updates.*;
  import static java.util.Arrays.asList;
  import static org.bson.codecs.configuration.CodecRegistries.fromProviders;
  import static org.bson.codecs.configuration.CodecRegistries.fromRegistries;

• POJO クラスの定義。 Githubのドライバーソースリポジトリから Person POJO と Address POJO の完全なコードをコピーします。

  • パーソナルクラス

  • アドレス クラス

カスタム CodecRegistry の作成

ドライバーで POJO を使用する前に、POJO の BSON との間の変換を処理するコーデックを含むようにCodecRegistryを構成する必要があります。 その最も簡単な方法は、 PojoCodecProvider.builder()メソッドを使用してCodecProviderを作成および構成することです。

次の例では、デフォルトのコーデック レジストリと POJO Codecインスタンスを自動的に作成するように構成されたPojoCodecProviderを組み合わせています。

CodecRegistry pojoCodecRegistry = fromRegistries(
    MongoClientSettings.getDefaultCodecRegistry(),
    fromProviders(PojoCodecProvider.builder().automatic(true).build())
);

MongoDB への POJO の挿入

コーデック レジストリは自動的に不明なクラス用の POJO Codecを作成しようとします。 そのため、追加構成なしで POJO をそのまま使用できるようになります。

MongoDB に POJO を挿入する前に、POJO クラスで構成されたMongoCollectionインスタンスを作成します。

MongoCollection<Person> collection = database.getCollection("people", Person.class);

Person ada = new Person("Ada Byron", 20, new Address("St James Square", "London", "W1"));
collection.insertOne(ada).subscribe(new OperationSubscriber<InsertOneResult>());

List<Person> people = asList(
    new Person("Charles Babbage", 45, new Address("5 Devonshire Street", "London", "W11")),
    new Person("Alan Turing", 28, new Address("Bletchley Hall", "Bletchley Park", "MK12")),
    new Person("Timothy Berners-Lee", 61, new Address("Colehill", "Wimborne", null))
);
collection.insertMany(people).subscribe(new OperationSubscriber<InsertManyResult>());

コレクションをクエリする

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

次の例では、 コレクション内のすべてのPersonインスタンスを出力します。

collection.find().subscribe(new PrintToStringSubscriber<>());

Person{id='...', name='Ada Byron', age=20, address=Address{street='St James Square', city='London', zip='W1'}}
Person{id='...', name='Charles Babbage', age=45, address=Address{street='5 Devonshire Street', city='London', zip='W11'}}
Person{id='...', name='Alan Turing', age=28, address=Address{street='Bletchley Hall', city='Bletchley Park', zip='MK12'}}
Person{id='...', name='Timothy Berners-Lee', age=61, address=Address{street='Colehill', city='Wimborne', zip='null'}}

クエリフィルターの指定

特定の条件に一致するPersonインスタンスをクエリするには、フィルター オブジェクトをfind()メソッドに渡します。 フィルター オブジェクトの作成を容易にするために、ドライバーはFiltersヘルパー メソッドを提供します。

collection.find(eq("address.city", "Wimborne"))
    .first()
    .subscribe(new PrintToStringSubscriber<>());

Person{id='591dbc2550852fa685b3ad1a', name='Timothy Berners-Lee', age=61, address=Address{street='Colehill', city='Wimborne', zip='null'}}

collection.find(gt("age", 30)).subscribe(new PrintToStringSubscriber<>());

Update Documents

コレクション内のドキュメントを更新するには、コレクションのupdateOne() メソッドとupdateMany() メソッドを使用できます。

次のパラメーターをメソッドに渡します。

• 更新するドキュメントを決定するためのフィルター オブジェクト。 空のフィルターを指定してすべてのPersonインスタンスを一致させるには、空のDocumentオブジェクトを使用します。

• 変更を指定するドキュメントを更新します。 使用可能な演算子のリストを表示するには、サーバー マニュアルの「更新演算子 」を参照してください。

更新メソッドは、更新によって変更されたドキュメントの数など、操作に関する情報を提供するUpdateResultタイプを返します。

collection.updateOne(
    eq("name", "Ada Byron"),
    combine(set("age", 23), set("name", "Ada Lovelace"))
).subscribe(new OperationSubscriber<>());

collection.updateMany(not(eq("zip", null)), set("zip", null))
         .subscribe(new OperationSubscriber<>());

collection.replaceOne(eq("name", "Ada Lovelace"), ada)
    .subscribe(new OperationSubscriber<>());

Delete Documents

コレクションからドキュメントを削除するには、コレクションのdeleteOne() メソッドとdeleteMany() メソッドを使用できます。

削除するドキュメントに一致するようにフィルター オブジェクトを渡します。 空のフィルターを指定するには、空のDocumentオブジェクトを使用します。

削除メソッドでは、削除されたドキュメント数など操作に関する情報を提供するDeleteResultタイプが返されます。

collection.deleteOne(eq("address.city", "Wimborne"))
    .subscribe(new OperationSubscriber<>());

collection.deleteMany(eq("address.city", "London"))
    .subscribe(new OperationSubscriber<>());