1。概要
このチュートリアルでは、MongoDBでの一括更新と挿入操作の実行について説明します。さらに、MongoDBは、1回の操作で複数のドキュメントを挿入または取得できるAPI呼び出しを提供します。 MongoDBは配列を使用します またはバッチ クライアントとデータベース間の呼び出し回数を減らすことにより、データベースのパフォーマンスを大幅に向上させるインターフェース。
このチュートリアルでは、MongoDBシェルとJavaドライバーコードを使用した両方のソリューションを見ていきます。
MongoDBでのドキュメントの一括更新の実装について詳しく見ていきましょう。
2。データベースの初期化
まず、mongoシェルに接続する必要があります：
mongo --host localhost --port 27017次に、データベースを設定します baeldung およびサンプルコレクションpopulations ：
use baeldung;
db.createCollection(populations);いくつかのサンプルデータをコレクションpopulationsに追加しましょう insertManyを使用する 方法：
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に置き換えます 「ニューヨーク」。
4。 Javaドライバーの使用
一括書き込み操作を実行するためのMongoDBシェルクエリについて説明しました。一括書き込み操作を作成する前に、まず MongoClientを作成しましょう。 コレクションとのつながり人口 データベースのbaeldung ：
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 メソッドはすべての操作を一度に実行しました。