Как отправить ответ в середине нескольких асинхронных вызовов в базу данных в NodeJS? - PullRequest
Новая
       20

Как отправить ответ в середине нескольких асинхронных вызовов в базу данных в NodeJS?

0 голосов
/ 27 сентября 2018

Необходимо завершить функцию 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 не работал, функция завершит работу с кодом ошибки в ответ, но без сбоевпрограмма, чтобы я мог отправить больше запросов позже?

Ответы [ 2 ]

0 голосов
/ 27 сентября 2018

Вы можете использовать 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);
            }

        })
    });
}
0 голосов
/ 27 сентября 2018

Попробуйте использовать 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.
    } 
);
...