MongoDBで1つのクエリを使って複数のドキュメントを更新する方法

MongoDBでは、initializeUnorderedBulkOp() を使ったバルク操作を利用することで、1回のリクエストで複数のドキュメント（行）をまとめて更新できます。通常の updateOne() や updateMany() は単一の更新条件しか指定できませんが、バルク操作なら異なる条件・異なる更新内容を持つ複数の更新処理をキューに登録し、一括実行することが可能です。

サンプルコレクションの作成

まず、insertOne() メソッドを使ってドキュメントを含むコレクションを作成します。

> db.upDateMultipleRowsDemo.insertOne({"CustomerName":"John","CustomerPurchaseAmount":500});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5cd6ceb06d78f205348bc626")
}
> db.upDateMultipleRowsDemo.insertOne({"CustomerName":"Chris","CustomerPurchaseAmount":700});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5cd6ceb26d78f205348bc627")
}
> db.upDateMultipleRowsDemo.insertOne({"CustomerName":"David","CustomerPurchaseAmount":50});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5cd6ceb36d78f205348bc628")
}
> db.upDateMultipleRowsDemo.insertOne({"CustomerName":"Larry","CustomerPurchaseAmount":1900});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5cd6ceb46d78f205348bc629")
}

登録済みドキュメントの確認

次に、find() メソッドを使ってコレクション内のすべてのドキュメントを表示します。

> db.upDateMultipleRowsDemo.find().pretty();

上記のクエリを実行すると、次のような出力が得られます。

{
   "_id" : ObjectId("5cd6ceb06d78f205348bc626"),
   "CustomerName" : "John",
   "CustomerPurchaseAmount" : 500
}
{
   "_id" : ObjectId("5cd6ceb26d78f205348bc627"),
   "CustomerName" : "Chris",
   "CustomerPurchaseAmount" : 700
}
{
   "_id" : ObjectId("5cd6ceb36d78f205348bc628"),
   "CustomerName" : "David",
   "CustomerPurchaseAmount" : 50
}
{
   "_id" : ObjectId("5cd6ceb46d78f205348bc629"),
   "CustomerName" : "Larry",
   "CustomerPurchaseAmount" : 1900
}

バルク操作による複数ドキュメントの一括更新

ここからが本題です。initializeUnorderedBulkOp() を呼び出してバルクオペレーションビルダーを取得し、find() と updateOne() を組み合わせて更新対象ごとの操作を登録します。最後に execute() を呼び出すことで、登録したすべての更新が一括して実行されます。

> var manyUpdateValue = db.upDateMultipleRowsDemo.initializeUnorderedBulkOp();

> manyUpdateValue.find({ _id: ObjectId("5cd6ceb06d78f205348bc626")}).updateOne({$set:{"CustomerName":"Bob" }});

> manyUpdateValue.find({ _id: ObjectId("5cd6ceb36d78f205348bc628")}).updateOne({$set:{"CustomerPurchaseAmount":56544444}});

> manyUpdateValue.execute();
BulkWriteResult({
   "writeErrors" : [ ],
   "writeConcernErrors" : [ ],
   "nInserted" : 0,
   "nUpserted" : 0,
   "nMatched" : 2,
   "nModified" : 2,
   "nRemoved" : 0,
   "upserted" : [ ]
})

実行結果を見ると、nMatched と nModified の値がどちらも「2」となっており、2件のドキュメントが正常に更新されたことがわかります。

更新結果の確認

もう一度すべてのドキュメントを表示して、更新が正しく反映されているか確認しましょう。

> db.upDateMultipleRowsDemo.find().pretty();

実行すると、次の出力が得られます。

{
   "_id" : ObjectId("5cd6ceb06d78f205348bc626"),
   "CustomerName" : "Bob",
   "CustomerPurchaseAmount" : 500
}
{
   "_id" : ObjectId("5cd6ceb26d78f205348bc627"),
   "CustomerName" : "Chris",
   "CustomerPurchaseAmount" : 700
}
{
   "_id" : ObjectId("5cd6ceb36d78f205348bc628"),
   "CustomerName" : "David",
   "CustomerPurchaseAmount" : 56544444
}
{
   "_id" : ObjectId("5cd6ceb46d78f205348bc629"),
   "CustomerName" : "Larry",
   "CustomerPurchaseAmount" : 1900
}

このように、最初のドキュメントの CustomerName が「Bob」に、3番目のドキュメントの CustomerPurchaseAmount が「56544444」にそれぞれ変更されていることが確認できます。

まとめ

• initializeUnorderedBulkOp() を使うと、異なる条件での複数の更新を1回の execute() 呼び出しでまとめて実行できる。
• ネットワークラウンドトリップが1回で済むため、大量のドキュメントを個別に更新するよりもパフォーマンスが大幅に向上する。
• 実行結果は BulkWriteResult オブジェクトとして返され、マッチ数や更新数などの詳細を確認できる。