Sequelize - 更新记录,并返回结果

Question

我正在使用MySQL的sequelize.例如,如果我这样做:

models.People.update({OwnerId: peopleInfo.newuser},
        {where: {id: peopleInfo.scenario.id}})
        .then(function (result) {
            response(result).code(200);

        }).catch(function (err) {
        request.server.log(['error'], err.stack);
       ).code(200);
    });

如果人员模型已成功更新,我不会收到信息.变量结果只是一个包含一个元素的数组,0 = 1

我怎么能确定记录是否已更新.

Answer 1

这就是我认为你在寻找的东西.

db.connections.update({
  user: data.username,
  chatroomID: data.chatroomID
}, {
  where: { socketID: socket.id },
  returning: true,
  plain: true
})
.then(function (result) {
  console.log(result);   
  // result = [x] or [x, y]
  // [x] if you're not using Postgres
  // [x, y] if you are using Postgres
});

来自Sequelize docs:promise返回一个包含一个或两个元素的数组.第一个元素x始终是受影响的行数,而第二个元素y是实际受影响的行(仅在options.returning设置为的postgres中受支持true.)

假设您使用的是Postgres,则可以使用以下命令访问更新的对象result[1].dataValues.

您必须设置returning: true选项以告知Sequelize返回对象.并且plain: true只是返回对象本身而不是其他可能没用的混乱元数据.

Answer 2

sequelize的更新功能返回一些受影响的行(结果数组的第一个参数).

您应该调用find来获取更新的行

models.People.update({OwnerId: peopleInfo.newuser},
    {where: {id: peopleInfo.scenario.id}})
    .then(() => {return models.People.findById(peopleInfo.scenario.id)})
    .then((user) => response(user).code(200))
    .catch((err) => {
         request.server.log(['error'], err.stack);
      });

Answer 3

最后我明白了。返回 true 在 mysql 中不起作用，我们必须使用 findByPk 以希望此代码会有所帮助。

       return new Promise(function(resolve, reject) {
User.update({
        subject: params.firstName, body: params.lastName, status: params.status
    },{
        returning:true,
        where: {id:id }                             
    }).then(function(){
        let response = User.findById(params.userId);                      
        resolve(response);
    }); 

});

Answer 4

您可以找到该项目并更新其属性，然后保存。save（）导致对数据库的UPDATE查询

        const job = await Job.findOne({where: {id, ownerId: req.user.id}});
        if (!job) {
            throw Error(`Job not updated. id: ${id}`);
        }

        job.name = input.name;
        job.payload = input.payload;
        await job.save();

在Postgres上：

Executing (default): UPDATE "jobs" SET "payload"=$1,"updatedAt"=$2 WHERE "id" = $3