Java로 MongoDB에서 문서의 대량 업데이트를 수행하는 방법은 무엇입니까?

Java로 MongoDB에서 문서의 대량 업데이트를 수행하는 방법은 무엇입니까?

저는 MongoDB 3.2와 MongoDB Java Driver 3.2를 사용하고 있습니다.현재 MongoDB에 저장/저장되어야 하는 업데이트된 문서가 수백 개 있습니다.이를 위해 배열을 반복하고 이 배열에 있는 각 문서를 호출합니다.updateOne()방법.

이제 이 논리를 대량 업데이트로 다시 구현하려고 합니다.MongoDB Java Driver 3.2를 사용하여 MongoDB 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 Java Driver 3.2를 사용하여 MongoDB 3.2에서 문서의 대량 업데이트를 수행하는 방법은 무엇입니까?

새 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 }

다음은 에서 여러 작업을 수행합니다.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);

---

질문에 대한 방법을 사용하면 다음과 같이 구현됩니다.

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);

언급URL : https://stackoverflow.com/questions/35846474/how-to-perform-a-bulk-update-of-documents-in-mongodb-with-java