首先我用的是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