MongoTemplate upsert - la manière facile de faire une mise à Jour à partir des pojo (dont l'utilisateur a editted)?

J'ai trouvé une très bonne solution pour cette question

//make a new description here
Description d = new Description();
d.setCode("no");
d.setName("norwegian");
d.setNorwegian("norwegian");
d.setEnglish("english");

//build query
Query query = new Query(Criteria.where("code").is(description.getCode()));

//build update
DBObject dbDoc = new BasicDBObject();
mongoTemplate.getConverter().write(d, dbDoc); //it is the one spring use for convertions.
Update update = Update.fromDBObject(dbDoc);

//run it!
mongoTemplate.upsert(query, update, "descriptions");

Plz noter que la mise à Jour.fromDBObject retour d'une mise à jour de l'objet avec tous les champs dans dbDoc. Si vous voulez juste de mettre à jour les champs non null, vous devez le code d'une nouvelle méthode pour exclure les champs null.

Par exemple, à l'avant-poste d'un doc comme ci-dessous:

//make a new description here
Description d = new Description();
d.setCode("no");
d.setEnglish("norwegian");

Nous avons seulement besoin de mettre à jour le champ "langue":

//return Update object
public static Update fromDBObjectExcludeNullFields(DBObject object) {
    Update update = new Update();       
    for (String key : object.keySet()) {
        Object value = object.get(key);
        if(value!=null){
            update.set(key, value);
        }
    }
    return update;
}

//build udpate
Update update = fromDBObjectExcludeNullFields(dbDoc);

OriginalL'auteur PaniniGelato

C'est ce que je fais pour le moment. Pas tellement élégante façon de le faire, mais il permet de gagner un précieux DB appel:

import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Query;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.util.JSON;

/**
 * Perform an upsert operation to update ALL FIELDS in an object using native mongo driver's methods
 * since mongoTemplate's upsert method doesn't allow it
 * @param upsertQuery
 * @param object
 * @param collectionName
 */
private void performUpsert(Query upsertQuery, Object object, String collectionName){

    ObjectMapper mapper = new ObjectMapper();

    try {
        String jsonStr = mapper.writeValueAsString(object);
        DB db = mongoTemplate.getDb();
        DBCollection collection = db.getCollection(collectionName);
        DBObject query = upsertQuery.getQueryObject();
        DBObject update = new BasicDBObject("$set", JSON.parse(jsonStr));
        collection.update(query, update, true, false);
    } catch (IOException e) {
        LOGGER.error("Unable to persist the metrics in DB. Error while parsing object: {}", e);
    }
}

OriginalL'auteur Vivek Sethi

Il y a deux cas doivent être distingués:

1. Mettre à jour un élément qui a déjà été récupérée à partir de la DB.
2. Update ou insert (upsert) un élément que vous avez créé dans le code.

Dans le Cas 1), Vous pouvez simplement utiliser mongoTemplate.enregistrer(pojo, "collection"), parce que votre POJO aura déjà rempli un ObjectID dans son champ id.

Dans le cas 2) Vous devez expliquer à mongo ce qui "existe déjà" signifie dans le cas de votre modèle de domaine: Par défaut, le mongoTemplate.méthode save() met à jour un élément existant, si il y en a un avec le même ObjectId. Mais avec un nouvellement instancié POJO vous n'avez pas que des id. Par conséquent, la mongoTemplate.upsert() la méthode a un paramètre de requête que vous pouvez créer comme ceci:

MyDomainClass pojo = new MyDomainClass(...);

Query query = Query.query(Criteria.where("email").is("[email protected]"));

DBObject dbDoc = new BasicDBObject();
mongoTemplate.getConverter().write(pojo, dbDoc);   //it is the one spring use for convertions.
dbDoc.removeField("_id");    //just to be sure to not create any duplicates
Update update = Update.fromDBObject(dbDoc);

WriteResult writeResult = mongoTemplate.upsert(query, update, UserModel.class);

OriginalL'auteur Robert

Suffit d'utiliser ReflectionDBObject - si vous faites Description l'étendre, vous devez juste obtenir votre objet de champs transféré à Update reflectively, magiquement. La note ci-dessus sur les champs null inclus dans la mise à jour est toujours valable.

OriginalL'auteur V. F.

La solution pour un nouveau printemps de données mongodb la version 2.X.X.

L'API a évolué, depuis le 2.X.X version:

Update.fromDocument(org.bson.Document object, String... exclude)

au lieu de (1.X.X):

Update.fromDBObject(com.mongodb.DBObject object, String... exclude)

La solution complète:

//make a new description here
Description d = new Description();
d.setCode("no");
d.setName("norwegian");
d.setNorwegian("norwegian");
d.setEnglish("english");
Query query = new Query(Criteria.where("code").is(description.getCode()));

Document doc = new Document(); //org.bson.Document
mongoTemplate.getConverter().write(item, doc);
Update update = Update.fromDocument(doc);

mongoTemplate.upsert(query, update, "descriptions");

Ça marche!!!

OriginalL'auteur Dawid