Spring Data MongoDB und Bulk Update

Bin ich mit Spring Data MongoDB und möchte zum durchführen einer Massenaktualisierung genau wie hier beschrieben: http://docs.mongodb.org/manual/reference/method/Bulk.find.update/#Bulk.find.update

Wenn Sie mit regulären Treiber sieht es so aus:

Das folgende Beispiel initialisiert ein Hauptteil () - Operationen-generator für die items-Auflistung, und fügt verschiedene multi update-Operationen, um die Liste der Operationen.

var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { status: "D" } ).update( { $set: { status: "I", points: "0" } } );
bulk.find( { item: null } ).update( { $set: { item: "TBD" } } );
bulk.execute()

Gibt es eine Möglichkeit zu erreichen, ähnliches Ergebnis mit Spring Data MongoDB ?

InformationsquelleAutor Rafal G. | 2014-10-30
  1. 22

    Bulk-updates werden unterstützt von spring-data-mongodb 1.9.0.RELEASE. Hier ist ein Beispiel:

    BulkOperations ops = template.bulkOps(BulkMode.UNORDERED, Match.class);
for (User user : users) {
    Update update = new Update();
    ...
    ops.updateOne(query(where("id").is(user.getId())), update);
}
ops.execute();
    InformationsquelleAutor jalogar
  2. 5

    Können Sie diese verwenden, solange der Treiber aktuell ist und der server, der Sie sprechen, ist mindestens MongoDB, die erforderlich ist für bulk-Operationen. Glaube nicht, dass es alles direkt in den Frühling-Daten jetzt (und viel der gleichen für die anderen höheren level-Treiber-Abstraktionen), aber Sie können natürlich den Zugriff auf die nativen Treiber Sammlung Objekte, die den Zugriff auf die Bulk-API:

        DBCollection collection = mongoOperation.getCollection("collection");
    BulkWriteOperation bulk = collection.initializeOrderedBulkOperation();

    bulk.find(new BasicDBObject("status","D"))
        .update(new BasicDBObject(
            new BasicDBObject(
                "$set",new BasicDBObject(
                    "status", "I"
                ).append(
                    "points", 0
                )
            )
        ));

    bulk.find(new BasicDBObject("item",null))
        .update(new BasicDBObject(
            new BasicDBObject(
                "$set", new BasicDBObject("item","TBD")
            )
        ));


    BulkWriteResult writeResult = bulk.execute();
    System.out.println(writeResult);

    Können Sie entweder füllen Sie die DBObject Typen, die erforderlich sind, indem Sie Sie, oder verwenden Sie die Bauherren geliefert im Frühjahr mongo-Bibliothek, die alle support - "extrahieren" die DBObject die Sie bauen.

    InformationsquelleAutor Neil Lunn
Schreibe einen Kommentar