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

Overview

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

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

• データベース: MongoDB インスタンス内の最上位のデータ組織。

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

• ドキュメント: string 、数値、日付などのリテラル データ、およびその他の埋め込みドキュメントが含まれます。

ドキュメント フィールドのタイプと構造の詳細については、MongoDB Server マニュアルのドキュメントガイド を参照してください。

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

目的のデータベース名で Mongo::Clientインスタンスを作成し、データベースにアクセスします。

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

client = Mongo::Client.new(['127.0.0.1:27017'], database: 'test_database')
database = client.database

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

データベースのインスタンスで [] メソッドを使用してコレクションにアクセスします。

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

database = client.database
collection = database['test_collection']

コレクションを作成する

MongoDB用のRubyドライバーには直接的な create_collection メソッドはありませんが、create メソッドを使用して特定のオプションを持つコレクションを作成できます。

次の例では、具体的なオプションを使用して sample_collection というコレクションを作成します。

database = client.database
database[:example_collection].create(capped: true, size: 1024)

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

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

collections メソッドを呼び出すと、データベース内のコレクションのリストをクエリできます。このメソッドは、データベース内のコレクションオブジェクトの配列を返します。

次の例では、collections メソッドを呼び出し、配列を反復処理して結果を出力します。

database = client.database
collection_list = database.collections
collection_list.each do |collection|
  puts collection.name
end

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

database = client.database
collection_names = database.collection_names
collection_names.each do |name|
  puts name
end

コレクションの削除

データベースからコレクションを削除するには、 dropメソッドを使用します。

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

database = client.database
collection = database[:test_collection]
collection.drop

データベースの削除

MongoDB配置からデータベースを削除するには、データベースインスタンスで drop メソッドを使用します。

次の例では、test_databaseデータベースを削除しています。

client = Mongo::Client.new(['127.0.0.1:27017'], database: 'test_database')
database = client.database
database.drop

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

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

デフォルトでは、データベースはMongo::Clientインスタンスからこれらの設定を継承し、コレクションは データベースからこれらを継承します。 ただし、次のいずれかの方法を使用して、データベースまたはコレクションのこれらの設定を変更できます。

• database.with:データベースを取得し、新しい読み込み設定 (read preference)、読み取り保証 (read concern)、書込み保証 (write concern)を適用します。

• collection.with:コレクションを取得し、新しい読み込み設定 (read preference)、読み取り保証 (read concern)、書込み保証 (write concern)を適用します。

上記のメソッドで読み取りまたは書込み設定を変更するには、 メソッドを呼び出して、新しい読み込み設定 (read preference)、読み取り保証 (read concern)、または書込み保証 (write concern)を渡します。

次の例では、database.with メソッドを使用して、test-database というデータベースの読み込み設定 (read preference)、読み取り保証 (read concern) ） 、 書込み設定（write preference） を変更する方法を示しています。

database_with_settings = client.use('test_database').with(
  read: { mode: :secondary },
  read_concern: { level: :local },
  write: { w: :majority }
)

次の例は、コレクションの読み込み設定 (read preference)、読み取り保証 (read concern)、書込み保証 (write concern)を変更する方法を示しています。

collection_with_settings = client[:test_collection].with(
  read: { mode: :secondary },
  read_concern: { level: :local },
  write: { w: :majority }
)

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

• 読み込み設定 (read preference)

• 読み取り保証（read concern）

• 書込み保証 (write concern)

client = Mongo::Client.new(['IP_ADDRESS_001:27017'], database: 'test', read: {
    mode: :secondary,
    tag_sets: [{'dc' => 'ny'}, {'dc' => 'sf'}]
  })
 
  database = client.database
 
  collection = database[:example_collection]

client = Mongo::Client.new(
    ['IP_ADDRESS_001:27017'],
    database: 'test_database',
    read: { mode: :secondary_preferred },
    local_threshold: 35
  )
  database = client.database
  collection = database[:example_collection]
  result = collection.find({}).first
  puts result

API ドキュメント

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

• collections

• collection_names

• コマンド

• データベースの削除

• コレクションの削除

• と共に