如何在多个异步调用中向 NodeJS 中的数据库发送响应？答案

【问题标题】：How to send response in mid of multiple async calls to database in NodeJS?如何在多个异步调用中向 NodeJS 中的数据库发送响应？
【发布时间】：2019-03-03 16:44:34
【问题描述】：

需要终止POST函数并发送Error: something作为响应，而不终止程序。

示例for-loop:

for (let i = 0; i < req.body.listoftouristsbyid.length; i++) {
  client.query("SELECT tourists.id FROM tourists WHERE tourists.id = " + req.body.listoftouristsbyid[i], function(err, result) {
    done();
    if (result.rows.length === 0) {
      console.log("Tourist " + req.body.listoftouristsbyid[i] + " you want to add does not exist");
      res.status(500);
      return res.render("Bad listoftoutistbyid request, student with id " + i + " does not exist");
    }
  })
}

我应该写什么来代替 return res.render，这样 POST 将不起作用，函数将终止并返回错误代码作为响应，但不会导致程序崩溃，因此我可以稍后发送更多请求？

【问题讨论】：

我不会向 DB 发出大量请求，而是通过将它们与 OR 组合来进行一个查询 ...
我希望你做输入验证。
你可以使用try ... catch声明。
这意味着您网站的任何访问者都可以使用您的数据库xkcd.com/327
好吧，不要在循环中做很多查询，并在每个查询返回后尝试发送响应。只能有一个响应。

标签： javascript node.js express ecmascript-6 ecmascript-2017

【解决方案1】：

您可以为此使用async-await，因为它在Promise 和Generators 等异步调用处理程序中得到了高度使用。

这是一个示例代码：

app.post('/APIendpoint', async (req, res) => {

    let listoftouristsbyid      = req.body.listoftouristsbyid;

    let dbResult = [];

    // Can put this whole for loop inside try too. Then success response will also be inside try after for-loop
    for (let i = 0; i < listoftouristsbyid.length; i++) {

        try {
            let result = await callDB( "SELECT tourists.id FROM tourists WHERE tourists.id = " + listoftouristsbyid[i] );
            dbResult.push(result);
        }
        catch (err) {

            console.log("Tourist " + listoftouristsbyid[i] + " you want to add does not exist");

            res.status(500);
            return res.send("Bad listoftoutistbyid request, student with id " + i + " does not exist");

        }
    }

    console.log("Successfully fetched all records ", dbResult);

    res.status(200);
    return res.send(dbResult);

});

function callDB(query) {

    return new Promise ( (resolve, reject) => {
        client.query(query, function(err, result) {

            if (result.rows.length === 0) {
                reject("not found");
            } else {
                resolve(result.rows);
            }

        })
    });
}

【讨论】：

【解决方案2】：

尝试使用async.map 来解决您的问题。 for 循环不适用于异步函数。

async.map(
    req.body.listoftouristsbyid, 
    function(touristId, callback) {
        client.query("<query>", function(err, result) {
            if (result.rows.length === 0) {
                callback(new Error("not found"));
            }
            callback(null, result);
        });
    },
    function(err, result) {
        // send response here.
    } 
);

【讨论】：