1. 概要

このチュートリアルでは、MongoDBでの一括更新と挿入操作の実行について説明します。 さらに、MongoDBは、1回の操作で複数のドキュメントを挿入または取得できるAPI呼び出しを提供します。 MongoDBは、ArrayまたはBatchインターフェースを使用します。これにより、クライアントとデータベース間の呼び出し回数が減り、データベースのパフォーマンスが大幅に向上します。

このチュートリアルでは、MongoDBシェルとJavaドライバーコードを使用した両方のソリューションを見ていきます。

MongoDBでのドキュメントの一括更新の実装について詳しく見ていきましょう。

2. データベースの初期化

まず、mongoシェルに接続する必要があります。

mongo --host localhost --port 27017

次に、データベースbaeldungとサンプルコレクションpopulationsを設定します。

use baeldung;
db.createCollection(populations);

insertMany メソッドを使用して、コレクションPopulationsにサンプルデータを追加してみましょう。

db.populations.insertMany([
{
    "cityId":1124,
    "cityName":"New York",
    "countryName":"United States",
    "continentName":"North America",
    "population":22
},
{
    "cityId":1125,
    "cityName":"Mexico City",
    "countryName":"Mexico",
    "continentName":"North America",
    "population":25
},
{
    "cityId":1126,
    "cityName":"New Delhi",
    "countryName":"India",
    "continentName":"Asia",
    "population":45
},
{
    "cityId":1134,
    "cityName":"London",
    "countryName":"England",
    "continentName":"Europe",
    "population":32
}]);

上記のinsertManyクエリは、次のドキュメントを返します。

{
    "acknowledged" : true,
    "insertedIds" : [
        ObjectId("623575049d55d4e137e477f6"),
        ObjectId("623575049d55d4e137e477f7"),
        ObjectId("623575049d55d4e137e477f8"),
        ObjectId("623575049d55d4e137e477f9")
    ]
}

ここでは、MongoDBですべてのタイプの書き込み一括操作を実行するために、上記のクエリに4つのドキュメントを挿入しました。

データベースbaeldungが正常に作成され、必要なすべてのデータもコレクション Populations に挿入されたため、一括更新を実行する準備が整いました。

3. MongoDBシェルクエリの使用

MongoDBのバルク操作ビルダーは、単一のコレクションの書き込み操作のリストを一括で作成するために使用されます。 バルク操作は2つの異なる方法で初期化できます。 メソッドinitializeOrderedBulkOpは、書き込み操作の順序付きリストで一括操作を実行するために使用されます。 initializeOrderedBulkOpの欠点の1つは、書き込み操作の処理中にエラーが発生した場合、MongoDBがリスト内の残りの書き込み操作を処理せずに戻ることです。

insert、update、replace、およびremoveメソッドを使用して、1回のDB呼び出しでさまざまなタイプの操作を実行できます。 例として、MongoDBシェルを使用した一括書き込み操作クエリを見てみましょう。

db.populations.bulkWrite([
    { 
        insertOne :
            { 
                "document" :
                    {
                        "cityId":1128,
                        "cityName":"Kathmandu",
                        "countryName":"Nepal",
                        "continentName":"Asia",
                        "population":12
                    }
            }
    },
    { 
        insertOne :
            { 
                "document" :
                    {
                        "cityId":1130,
                        "cityName":"Mumbai",
                        "countryName":"India",
                        "continentName":"Asia",
                        "population":55
                    }
            }
    },
    { 
        updateOne :
            { 
                "filter" : 
                     { 
                         "cityName": "New Delhi"
                     },
                 "update" : 
                     { 
                         $set : 
                         { 
                             "status" : "High Population"
                         } 
                     }
            }
    },
    { 
        updateMany :
            { 
                "filter" : 
                     { 
                         "cityName": "London"
                     },
                 "update" : 
                     { 
                         $set : 
                         { 
                             "status" : "Low Population"
                         } 
                     }
            }
    },
    { 
        deleteOne :
            { 
                "filter" : 
                    { 
                        "cityName":"Mexico City"
                    } 
            }
    },
    { 
        replaceOne :
            {
                "filter" : 
                    { 
                        "cityName":"New York"
                    },
                 "replacement" : 
                    {
                        "cityId":1124,
                        "cityName":"New York",
                        "countryName":"United States",
                        "continentName":"North America",
                        "population":28
                    }
             }
    }
]);

