sequelize.transaction() 可以将异步函数作为回调吗？

Question

因此，阅读Instance 上的 Sequelize 文档以及有关 transactions 的文档，sequelize.transaction() 将 autoCallback 函数作为参数。文档说：

回调是用事务对象调用的，应该返回 一个承诺。如果 promise 得到解决，则事务提交；如果 promise 拒绝，事务回滚

但是我计划在事务内部做很多事情，我想避免回调地狱。所以我试着做

try {
    let result = sequelize.transaction({
            isolationLevel: 'SERIALIZABLE'
        }, async t => {
            // code to run here with await
            let var1 = await Model.find({ transaction: t });
            let var2 = await Model.find({ transaction: t });

            if (var1.id === 1)
                return "Whatever result";
            else
                throw new Error("Something wicked");
        }
    )});

    // Whatever result
    console.log(result);
}catch(e){
    // Something wicked
}

这似乎工作得很好。但它完全没有记录，我还没有看到有人使用它。可以吗，还是我会遇到随机问题？

Answer 1

正如 @Bergi 和 @Nicholas Tower 在 cmets 中指出的那样：

由于异步函数总是返回承诺，而回调函数应该返回承诺，这是一个相当直截了当的答案。

是的，可以使用。

Answer 2

如果您想使用直接 async/await，请参见下文。您也没有将事务（代码中的t）传递给查询，因此他们不会使用它 - 您必须在transaction 选项中显式传递它。如果您在提交事务后进行任何更改，如果有任何错误，则随后将其回滚。您还可以通过与Promise.all() 同时运行查询来改进您的代码。

// define outside the try/catch so you can rollback if needed
let transaction;
let result;
try {
    transaction = await sequelize.transaction({ isolationLevel: 'SERIALIZABLE' });

    // run concurrently with Promise.all()
    const [ var1, var2 ] = await Promise.all([
       // don't await here, but you have to pass the transaction
       Model.findByPk({ transaction }),
       Model.findOne({ transaction }), // ditto
    ]);

    if (var1.id === 1) {
       result = "Whatever result";
    } else {
       throw new Error("Something wicked");
    }
    // if you need to commit anything...
    // await transaction.commit();
} catch(err) {
    /* if you need to roll back anything...
    if (transaction) {
       await transaction.rollback();
    }
    */
    console.log(err);
}
return result;