Node.js async prend trop de temps pour exécuter

Question

J'ai mon tableau de requêtes

var array = [ 'UPDATE EVALUATION SET mark = "16" WHERE id_eval = "21" AND id_usr = "125"', 
       'UPDATE EVALUATION SET mark = "9" WHERE id_eval = "22" AND id_usr = "125"', 
       'UPDATE EVALUATION SET mark = "8" WHERE id_eval = "34" AND id_usr = "125"' 
      ] 

Cependant, lorsque je tente de les exécuter à la fois avec async, ma page web dit Waiting for localhost... et il continue à chargement pour toujours. Qu'est-ce que je fais mal?

async.forEach(array, function(query, callback) { 
    connection.query(query, function(err, rows, fields) { 
     if(err) { 
      return console.error(err); 
     } 

     callback(); 
    }); 
}, function(err){ 
    if(err) { 
     return console.log(err); 
    } 
}); 

Answer 1

Assurez-vous que vous retournez la réponse après le rappel forEach est appelé:

async.forEach(array, function(query, callback) { 
    connection.query(query, function(err, rows, fields) { 
     if(err) { 
      console.error(err); 
     } 

     callback(); 
    }); 
}, function(err){ 
    if(err) { 
     console.log(err); 
    } 

    res.redirect('/next-page'); 
}); 

De cette façon, la redirection se produira seulement à la fin de tout les requêtes.

Certaines choses que vous devriez vérifier:

• Vérifiez que vous n'avez pas appelé res.end() ou res.redirect() ou quelque chose de semblable avant que le code ci-dessus.
• Vérifiez que votre méthode DB query n'attend réellement que 2 arguments: requête et rappel, et rien entre eux (par exemple les paramètres de requête).
• Vérifiez que cette partie du code est réellement appelée quand vous l'attendez. Essayez de déboguer la requête jusqu'au bout.
• Actuellement, il n'y a pas de vraie gestion des erreurs ici. Vous devriez envisager de renvoyer une erreur HTTP si quelque chose ne va pas. Cela devrait également vous aider à déboguer ce code dans le futur.

Answer 2

Habituellement vous avez un gestionnaire de requêtes comme ceci:

const server = http.createServer((req, res) => { 
    res.statusCode = 200; 
    res.setHeader('Content-Type', 'text/plain'); 
    res.end('Hello World\n'); 
}); 

Votre navigateur contient la connexion jusqu'à ce que res.end a été appelé!

Dans votre environnement, il devrait ressembler somethinge comme

const server = http.createServer((req, res) => { 

    // ... 
    async.forEach(array, function(query, callback){ 
    connection.query(query, function(err, rows, fields) { 
     // you may do some work here but leave it *alyways* via callback! 
     callback(err); 
    }); 
    }, function(err){ 
    if(err){ // this may be errors from above 
     return console.log(err); 
    } 
    // Exit here ! 
    res.statusCode = 200; 
    res.setHeader('Content-Type', 'text/plain'); 
    res.end('All done.\n'); 
    }); 
}); 

... ou un peu plus propre

function doSomeDatabaseUpdates(onFinished) { 
    var array = [...]; 
    async.forEach(array, function(query, callback){ 
    connection.query(query, function(err, rows, fields) { 
     // you may do some work here but leave it *alyways* via callback! 
     callback(err); 
    }); 
    }, 
    function IGetCalledAfterAboveCallbackWereExecuted(err){ 
    if(err){ // this may be errors from above 
     return console.log(err); 
    } 
    // Exit here ! 
    onFinished(); 
    }); 
} 


const server = http.createServer((req, res) => { 

    // ... do some work 

    if (doSomeUpdated === true) { 
    doSomeDatabaseUpdates(function calledAfterUpdates() { 
     res.end("updates something"); 
    }); 
    } else { 
    res.end("nothing to do"); 
    } 

});