Nodejs中MySQL是否能够等待全部query回传结果才继续执行？

在Node.js中处理异步操作时，特别是涉及到数据库查询时，经常会遇到类似的问题。为了确保所有的查询都完成后再执行下一步操作，我们可以使用Promise或者async/await来更好地管理这些异步操作。

下面是改进后的代码示例，使用async/await来确保所有的查询都完成后再调用回调函数：

const mysql = require('mysql');
const dbclient = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'database_name'
});

const findUserByUid = async (uid) => {
    return new Promise((resolve, reject) => {
        dbclient.query("SELECT * FROM users WHERE uid = ?", [uid], (err, results) => {
            if (err) reject(err);
            resolve(results[0]);
        });
    });
};

const findTaskByTid = async (tid) => {
    return new Promise((resolve, reject) => {
        dbclient.query("SELECT * FROM tasks WHERE tid = ?", [tid], (err, results) => {
            if (err) reject(err);
            resolve(results[0]);
        });
    });
};

const getAllCouponsInfoByManagerUidAndRange = async (uid, range) => {
    try {
        // Select the special range in coupons, the range object have 'start' and 'end'.
        const sql_1 = "SELECT * FROM coupon WHERE coupon_id BETWEEN ? AND ?";
        const [coupons] = await dbclient.query(sql_1, [range.start, range.start + range.amount - 1]);

        // Convert the date fields to JSON format
        coupons = TaskDateConvertToJson(coupons, ["create_time", "used_time"]);

        // Process each coupon
        for (let j = 0; j < coupons.length; j++) {
            const [employee] = await findUserByUid(coupons[j].uid);
            const [manager] = await findUserByUid(coupons[j].manager);
            const [task] = await findTaskByTid(coupons[j].tid);

            coupons[j]['employee'] = employee;
            coupons[j]['manager'] = manager;
            coupons[j]['task'] = task;

            delete coupons[j]['uid'];
            delete coupons[j]['tid'];

            console.log(coupons[j]);
        }

        return coupons;
    } catch (error) {
        console.error(error);
    }
};

getAllCouponsInfoByManagerUidAndRange(uid, range)
    .then(coupons => {
        console.log('All queries completed:', coupons);
    })
    .catch(error => {
        console.error('Error occurred:', error);
    });

function TaskDateConvertToJson(data, fields) {
    data.forEach(item => {
        fields.forEach(field => {
            item[field] = JSON.stringify(item[field]);
        });
    });
    return data;
}

解释

1. 使用async/await：通过将查询封装成返回Promise的函数（如findUserByUid和findTaskByTid），我们可以在主逻辑中使用await关键字来等待这些查询完成。
2. 循环处理：在循环中，每个查询都是异步的，但通过await关键字，我们可以确保在处理下一个查询之前，当前查询已经完成。
3. 错误处理：使用try/catch结构来捕获和处理可能发生的错误。

这种方法确保了所有的查询都按顺序完成，并且只有在所有查询都成功完成后才会调用回调函数。