データベースとコレクション

Overview

このガイドでは、 Scalaドライバーを使用してMongoDB のデータベースとコレクションを操作する方法を学習できます。

MongoDB では、データは次のレベルの階層に整理されています。

• データベース: コレクションを保存するMongoDBデプロイの最上位のデータ構造。

• コレクション: MongoDBドキュメントのグループ。 関係データベースのテーブルに類似しています。

• ドキュメント: string 、数値、日付などのリテラル データを保存するユニット。およびその他の埋め込みドキュメントを保存するユニット。 ドキュメントフィールドのタイプと構造の詳細については、 MongoDB Serverマニュアルのドキュメントガイドを参照してください。

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

データベースにアクセスするには、MongoClientインスタンスで getDatabase() メソッドを呼び出します。

次の例えでは"test_database"という名前のデータベースにアクセスします。

val database = mongoClient.getDatabase("test_database")

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

コレクションにアクセスするには、 MongoDatabaseインスタンスで getCollection() メソッドを呼び出します。

次の例では、"test_collection" という名前のコレクションにアクセスします。

val collection = database.getCollection("test_collection")

コレクションを作成する

データベースにコレクションを明示的に作成するには、MongoDatabaseインスタンスの createCollection() メソッドを使用します。

次の例では、 "example_collection"という名前のコレクションを作成します。

val createObservable = database.createCollection("example_collection")
Await.result(createObservable.toFuture(), Duration(10, TimeUnit.SECONDS))

CreateCollectionOptionsインスタンスをcreateCollection() メソッドに渡すことで、最大サイズやドキュメント検証ルールなどのコレクションオプションを指定できます。オプションのパラメーターの完全なリストについては、 MongoDB Serverマニュアルの create コマンドのドキュメント を参照してください。

コレクションの一覧を取得する

データベース内のコレクションのリストをクエリするには、 MongoDatabaseインスタンスの listCollections() メソッドを呼び出します。

次の例では、データベース内のすべてのコレクションを一覧表示します。

val results = Await.result(database.listCollections().toFuture(), Duration(10, TimeUnit.SECONDS))
results.foreach(println)

Iterable((name,BsonString{value='test_collection'}), (type,BsonString{value='collection'}), ... )
Iterable((name,BsonString{value='example_collection'}), (type,BsonString{value='collection'}), ... )

データベース内のコレクションの名前のみをクエリするには、次のようにlistCollectionNames()メソッドを呼び出します。

val results = Await.result(database.listCollectionNames().toFuture(), Duration(10, TimeUnit.SECONDS))
results.foreach(println)

test_collection
example_collection

コレクションの削除

コレクションを削除するには、MongoCollectionインスタンスで drop() メソッドを呼び出します。

次の例では、 "test_collection"コレクションを削除しています。

val deleteObservable = database.getCollection("test_collection").drop()
Await.result(deleteObservable.toFuture(), Duration(10, TimeUnit.SECONDS))

読み取り操作と書込み操作の設定

読み込み設定（ read preference ） を設定することで、ドライバーが読み取り操作をルーティングする方法を制御できます。 また、読み取り保証 ( read concern ) と書込み保証 ( write concern ) を設定して、ドライバーがレプリカセットでの読み取りおよび書込み (write) 操作の確認を待機する方法のオプションも制御できます。

デフォルトでは 、データベースは MongoClientインスタンスからこれらの設定を継承し、コレクションはデータベースからこれらを継承します。ただし、withReadPreference() メソッドを使用してデータベース上のこれらの設定を変更することもできます。

次の例では、データベースにアクセスし、データベースの読み込み設定 (read preference)を secondary として指定しています。

val databaseWithReadPrefs =
    mongoClient.getDatabase("test_database").withReadPreference(ReadPreference.secondary())

また、 withReadPreference() メソッドを使用して、コレクションの読み取りおよび書込み設定を変更することもできます。次の例では、コレクションの読み込み設定 (read preference)を secondary として指定しながらコレクションにアクセスする方法を示しています。

val collectionWithReadPrefs =
    database.getCollection("test_collection").withReadPreference(ReadPreference.secondary())

読み取りおよび書込み設定の詳細については、MongoDB Server マニュアルの次のガイドを参照してください。

• 読み込み設定 (read preference)

• 読み取り保証（read concern）

• 書込み保証 (write concern)

val tag1 = new Tag("dc", "ny")
val tag2 = new Tag("dc", "sf")
val tagSet = new TagSet(List(tag1, tag2).asJava)
val connectionString = ConnectionString("<connection string URI>")
val readPreference = ReadPreference.primaryPreferred(tagSet)
val mongoClientSettings = MongoClientSettings.builder()
  .applyConnectionString(connectionString)
  .readPreference(readPreference)
  .build()
val clientWithTags = MongoClient(mongoClientSettings)

val connectionString = ConnectionString("mongodb://localhost:27017")
val mongoClientSettings = MongoClientSettings.builder()
  .applyConnectionString(connectionString)
  .applyToClusterSettings(builder => builder.localThreshold(35, TimeUnit.MILLISECONDS))
  .build()
val client = MongoClient(mongoClientSettings)

API ドキュメント

このガイドで説明した型やメソッドの詳細については、次の API ドキュメントを参照してください。

• MongoClient

• MongoDatabase

• MongoCollection

• CreateCollectionOptions

• ClusterSettings

• MongoClientSettings