クイック スタート

前提条件

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

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

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

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

  import com.mongodb.bulk.BulkWriteResult;
  import com.mongodb.client.model.BulkWriteOptions;
  import com.mongodb.client.model.DeleteOneModel;
  import com.mongodb.client.model.InsertOneModel;
  import com.mongodb.client.model.ReplaceOneModel;
  import com.mongodb.client.model.UpdateOneModel;
  import com.mongodb.client.model.WriteModel;
  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.Document;
  import java.util.ArrayList;
  import java.util.List;
  import static com.mongodb.client.model.Accumulators.*;
  import static com.mongodb.client.model.Aggregates.*;
  import static com.mongodb.client.model.Filters.*;
  import static com.mongodb.client.model.Projections.*;
  import static com.mongodb.client.model.Sorts.*;
  import static com.mongodb.client.model.Updates.*;
  import static java.util.Arrays.asList;
  import static java.util.Collections.singletonList;

接続を行う

実行中の MongoDB 配置に接続するには、 MongoClients.create()メソッドを使用します。

MongoClientインスタンスは、データベースへの接続のプールを表します。 同時操作スレッドを使用する場合でも、必要なインスタンスはMongoClientの 1 つだけです。

データベースへのアクセス

MongoClientインスタンスがMongoDB 配置に接続されたら、MongoClient.getDatabase()メソッドを使用してデータベースにアクセスします。

getDatabase()メソッドにデータベースの名前を指定します。 データベースが存在しない場合は、そのデータベースのデータを最初に保存するときに MongoDB によってデータベースが作成されます。

次の例では、 mydbデータベースにアクセスします。

MongoDatabase database = mongoClient.getDatabase("mydb");

MongoDatabase インスタンスは不変です。

コレクションにアクセスする

