我有一个异步函数,用于在 Node.js 中查询 mysql 数据库。我正在等待查询执行的结果并将结果插入到数组中。
async function getOpenOrders() {
try {
const arrayLoads = [],
last4Orders = await pool.query( `${query1} ` )
// console.log(last4Orders)
for ( let i = 0; i < last4Orders.length; i++ ) {
// console.log(last4Orders[i].orderID)
console.log( arrayLoads )
console.log( `===================` )
const rows = await pool.query( `${query2}` )
console.log( rows )
arrayLoads.push( rows )
// console.log(arrayLoads)
}
// console.log(rows[0])
// console.log(arrayLoads)
res.send( arrayLoads )
} catch ( err ) {
console.log( err )
}
}
getOpenOrders()
但是,for 循环中的 await 查询并没有停止同步代码,因为我的
console.log()
显示如下内容: []
===================
[]
[ [] ]
===================
[]
[ [], [] ]
===================
[RowDataPacket { Number: '4732', Test: 'TQLM-384', User: 23 },
RowDataPacket { Number: '4732', Test: 'TQLM-384', User: 23 }]
[ [],
[],
[RowDataPacket { Number: '4732', Test: 'TQLM-384', User: 23 },
RowDataPacket { Number: '4732', Test: 'TQLM-384', User: 23 }]
===================
[RowDataPacket { Number: '4732', Test: 'TQLM-384', User: 23 },
RowDataPacket { Number: '4732', Test: 'TQLM-384', User: 23 }]
最佳答案
mysql pool.query
方法返回一个回调,如果你想使用 async await
,尝试promisify 该方法然后使用 async await
const {promisify} = require('util');
async function getOpenOrders() {
try {
const arrayLoads = [],
query = promisify(pool.query).bind(pool);
last4Orders = await query( `${query1} ` )
// console.log(last4Orders)
for ( let i = 0; i < last4Orders.length; i++ ) {
// console.log(last4Orders[i].orderID)
console.log( arrayLoads )
console.log( `===================` )
const rows = await query( `${query2}` )
console.log( rows )
arrayLoads.push( rows )
// console.log(arrayLoads)
}
// console.log(rows[0])
// console.log(arrayLoads)
res.send( arrayLoads )
} catch ( err ) {
console.log( err )
}
}
getOpenOrders()
关于mysql - 异步函数等待不等待,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/57816253/