在使用 express 呈现页面之前等待所有 mySql 请求完成答案

【问题标题】：Waiting for all mySql requests to finish before rendering page with express在使用 express 呈现页面之前等待所有 mySql 请求完成
【发布时间】：2021-07-04 16:45:37
【问题描述】：

我有一个 node.js 服务器，它在用户选择他想要查看状态的储物柜类型后查询数据库。储物柜有多种状态：殖民、非更新、免费、占用。获取这些类别中的任何一个都是通过特定请求完成的。

我想要的是，如果用户选择所有选项，能够执行所有请求并将所有行放入数组中，然后用它呈现网页。问题是异步的，```connection.query````没有按顺序返回，不知道怎么解决。

app.get('/admin/sites/lockers/*', function (req, res) {
    console.log("GET /admin/sites/lockers");
    let parsedQs = querystring.parse(url.parse(req.originalUrl).query);
    console.log(parsedQs);
    let resultArray = [];

    if(parsedQs['colonised']) {
        let query = fs.readFileSync('./sql/colonised_lockers.sql', 'utf8');
        connection.query(query, function (err, results, fields) {
            resultArray.push(results[0]);
            console.log("colonized :", resultArray);
        });
    }

    if(parsedQs['non_renewed']) {
        let query = fs.readFileSync('./sql/non_renewed_lockers.sql', 'utf8');
        connection.query(query, function (err, results, fields) {
            resultArray.push(results[0]);
            console.log("non_renewed :", resultArray);
        });
    }

    if(parsedQs['free']) {
        let query = fs.readFileSync('./sql/free_lockers.sql', 'utf8');
        connection.query(query, function (err, results, fields) {
            resultArray.push(results[0]);
            console.log("free :", resultArray);
        });
    }
    console.log("finally :", resultArray);
    res.render('admin/lockerView.ejs', {lockers : resultArray });
});

【问题讨论】：

你读过关于等待等的nodejs.dev/learn/…

标签： javascript mysql node.js asynchronous

【解决方案1】：

您可以尝试在您用于连接数据库的工具的文档中找到基于Promise 而不是callback 的方法。但是您也可以将您的connection.query 包装到Promise 中并使用async await 以便在处理程序中具有“类似同步”流。比如：

function makeDBQuery(query) {
  return Promise((resolve, reject) => {
    connection.query(query, function (err, result) {
      err ? reject(err) : resolve(result);
    });
  });
}

app.get('/admin/sites/lockers/*', async function (req, res) {
  console.log('GET /admin/sites/lockers');
  const parsedQs = querystring.parse(url.parse(req.originalUrl).query);
  console.log(parsedQs);
  const resultArray = [];

  if (parsedQs['colonised']) {
    const query = fs.readFileSync('./sql/colonised_lockers.sql', 'utf8');
    const result = await makeDBQuery(query);
    resultArray.push(result);
  }

  if (parsedQs['non_renewed']) {
    const query = fs.readFileSync('./sql/non_renewed_lockers.sql', 'utf8');
    const result = await makeDBQuery(query);
    resultArray.push(result);
  }

  if (parsedQs['free']) {
    const query = fs.readFileSync('./sql/free_lockers.sql', 'utf8');
    const result = await makeDBQuery(query);
    resultArray.push(result);
  }
  console.log('finally :', resultArray);
  res.render('admin/lockerView.ejs', { lockers: resultArray });
});

当然你需要一些错误处理程序，你可以将重复的代码移动到附加函数中，但这是另一回事）

【讨论】：