几个异步函数后的一个响应

Question

我有一个带有表单的网页，用户可以在其中编辑个人信息、教育、工作经历等。 并且用户可以添加多个学位，例如：bs、ms、phd。还有一些工作职位。

当用户按下“保存”按钮时，我会将所有这些数据发送到我的服务器。我在一个请求中发送所有内容。在服务器中，我有一点要处理请求。

app.post(config.version + '/profile', (req, res, next) => {});

然后我做了一些 MySQL 查询来插入/更新/删除数据。我使用来自 npm 的 mysql 包来做到这一点。

new Promise((resolve, reject) => {
    const userQuery = `INSERT INTO user ...;`;
    const degreesQuery = 'INSERT INTO degree ...;';
    const positionsQuery = 'UPDATE position SET ...;';

    this.connection.query(userQuery, err => {});
    this.connection.query(degreesQuery, err => {});
    this.connection.query(positionsQuery, err => {});

    resolve({});
})

最后我做了resolve({})，但我想选择更新的配置文件并将其发回（因为在 MySQL 表中我添加了有助于我不再插入重复数据的 ID）。所以，我的问题是只有当我所有的异步 this.connection.querys 完成后，resolve({}) 怎么办？

Answer 1

我的建议是在 Promise.all() 中运行所有查询。

例子：

const queries = [
    `INSERT INTO user ...;`;,
    'INSERT INTO degree ...;',
    'UPDATE position SET ...;'
];

Promise.all(queries.map((query) => {
    return new Promise((resolve, reject) => {
         this.connection.query(query, err => {
             return err ? reject(err) : resolve();
         });
    });
})
.then(() => {
    // continue
    // get your updated data here with and send it as response
})

如果你的 db 库支持 Promise，就这样写

Promise.all(queries.map((query) => {
    return this.connection.query(query);
})
.then(() => {
    // continue
    // get your updated data here with and send it as response
})