我有一个异步函数,用于在 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/

10-14 16:42
查看更多