一括書き込み操作

項目一覧

Overview

サンプルデータ
書込み (write) 操作を定義する
挿入操作
アップデート操作
置換操作
削除操作
一括操作の実行
一括書き込み操作をカスタマイズする
戻り値
詳細情報
API ドキュメント

Overview

このガイドでは、 Scalaドライバーを使用して、1 回のデータベース呼び出しでデータに複数の変更を加える一括書き込み操作を実行する方法を説明します。

同じタスクでドキュメントの挿入、ドキュメントの更新、ドキュメントの削除が必要になる状況を考えてみましょう。個別の書込みメソッドを使用して各タイプの操作を実行すると、各書込みはデータベースに個別にアクセスします。一括書き込み操作を使用して、アプリケーションがサーバーに行う呼び出しの数を最適化できます。

サンプルデータ

このガイドの例では、restaurants sample_restaurantsAtlasサンプルデータセットのデータベース内のコレクションを使用します。Scalaアプリケーションからこのコレクションにアクセスするには、Atlas クラスターに接続する MongoClient を作成し、database 変数と collection 変数に次の値を割り当てます。

val database: MongoDatabase = mongoClient.getDatabase("sample_restaurants")
val collection: MongoCollection[Document] = database.getCollection("restaurants")

MongoDB Atlasクラスターを無料で作成して、サンプルデータセットをロードする方法については、「Atlas を使い始める」ガイドを参照してください。

書込み (write) 操作を定義する

実行する書込み操作ごとに、汎用のWriteModelクラスから継承する次の操作クラスのいずれかの対応するインスタンスを作成します。

InsertOneModel
UpdateOneModel
UpdateManyModel
ReplaceOneModel
DeleteOneModel
DeleteManyModel

次に、これらのインスタンスのリストをbulkWrite()メソッドに渡します。

次のセクションでは、前述のクラスのインスタンスを作成して使用する方法を示します。「一括操作の実行」セクションでは、モデルのリストをbulkWrite()メソッドに渡して一括操作を実行する方法が説明されています。

挿入操作

挿入操作を実行するには、 InsertOneModelインスタンスを作成し、挿入するドキュメントを指定します。

次の例では、 InsertOneModelのインスタンスを作成しています。

val insertOneModel = InsertOneModel(
    Document("name" -> "Blue Moon Grill",
             "borough" -> "Brooklyn",
             "cuisine" -> "American")
)

複数のドキュメントを挿入するには、ドキュメントごとにInsertOneModelのインスタンスを作成します。

重要

一括操作を実行する場合、 InsertOneModelはコレクション内にすでに存在する_idを含むドキュメントを挿入できません。この状況では、ドライバーはMongoBulkWriteExceptionをスローします。

アップデート操作

ドキュメントを更新するには、 UpdateOneModelのインスタンスを作成し、次の引数を渡します。

コレクション内のドキュメントをマッチングするために使用される基準を指定するクエリフィルター。
実行する更新操作。更新操作の詳細については、 MongoDB Serverマニュアルの「フィールド更新演算子」ガイドを参照してください。

次の例では、 UpdateOneModelのインスタンスを作成しています。

val updateOneFilter = equal("name", "White Horse Tavern")
val updateOneDoc = set("borough", "Queens")
val updateOneModel = UpdateOneModel(updateOneFilter, updateOneDoc)

複数のドキュメントが UpdateOneModelインスタンスで指定されたクエリフィルターに一致する場合、この操作最初の結果が更新されます。次のコードに示すように、ドライバーが更新操作を実行する前に、一致したドキュメントに順序を適用するために、UpdateOptionsインスタンスで並べ替えを指定できます。

val options = UpdateOptions.sort(ascending("name"))

複数のドキュメントを更新するには、 UpdateManyModelのインスタンスを作成し、 UpdateOneModelと同じ引数を渡します。 UpdateManyModelクラスは、クエリフィルターに一致するすべてのドキュメントのアップデートを指定します。

次の例では、 UpdateManyModelのインスタンスを作成しています。

