异步 await 在 Express 中没有响应.js使用 MySQL.js

Question

首先，我尝试将数据插入餐厅餐桌。

完成后(控制台日志(。它应该调用第二个查询(插入审核(。但它不会调用该查询并保留第一个函数。

我该如何解决这个问题？

async function createRestaurant(req, res, next) {
const restaurant = {
name: req.body.name,
description: req.body.description
}
const audits = {
description: req.body.description
}

let query = "INSERT INTO restaurant SET ?";
await connection.query(query, restaurant, (error, results) => {
if (error) {
console.log("Error at res")
return true;
} else {
console.log("200 res")
return true;
}
});
let query2 = "INSERT INTO audits SET ?";
await connection.query(query2, audits, (error, results) => {
if (error) {
console.log("Error at audit")
} else {
console.log("200 res")
}
});
}
module.exports = {
createRestaurant: createRestaurant
}

Answer 1

你不应该将回调与 async/await 一起使用，async/await 的目的是以同步方式编写异步代码。 实际上，您可以返回等待调用并使用try/catch块。

在您的示例中，函数在第一个查询回调中返回，因此永远不会到达第二个查询。

async function createRestaurant(req, res, next) {
const restaurant = {
name: req.body.name,
description: req.body.description
}
const audits = {
description: req.body.description
}
try {
let query = "INSERT INTO restaurant SET ?";
let resRestaurant = await connection.query(query, restaurant);
console.log(200, 'resRestaurant');
let query2 = "INSERT INTO audits SET ?";
let resAudit = await connection.query(query2, audits);
console.log(200, 'resAudit');
return {resRestaurant, resAudit}; // You can return data here
} catch(e) {
console.log('err in requests', e); // you can also use try/catch block for each request
}
}

Answer 2

你不能在每个地方都使用 async/await。如果你想使用async/await，它应该是一个承诺。由于 mysqljs 不是一个承诺的基于库，因此您不能在此处使用 async/await。