[解決済み] JavaでMongoDBのドキュメントの一括更新を行うには?
2022-02-07 14:59:32
質問内容
MongoDB 3.2 と MongoDB Java Driver 3.2 を使っています。数百の更新されたドキュメントの配列があり、それを今MongoDBに保存/保管する必要があります。そのために、配列を繰り返し処理し、その配列の各ドキュメントに対して
updateOne()
というメソッドがあります。
さて、このロジックを一括更新で再実装してみたいと思います。MongoDB 3.2 で MongoDB Java Driver 3.2 を使ってバルクアップデートを行う例を探してみました。
こんなコードを試してみました。
MongoClient mongo = new MongoClient("localhost", 27017);
DB db = (DB) mongo.getDB("test1");
DBCollection collection = db.getCollection("collection");
BulkWriteOperation builder = collection.initializeUnorderedBulkOperation();
builder.find(new BasicDBObject("_id", 1001)).upsert()
.replaceOne(new BasicDBObject("_id", 1001).append("author", "newName"));
builder.execute();
しかし、この方法は2.4などの古いMongoDB Java Driverをベースにしており、非推奨のメソッドを使っているようです。
私の質問です。
MongoDB 3.2 で MongoDB Java Driver 3.2 を使ってドキュメントの一括更新を行うにはどうすればいいでしょうか?
解決方法は?
のマニュアルにある例を使って、新しい
bulkWrite()
APIでは、以下のドキュメントを含む以下のテストコレクションを考えてみましょう。
{ "_id" : 1, "char" : "Brisbane", "class" : "monk", "lvl" : 4 },
{ "_id" : 2, "char" : "Eldon", "class" : "alchemist", "lvl" : 3 },
{ "_id" : 3, "char" : "Meldane", "class" : "ranger", "lvl" : 3 }
以下は
bulkWrite()
に対して複数の操作を行います。
characters
コレクションを作成します。
Mongoのシェルです。
try {
db.characters.bulkWrite([
{
insertOne:{
"document":{
"_id" : 4, "char" : "Dithras", "class" : "barbarian", "lvl" : 4
}
}
},
{
insertOne:{
"document": {
"_id" : 5, "char" : "Taeln", "class" : "fighter", "lvl" : 3
}
}
},
{
updateOne: {
"filter" : { "char" : "Eldon" },
"update" : { $set : { "status" : "Critical Injury" } }
}
},
{
deleteOne: { "filter" : { "char" : "Brisbane"} }
},
{
replaceOne: {
"filter" : { "char" : "Meldane" },
"replacement" : { "char" : "Tanys", "class" : "oracle", "lvl" : 4 }
}
}
]);
}
catch (e) { print(e); }
で、出力を表示します。
{
"acknowledged" : true,
"deletedCount" : 1,
"insertedCount" : 2,
"matchedCount" : 2,
"upsertedCount" : 0,
"insertedIds" : {
"0" : 4,
"1" : 5
},
"upsertedIds" : {
}
}
同等のJava 3.2実装は以下の通りです。
MongoCollection<Document> collection = db.getCollection("characters");
List<WriteModel<Document>> writes = new ArrayList<WriteModel<Document>>();
writes.add(
new InsertOneModel<Document>(
new Document("_id", 4)
.append("char", "Dithras")
.append("class", "barbarian")
.append("lvl", 3)
)
);
writes.add(
new InsertOneModel<Document>(
new Document("_id", 5)
.append("char", "Taeln")
.append("class", "fighter")
.append("lvl", 4)
)
);
writes.add(
new UpdateOneModel<Document>(
new Document("char", "Eldon"), // filter
new Document("$set", new Document("status", "Critical Injury")) // update
)
);
writes.add(new DeleteOneModel<Document>(new Document("char", "Brisbane")));
writes.add(
new ReplaceOneModel<Document>(
new Document("char", "Meldane"),
new Document("char", "Tanys")
.append("class", "oracle")
.append("lvl", 4)
)
);
BulkWriteResult bulkWriteResult = collection.bulkWrite(writes);
ご質問の件では
replaceOne()
メソッドがあり、これは次のように実装されるでしょう。
MongoCollection<Document> collection = db.getCollection("collection");
List<WriteModel<Document>> writes = Arrays.<WriteModel<Document>>asList(
new ReplaceOneModel<Document>(
new Document("_id", 1001), // filter
new Document("author", "newName"), // update
new UpdateOptions().upsert(true) // options
)
);
BulkWriteResult bulkWriteResult = collection.bulkWrite(writes);
関連
-
[解決済み】 java.lang.ClassNotFoundException: oracle.jdbc.driver.OracleDriver [重複]。
-
[解決済み] JavaでInputStreamを読み込んでStringに変換するにはどうすればよいですか?
-
[解決済み] Java Mapの各エントリを効率的に反復処理するには?
-
[解決済み] Javaでメモリーリークを発生させるにはどうしたらいいですか?
-
[解決済み] JavaでStringをintに変換するにはどうしたらいいですか?
-
[解決済み] Javaで配列に特定の値が含まれているかどうかを判断するにはどうすればよいですか?
-
[解決済み] Java で、あるコンストラクタを別のコンストラクタから呼び出すにはどうすればよいですか?
-
[解決済み] Javaで配列を宣言し、初期化する方法は?
-
[解決済み] Javaで文字列値からenum値を取得する方法
-
[解決済み] MongoDBに "like "を使ってクエリを実行する方法
最新
-
nginxです。[emerg] 0.0.0.0:80 への bind() に失敗しました (98: アドレスは既に使用中です)
-
htmlページでギリシャ文字を使うには
-
ピュアhtml+cssでの要素読み込み効果
-
純粋なhtml + cssで五輪を実現するサンプルコード
-
ナビゲーションバー・ドロップダウンメニューのHTML+CSSサンプルコード
-
タイピング効果を実現するピュアhtml+css
-
htmlの選択ボックスのプレースホルダー作成に関する質問
-
html css3 伸縮しない 画像表示効果
-
トップナビゲーションバーメニュー作成用HTML+CSS
-
html+css 実装 サイバーパンク風ボタン
おすすめ
-
[解決済み】HTTPステータス 405 - リクエストメソッド「POST」はサポートされていません (Spring MVC)
-
[解決済み] java.sql.SQLException: ユーザー 'root'@'localhost' (using password: YES) のためのアクセスが拒否されました。
-
[解決済み】エラー「No enclosing instance of type Foo is accessible」の原因と修正方法について教えてください。
-
[解決済み】非閉鎖文字リテラルエラー
-
[解決済み】「java -cp」と「java -jar」の違い?
-
[解決済み】文字列中の � を置換する方法
-
[解決済み】Javaメソッドスタブ
-
[解決済み] [Solved] java.lang.NoClassDefFoundError: クラスXXXを初期化できませんでした。
-
[解決済み] Hide Utility Class Constructor : ユーティリティクラスはパブリックまたはデフォルトコンストラクタを持つべきではありません。
-
[解決済み】Javaの".class expected "について