node.js - 在 Sequelize 事务中执行 promise 列表时无法捕获/抛出错误？

Question

在下面的代码中，我试图 upsert 到用户记录。如果任一记录未能 upsert ，我希望两条记录都回滚。

在下面的代码中，我通过设置 user_id = null 强制第二条记录失败。但是，它仍然命中 then 块 return result; 。它不会捕获/抛出错误或回滚事务。我也在我的日志中看到了这个错误:

Unhandled rejection SequelizeValidationError: notNull Violation: User.user_id cannot be null
    at Promise.all.then

async function submitUsers(users) {
  return db.sequelize.transaction(async (tx) => {
     const queries = users.map((user, index) => {
        if (index == 1) {
            user.user_id = null;
        }
        User.upsert(user, tx);
     });

     await Promise.all(queries);
  }).then((result) => {
     return result;
  }).catch((e) => {
     throw e;
  });
}


const users = [ {user_id: 1}, {user_id: 2}];
await submitUsers(users);

Answer 1

你没有正确地返回你的 promise 。试试这个;

async function submitUsers(users) {
  return db.sequelize.transaction((tx) => {
     const queries = users.map((user, index) => {
        if (index == 1) {
            user.user_id = null;
        }
        return User.upsert(user, tx);
     });

     return Promise.all(queries);
  }).then((result) => {
     return result;
  }).catch((e) => {
     throw e;
  });
}