val updateManyFilter = equal("name", "Wendy's")
val updateManyDoc = set("cuisine", "Fast food")
val updateManyModel = UpdateOneModel(updateManyFilter, updateManyDoc)

置換操作

置換操作、指定されたドキュメントのすべてのフィールドと値が削除され、指定した新しいフィールドと値に置き換えられます。置換操作を実行するには、ReplaceOneModel のインスタンスを作成し、次の引数を渡します。

コレクション内のドキュメントをマッチングするために使用される基準を指定するクエリフィルター
挿入する新しいフィールドと値を指定する置換ドキュメント

次の例では、 ReplaceOneModelのインスタンスを作成しています。

val replaceFilter = equal("name", "Cooper Town Diner")
val replaceDoc = Document("name" -> "Smith Town Diner",
                          "borough" -> "Brooklyn",
                          "cuisine" -> "American")
val replaceOneModel = ReplaceOneModel(replaceFilter, replaceDoc)

複数のドキュメントが ReplaceOneModelインスタンスで指定されたクエリフィルターに一致する場合、その操作は最初の結果を置き換えます。次のコードに示すように、ドライバーが置換操作を実行する前に、一致したドキュメントに順序を適用するために、ReplaceOptionsインスタンスで並べ替えを指定できます。

val options = ReplaceOptions.sort(ascending("name"))

Tip

複数のドキュメントの置換

複数のドキュメントを置き換えるには、ドキュメントごとにReplaceOneModelのインスタンスを作成します。

削除操作

ドキュメントを削除するには、 DeleteOneModelのインスタンスを作成し、削除するドキュメントを指定するクエリフィルターを渡します。 DeleteOneModelインスタンスには、クエリフィルターに一致する最初のドキュメントのみを削除するための手順が記載されています。

次の例では、 DeleteOneModelのインスタンスを作成しています。

val deleteOneModel = DeleteOneModel(equal("name", "Morris Park Bake Shop"))

複数のドキュメントを削除するには、 DeleteManyModelのインスタンスを作成し、削除するドキュメントを指定してクエリフィルターを渡します。 DeleteManyModelのインスタンスには、クエリフィルターに一致するすべてのドキュメントを削除するための手順が表示されます。

次の例では、 DeleteManyModelのインスタンスを作成しています。

val deleteManyModel = DeleteManyModel(equal("cuisine", "Experimental"))

一括操作の実行

実行する操作ごとにモデルインスタンスを定義した後、これらのインスタンスのリストをbulkWrite()メソッドに渡します。デフォルトでは、メソッドはモデルのリストで指定された順序で操作を実行します。

次の例では、 bulkWrite()メソッドを使用して複数の書込み操作を実行します。

val insertOneModel = InsertOneModel(
    Document("name" -> "Red's Pizza",
             "borough" -> "Brooklyn",
             "cuisine" -> "Pizzeria")
)
val updateOneModel = UpdateOneModel(equal("name", "Moonlit Tavern"), set("borough", "Queens"))
val deleteManyModel = DeleteManyModel(equal("name", "Crepe"))
val writes = Seq(insertOneModel, updateOneModel, deleteManyModel)
val observable = collection.bulkWrite(writes)
observable.subscribe(
  (result: BulkWriteResult) => println(s"Success: $result"),
  (error: Throwable) => println(s"Error: ${error.getMessage}"),
  () => println("Completed")
)

Success: AcknowledgedBulkWriteResult{insertedCount=1, matchedCount=1, removedCount=1,
modifiedCount=1, upserts=[], inserts=[BulkWriteInsert{index=0, id=BsonObjectId{value=...}}]}
Completed

いずれかの書き込み操作が失敗した場合、 Scalaドライバーは BulkWriteError を発生させ、それ以上の操作を実行しません。 BulkWriteError は、失敗した操作と例外に関する詳細を含む details アイテムを提供します。

注意

ドライバーが一括操作を実行する場合、ターゲットコレクションの書込み保証 (write concern) が使用されます。ドライバーは、実行順序に関係なく、すべての操作を試行した後にすべての書込み保証 (write concern) エラーを報告します。