无法在单个 lambda 函数中编写多个查询

Question

我正在使用 AWS API getaway 和 lambda 进行 API 开发。我正在使用无服务器 MySQL https://www.npmjs.com/package/serverless-mysql 用于mysql连接和操作的包。 但我无法执行多个查询。请检查以下代码。

显示错误“解析错误：意外的令牌连接”。

var sql_1 = 'Query 1';
let rows = await connection.query(sql_1);

rows.forEach(function (row) {

    var sql_2 = 'Query 2';
    let rows = await connection.query(sql_2); // I am refering id in sql2 from result of sql_1
});

Answer 1

我对您的代码感到困惑，因为您正在重新分配一个正在迭代的变量，除了多个语法错误。

但我认为您的问题是您误解了如何正确使用异步 JavaScript。 ForEach 在继续之前不会等待您的查询完成。

最好使用 Promise.all() 之类的东西来等待所有查询异步返回。

let q1Rows = await query(...);

let otherQueries = Promise.all(q1Rows.map(async (row) => await query(row.someData)));
// otherQueries is now an array of all the returned queries in order

Answer 2

您可以使用 Promise await 编写多个查询。

var sql_1 = 'Query 1';
let rows = await connection.query(sql_1);

let resultTemp=[];
    await Promise.all(rows.map(async (row) => {
       var sql_2 = 'Query 2';
       let result = await connection.query(sql_2 );
            resultTemp.push(result);

     }));

 context.succeed(resultTemp);