我有一个函数连接到amazon RDS并从表中选择数据,但我的回调函数总是返回结果是未定义的。我使用async / await来执行此功能,但它不起作用。
我的问题:我需要函数getOrder必须完成并在调用callback之后返回一个结果。
我的功能:
'use strict';
let mysql = require('mysql');
let config = require('./config');
let pool = mysql.createPool({
connectionLimit : 10,
host : config.host,
user : config.user,
password : config.password,
database : config.database
});
exports.handler = async (event, context, callback) => {
let result = {};
try{
let sql = "SELECT * FROM tbl_test WHERE deleted = ? ";
result = await getOrder(sql,0);
}catch (err){
throw new Error(err);
}
console.log("-----Result: ",result);
return callback(null, {body: JSON.stringify(result),statusCode:200});
};
let getOrder = async (sql, params) => {
pool.getConnection((err, connection) => {
connection.query(sql, params, (err, results) => {
if (err){
throw new Error(err);
}
console.log("-----Query Done!");
connection.release();
console.log("-----Data: ", results);
return results;
});
});
};
运行结果:
为了使它工作,在你的getOrder
异步函数中你应该返回一个promise。
例如:
let getOrder = async (sql, params) => {
return new Promise((resolve, reject) => {
pool.getConnection((err, connection) => {
connection.query(sql, params, (err, results) => {
if (err){
reject(err);
}
console.log("-----Query Done!");
connection.release();
console.log("-----Data: ", results);
resolve(results);
});
});
});
};
我这样做了:
client.connect();
var val = await client.query("YOUR QUERY");
client.end();
我认为关键是在query()方法之前放置await。