Sequelize upsert

j'ai besoin d'obtenir l'id de l'insertion/mise à jour d'enregistrement lors de l'utilisation de .upsert() dans sequelize.

maintenant .upsert() retourne un booléen indiquant si la ligne a été créé ou mis à jour.

return db.VenueAddress.upsert({
            addressId:address.addressId,
            venueId: venue.venueId,
            street: address.street,
            zipCode: address.zipCode,
            venueAddressDeletedAt: null
        }).then(function(test){
            //test returned here as true or false how can i get the inserted id here so i can insert data in other tables using this new id?
        });

source d'informationauteur Hussein Al-Far

  1. 6

    Je voulais upsert pour retourner le créées ou mises à jour de l'objet. Il n'est pas seulement parce que PGSQL prend en charge directement, apparemment.

    J'ai donc créé une implémentation naïve qui sera probablement un non-performantes moyen, et, éventuellement, avec toutes sortes de conditions de course, faire:

    Sequelize.Model.prototype.findCreateUpdate = function(findWhereMap, newValuesMap) {
  return this.findOrCreate({
    where: findWhereMap, 
    defaults: findWhereMap
  })
  .spread(function(newObj, created) {
    //set:
    for(var key in newValuesMap) {
      newObj[key] = newValuesMap[key];
    }

    return newObj.save();
  });
};

    D'utilisation lorsque vous essayez de créer/mettre à jour un déménagement dans un jeu (exemple artificiel alerte!):

    models.Game
.findOne({where: {gameId: gameId}})
.then(function(game) {
  return db.Move.findCreateUpdate(
    {gameId: gameId, moveNum: game.moveNum+1}, 
    {startPos: 'kr4', endPos: 'Kp2'}
  );
});
  2. 4

    C'est ce qui a fonctionné pour moi: 

    Model.upsert({
    title:your title,
    desc:your description,
    location:your locations
}).then(function (test) {
    if(test){
        res.status(200);
        res.send("Successfully stored");
    }else{
        res.status(200);
        res.send("Successfully inserted");
    }
})

    Il va vérifier db en se basant sur votre clé primaire. Si il trouve ensuite, il mettra à jour les données, sinon il va créer une nouvelle ligne/insérer une nouvelle ligne.

  3. 3

    je sais que c'est un vieux post, mais dans le cas où cela peut aider n'importe qui

    const upsert = async (model: any, values: any, condition: any): Promise<any> => {
  const obj = await model.findOne({ where: condition })
  if (obj) {
    //only do update is value is different from queried object from db
    for (var key in values) {
      const val = values[key]
      if (parseFloat(obj[key]) !== val) {
        obj.isUpdatedRecord = true
        return obj.update(values)
      }
    }
    obj.isUpdatedRecord = false
    return obj

  } else {
    //insert
    const merged = { ...values, ...condition }
    return model.create(merged)
  }
}
  4. 2

    janmeier dit:

    C'est uniquement pris en charge par postgres, de manière à conserver l'API cohérente à travers les dialectes, ce n'est pas possible.

    voir : https://github.com/sequelize/sequelize/issues/3354

  5. 1

    Je ne pense pas que le retour de la upserted record était disponible au moment de l'OP posé cette question, mais il a depuis été mis en œuvre avec ce PR. Comme de Sequelize v4.32.1vous pouvez passer un booléen "retourne" la requête en tant que paramètre à choisir entre retourner un tableau avec l'enregistrement et l'opérateur booléen " ou juste un booléen indiquant si oui ou non un nouveau record a été créé.

    Vous n'avez encore besoin de fournir l'id de l'enregistrement que vous souhaitez upsert ou un nouveau dossier sera créé.

    Par exemple:

    const [record, created] = await Model.upsert(
  { id: 1, name: 'foo' }, //Record to upsert
  { returning: true }     //Return upserted record
);
  6. -1

    Qui je me suis résolu comme suit:

    return db.VenueAddress.upsert({
        addressId:address.addressId,
        venueId: venue.venueId,
        street: address.street,
        zipCode: address.zipCode,
        venueAddressDeletedAt: null
    },{individualHooks: true}).then(function(test){ 
        //note individualHooks
    });