泛型池函数返回回调的结果

generic pool function return result of callback

本文关键字：结果 回调 返回 函数 泛型      更新时间：2023-09-26

我是nodejs的新手，我正在使用mariasql的泛型池。一切正常。但是我移动了我的代码在这样的函数内，我不太确定什么是nodejs的事件处理方式，这样我就可以从函数返回的结果

var pooledQuery = function (query) {
    var result;
    //return here will be the return value of pool.acquire
    pool.acquire(function(err, client) {
        var db;
        if (err != null) {
            console.log(err)
            return err;
        }
        result = [];
        db = client.query(query);
        db.on('result', function(res) {
            return res.on('row', function(row) {
                console.log(row);
                return result.push(row);
            }).on('error', function(err) {
                console.log('error');
            }).on('end', function(info) {
                return result;
            });
        }).on('end', function() {
            pool.release(client);
            return result; <-- i want to know how i can obtain this return value outside of this function?? 
        });
    });
    //since pool.acquire is non-blocking the code will reach here and return an empty value
    return result;
};

使用上面的函数，nodejs是如何完成这样的事情的呢

var result = pooledQuery("SELECT foo, bar FROM foobar");

我正在使用这个通用池从nodejs https://github.com/coopernurse/node-pool

返回一个承诺

   var pooledQuery = function(query) {
       return new Promise(function(resolve, reject) {
           //return here will be the return value of pool.acquire
           pool.acquire(function(err, client) {
             var db;
             if (err != null) {
               reject(err); // oh no! error, let the promise know that it failed
             }
             result = [];
             db = client.query(query);
             db.on('result', function(res) {
               return res.on('row', function(row) {
                 console.log(row);
                 return result.push(row);
               }).on('error', function(err) {
                 reject(err) // here too
               }).on('end', function(info) {
                 return result;
               });
             }).on('end', function() {
               pool.release(client);
               resolve(result); // your promise is resolved, 
               // any ".then" callback applied to it will be called now. 
               // i.e `pooledQuery(query).then(function(result){console.log(result)})
             });
           });
         }
       };

使用like so 

pooledQuery("SELECT foo, bar FROM foobar").then(function(result){console.log(result);})

有很多promise库。使用bluebird

相关文章：