首页 > 如何把回调函数的返回值promise化?返回的是一个函数

如何把回调函数的返回值promise化?返回的是一个函数

首先我用的是nodejs 的mysql模块,里面有个连接池,语法如下

pool.getConnection(function(err,connection){
    connection.query("USE userInfo",function(err,rows){
        
    });
});

我根据大神们给我的建议,用async/await改写这段代码,其中很重要一步是把,pool.getConnection和connection.query转化为promise对象

//先promise化pool.getConnection
    var getConn = new Promise(function(resolve,reject){
        pool.getConnection(function(err,connection){
            if (err) {
                reject(err);
            } else {
                resolve(connection);
            }
        });
    });
    

但是connection.query需要上一个传回来的connection,在async函数中我可以写如下代码

let connection = await getConn;

但是那样connection就不是promise对象了,后续更多的异步操作将会又回到回调函数的风格上了,所以我想把connection.query也promise化,但是只能写在async函数内部了,而且也不知道怎么写成能根据查询字符串变化返回rows的对象

async函数代码如下,目前运行后可以得到rows

const test = async()=>{
        let connection = await getConn;
        var conn = new Promise(function(resolve,reject){
            connection.query("USE userInfo",function(err,rows){
                if (err) {
                    reject(err);
                } else {
                    resolve(rows);
                }
            });
        });
        let rows = await conn;
        console.log(rows);
    };
    

想要让connection.query的promise对象为能传参的函数,应该如何写呢?


你需要这个 https://github.com/lukeb-uk/node-promise-mysql

【热门文章】
【热门文章】