Wie durchführen einer Massenaktualisierung von Dokumenten in MongoDB mit Java

Ich bin mit MongoDB 3.2 und MongoDB-Java-Treiber 3.2. Ich habe ein array von ein paar Hunderten von aktualisierten Dokumenten, die sollten jetzt gespeichert/abgelegt in MongoDB. Damit zu tun, dass ich die Iteration über das array und rufen Sie für jedes Dokument, das in dieses array die updateOne() Methode.

Nun, ich möchte zu re-implementieren diese Logik mit einem bulk-update. Ich habe versucht zu finden ein Beispiel für Massen-Updates in MongoDB 3.2 mit MongoDB-Java-Treiber 3.2.

Ich habe versucht, diesen code:

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

Aber es scheint, dass dieser Ansatz basiert auf einem veralteten MongoDB-Java-Treiber, wie 2,4-und nutzt deprecated-Methoden.

Meine Frage:

Wie durchführen einer Massenaktualisierung von Dokumenten in MongoDB 3.2 mit MongoDB-Java-Treiber 3.2?

InformationsquelleAutor Mike B. | 2016-03-07
  1. 16

    Unter Verwendung des Beispiels in der Anleitung auf die neue bulkWrite() API, sollten Sie die folgenden test-Sammlung, die enthält die folgenden Dokumente:

    { "_id" : 1, "char" : "Brisbane", "class" : "monk", "lvl" : 4 },
{ "_id" : 2, "char" : "Eldon", "class" : "alchemist", "lvl" : 3 },
{ "_id" : 3, "char" : "Meldane", "class" : "ranger", "lvl" : 3 }

    Den folgenden bulkWrite() führt mehrere Operationen auf den characters Sammlung:

    Mongo shell:

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

    dem Drucke der Ausgabe:

    {
   "acknowledged" : true,
   "deletedCount" : 1,
   "insertedCount" : 2,
   "matchedCount" : 2,
   "upsertedCount" : 0,
   "insertedIds" : {
      "0" : 4,
      "1" : 5
   },
   "upsertedIds" : {

   }
}

    Die äquivalente Java-3.2 Implementierung folgt:

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

    Für Ihre Frage verwenden Sie die replaceOne() Methode und würde dies umgesetzt, wie

    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);
    • Nicht, dass ich bewusst bin, aber die MongoDB Grenzen und Schwellen noch gelten.
    • Große & vielen Dank. Zwei Fragen. 1. Gibt es irgendeine Regel, wenn ich eine Bewegung von Einzel-update für Massen-Updates in MongoDB? Ich meine von der Menge der Dokumente, Punkt der Regel. 2. In Bezug auf replaceOne() alle meine aktualisierte Dokumente enthalten, ein update von ein-zwei Felder. Warum soll ich diese Methode verwenden und nicht updateOne()? Soweit ich das verstanden habe, replaceOne() ersetzt das gesamte Dokument, während updateOne() können Sie einfach aktualisieren Sie den Wert des bestimmten Feldern, die schneller sein soll, hab ich Recht?
    • Ich denke, das rechtfertigt eine neue Frage, die ist Verschieden von dem, was Sie ursprünglich gefragt. Wenn Sie nach einer anderen Frage werde ich so andere glücklich, Sie zu beantworten. Der Allgemeine Fall ist hier eine Frage, eine Antwort. Ich kann die Antwort auf Ihre weitere Frage, aber Es sollte eine andere Frage völlig. Poste es bitte separat.
    • Die Allgemeine Antwort ist replaceOne ersetzt ein einzelnes Dokument in der Sammlung entspricht dem filter. Wenn mehrere Dokumente match replaceOne wird, ersetzen Sie die erste übereinstimmenden Dokumente nur. updateOne() updates ein einzelnes Dokument innerhalb der collection auf dem filter basiert. Wenn {upsert: true} - option angegeben ist und keine Dokumente, die dem filter entsprechen, wird ein neues Dokument erzeugt werden, indem die Vergleiche auf Gleichheit im filter mit den änderungen von update. Wenn der filter nur Vergleichsoperationen, dann werden nur die änderungen aus dem update wird angewendet, um das neue Dokument.
    • Ich habe eine separate Frage: stackoverflow.com/questions/35848688/...
    • Standardmäßig wird, wenn ein Schreibvorgang fehlschlägt, während die bulk-operation dann keine Daten mehr geschrieben werden. Wenn Sie möchten, MongoDB, zu versuchen, die verbleibenden schreibt, dann verwenden Sie diesen: collection.bulkWrite(write, new BulkWriteOptions().ordered(false));

    InformationsquelleAutor chridam
Schreibe einen Kommentar