mysql - Nodejs-mysql 池连接不适用于异步系列

Question

以下是我的 Node 脚本的代码片段:

pool.getConnection(function(err, maria_connection) {

        maria_connection.query(' CREATE TABLE Currency(uuid VARCHAR(10),name VARCHAR(12),PRIMARY KEY(uuid), UNIQUE(name))')
        async.series({
                one: function(callback){
                    var currency_ids = []

                        request('host_url', function (error, response, html) {
                          if (!error && response.statusCode == 200) {
                            .....used maria_connection here to save some data
                          }
                        })
                    setTimeout( function(){
                      callback(null, 1);
                    },20000)
                 },
                 two: function(callback){
                     maria_connection.query({
                      sql: 'SELECT uuid FROM Currency'
                      },
                      function (error, results, fields){
                        console.log(error)
                        add_currencies( results )
                      }
                    )
                       setTimeout( function(){
                        callback(null, 2);
                       },20000)
                 },
                 three: function(callback){
                       console.log('third series called')
                       maria_connection.query({
                          sql: 'SELECT * FROM Brokers'
                          },
                          function (error, results, fields){
                             if (error) throw error;
                            console.log(results)
                          }
                       )
                      setTimeout( function(){
                        callback(null, 3);
                       },20000)
                 },
                 four: function(callback){ process.exit(-1); }
        }, function(error, results) { // <--- this is the main callback
                maria_connection.release();
        });

现在系列中的前两项工作正常，但是当调用第三个函数时，控制台日志会打印文本“第三个系列已调用”，但 maria_connection 不起作用。它甚至不会抛出任何错误。

Answer 1

我认为您没有正确使用 async.js 以及 throw() 和 setTimeout()。您不需要使用它们。

例如，您使用 setTimeout() 时假定当前任务最多需要 20 秒 - 但如果不是的话怎么办？如果您调用callback()，您将在当前任务完成之前开始下一个任务。您可能会同时运行两个查询(这违背了使用async.series()的想法)。

当你保证任务完成(或返回错误)时，最好触发callback()。如果发生错误，不要抛出错误，而是将其传递到回调中，以便它可以优雅地停止async.series()。

async.series({
    one: function(callback){
        var currency_ids = []
        request('host_url', function (error, response, html) {
            if (error)
                return callback(error);
            if (response.statusCode != 200) 
                return callback(new Error('not 200'));
            // .....used maria_connection here to save some data (*)
        });
    },
    two: function(callback){
        maria_connection.query({ sql: 'SELECT uuid FROM Currency' }, function (error, results, fields){
            if (error)
                return callback(error);
            add_currencies(results); // (*)
        });
    },
    three: function(callback){
        console.log('third series called')
        maria_connection.query({ sql: 'SELECT * FROM Brokers' }, function (error, results, fields){
            if (error)
                return callback(error);
            console.log(results)
            callback();
        });
    }
}, function(error, results) {
    // if an error occurs, it will come down here
    // if all tasks are completed successfully, it will also come down here too
    console.log(error, results); 
    maria_connection.release(); 
    process.exit(-1);
});

如果(*)是异步操作，请确保在操作完成时调用回调。例如，如果 add_currencies() 是一个异步操作，您很可能希望将其编写为

function add_currencies(results, callback) {
    doAsyncOperation(results, function (error) {
        if (error)
            return callback(error);
        callback();
    });

    // or simply doAsyncOperation(results, callback);
}

重要的一点是在每个任务中至少触发一次回调。如果没有，通常事情就会开始悬而未决。