上記のbulkWriteクエリは、次のドキュメントを返します。

{
    "acknowledged" : true,
    "deletedCount" : 1,
    "insertedCount" : 2,
    "matchedCount" : 3,
    "upsertedCount" : 0,
    "insertedIds" : 
        {
            "0" : ObjectId("623575f89d55d4e137e477f9"),
            "1" : ObjectId("623575f89d55d4e137e477fa")
        },
    "upsertedIds" : {}
}

ここで、上記のクエリでは、すべてのタイプの書き込み操作、つまり insertOne updateOne deleteOne replaceOneを実行しました。

まず、 insertOne メソッドを使用して、コレクションに新しいドキュメントを挿入しました。 次に、 updateOne を使用して、cityName「ニューデリー」のドキュメントを更新しました。 その後、 deleteOne メソッドを使用して、フィルターに基づいてコレクションからドキュメントを削除しました。 最後に、 replaceOne を使用して、ドキュメント全体をフィルター cityName “ New York”に置き換えました。

4. Javaドライバーの使用

一括書き込み操作を実行するためのMongoDBシェルクエリについて説明しました。 一括書き込み操作を作成する前に、まずデータベースbaeldungのコレクションpopulationsとのMongoClient接続を作成しましょう。

MongoClient mongoClient = new MongoClient("localhost", 27017);
MongoDatabase database = mongoClient.getDatabase("baeldung");
MongoCollection<Document> collection = database.getCollection("populations");

ここでは、デフォルトのポート27017で実行されているMongoDBサーバーとの接続を作成しました。 ここで、Javaコードを使用して同じ一括操作を実装しましょう。

List<WriteModel<Document>> writeOperations = new ArrayList<WriteModel<Document>>();
writeOperations.add(new InsertOneModel<Document>(new Document("cityId", 1128)
  .append("cityName", "Kathmandu")
  .append("countryName", "Nepal")
  .append("continentName", "Asia")
  .append("population", 12)));
writeOperations.add(new InsertOneModel<Document>(new Document("cityId", 1130)
  .append("cityName", "Mumbai")
  .append("countryName", "India")
  .append("continentName", "Asia")
  .append("population", 55)));
writeOperations.add(new UpdateOneModel<Document>(new Document("cityName", "New Delhi"),
  new Document("$set", new Document("status", "High Population"))
));
writeOperations.add(new UpdateManyModel<Document>(new Document("cityName", "London"),
  new Document("$set", new Document("status", "Low Population"))
));
writeOperations.add(new DeleteOneModel<Document>(new Document("cityName", "Mexico City")));
writeOperations.add(new ReplaceOneModel<Document>(new Document("cityId", 1124), 
  new Document("cityName", "New York").append("cityName", "United States")
    .append("continentName", "North America")
    .append("population", 28)));
BulkWriteResult bulkWriteResult = collection.bulkWrite(writeOperations);
System.out.println("bulkWriteResult:- " + bulkWriteResult);

ここでは、最初に writeModel のリストを作成して、さまざまなタイプの書き込み操作をすべて1つの更新リストに追加しました。 さらに、クエリでは InsertOneModel UpdateOneModel UpdateManyModel DeleteOneModel 、およびReplaceOneModelを使用しました。 最後に、BulkWriteメソッドはすべての操作を一度に実行しました。

5. 結論

この記事では、さまざまな種類の書き込み操作を使用して、MongoDBで一括操作を実行する方法を学びました。 ドキュメントの挿入、更新、削除、および置換をすべて1つのDBクエリで実行しました。 さらに、initializeOrderedBulkOpのユースケースをMongoDBの一括更新に学習しました。

最初に、MongoDBシェルクエリでの一括操作のユースケースを調べ、次に対応するJavaドライバーコードについて説明しました。

すべてのケースの例は、GitHubにあります。