MongoDatabaseインスタンスが作成されたら、 getCollection()`メソッドを使用してコレクションにアクセスします。

getCollection()メソッドにコレクションの名前を指定します。 コレクションが存在しない場合、MongoDB は最初にそのコレクションにデータを保存する際にコレクションを作成します。

たとえば、次のステートメントは、 データベース インスタンスを使用して、 mydbデータベース内のtestという名前のコレクションにアクセスします。

MongoCollection<Document> collection = database.getCollection("test");

MongoCollection インスタンスは不変です。

ドキュメントの作成

ドライバーを使用してドキュメントを作成するには、 Documentクラスを使用します。

たとえば、次の JSON ドキュメントについて考えてみます。

{
   "name" : "MongoDB",
   "type" : "database",
   "count" : 1,
   "versions": [ "v3.2", "v3.0", "v2.6" ],
   "info" : { x : 203, y : 102 }
}

ドライバーを使用してドキュメントを作成するには、 フィールドと値を持つDocumentオブジェクトをインスタンス化し、そのappend()メソッドを使用して、ドキュメント オブジェクトに追加のフィールドと値を含めます。 埋め込みドキュメントを指定するには、値を別のDocumentオブジェクトにすることができます。

Document doc = new Document("name", "MongoDB")
    .append("type", "database")
    .append("count", 1)
    .append("versions", Arrays.asList("v3.2", "v3.0", "v2.6"))
    .append("info", new Document("x", 203).append("y", 102));

ドキュメントの挿入

MongoCollectionオブジェクトを取得したら、コレクションにドキュメントを挿入できます。

var subscriber = new OperationSubscriber<InsertOneResult>();
collection.insertOne(doc).subscribe(subscriber);
// Wait for the insertOne operation to complete
subscriber.await();

Publisher<InsertOneResult> publisher = collection.insertOne(doc);

publisher.subscribe(new Subscriber<InsertOneResult>() {
    @Override
    public void onSubscribe(final Subscription s) {
        s.request(1);  // <--- Data requested and the insertion will now occur
    }
    @Override
    public void onNext(final InsertOneResult result) {
        System.out.println("Inserted: " + result);
    }
    @Override
    public void onError(final Throwable t) {
        System.out.println("Failed");
    }
    @Override
    public void onComplete() {
        System.out.println("Completed");
    }
});

{ "i" : value }

List<Document> documents = new ArrayList<Document>();
for (int i = 0; i < 100; i++) {
    documents.add(new Document("i", i));
}

var subscriber = new OperationSubscriber<InsertManyResult>();
collection.insertMany(documents).subscribe(subscriber);
// Wait for the insertMany operation to complete
subscriber.await();

コレクション内のドキュメントをカウント

コレクション内のドキュメント数をカウントするには、コレクションのcountDocuments()メソッドを使用できます。 次のコードでは101が出力され、 insertMany()を使用して挿入された100とinsertOne()を使用して挿入された1が記述されます。

collection.count()
    .subscribe(new PrintSubscriber<Long>("total # of documents: %s"));

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

コレクションをクエリするには、コレクションのfind()メソッドを使用できます。 引数なしで メソッドを呼び出して、コレクション内のすべてのドキュメントをクエリしたり、フィルターを渡してフィルター条件に一致するドキュメントをクエリしたりできます。

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

{
  "_id" : { "$oid" : "551582c558c7b4fbacf16735" },
  "name" : "MongoDB",
  "type" : "database",
  "count" : 1,
  "info" : { "x" : 203, "y" : 102 }
}

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

クエリフィルターの指定

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

collection.find(eq("i", 71)).first().subscribe(new PrintDocumentSubscriber());

{ "_id" : { "$oid" : "5515836e58c7b4fbc756320b" }, "i" : 71 }

collection.find(gt("i", 50)).subscribe(new PrintDocumentSubscriber());

collection.find(and(gt("i", 50), lte("i", 100)))
    .subscribe(new PrintDocumentSubscriber());

Update Documents

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

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

• 更新するドキュメントを決定するためのフィルター オブジェクト。 フィルター オブジェクトの作成を容易にするために、ドライバーはFiltersヘルパー メソッドを提供します。 空のフィルターを指定してコレクション内のすべてのドキュメントを一致させるには、空のDocumentオブジェクトを使用します。

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

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

collection.updateOne(eq("i", 10), set("i", 110))
    .subscribe(new PrintSubscriber<UpdateResult>("Update Result: %s"));

UpdateResult updateResult = collection.updateMany(lt("i", 100), inc("i", 100))
    .subscribe(new PrintSubscriber<UpdateResult>("Update Result: %s"));

Delete Documents

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

フィルター オブジェクトを渡して、削除するドキュメントを決定します。 フィルター オブジェクトの作成を容易にするために、ドライバーはFiltersヘルパー メソッドを提供します。 空のフィルターを指定してコレクション内のすべてのドキュメントを一致させるには、空のDocumentオブジェクトを使用します。

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

collection.deleteOne(eq("i", 110))
    .subscribe(new PrintSubscriber<DeleteResult>("Delete Result: %s"));

DeleteResult deleteResult = collection.deleteMany(gte("i", 100))
    .subscribe(new PrintSubscriber<DeleteResult>("Delete Result: %s"));

インデックスの作成

1 つまたは複数のフィールドにインデックスを作成するには、インデックス仕様ドキュメントをcreateIndex()メソッドに渡します。 インデックスキー仕様ドキュメントには、次のドキュメントをモデル化した各フィールドのインデックスとインデックスのタイプが含まれています。

new Document(<field1>, <type1>).append(<field2>, <type2>) ...

昇順のインデックス タイプを作成するには、 <type>の1を指定します。 降順のインデックス タイプを作成するには、 <type>の-1を指定します。

次の例では、 iフィールドに昇順のインデックスを作成しています。

collection.createIndex(new Document("i", 1))
    .subscribe(new PrintSubscriber<String>("Create Index Result: %s"));

他のインデックス タイプのリストを表示するには、「インデックスの作成」ガイドを参照してください。

詳細情報

POJO で MongoDB を使用する方法を示すその他のチュートリアルについては、「クイック スタート（POJO の例） 」ガイドを参照してください。

その他のチュートリアルについては、「チュートリアル」セクションを参照してください。