 
                        首先我用的是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对象为能传参的函数,应该如何写呢?
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
你需要这个 https://github.com/lukeb-uk/node-promise-mysql