【新手求助】Nodejs 异步操作问题

要解决这个问题，我们需要理解Node.js中的异步编程模型。在Node.js中，很多操作都是异步的，比如数据库查询。直接使用同步思维会导致回调地狱（Callback Hell）或者无法得到预期的结果。

正确的实现方法

我们可以使用Promise来处理异步操作，这样可以更好地组织代码逻辑。这里我们使用async/await语法来简化异步代码的编写。

首先，确保你已经安装了mysql-native库：

npm install mysql-native

然后，你可以按照以下方式修改你的代码：

const mysql = require('mysql-native');
const db = mysql.createConnection({
    user: 'your_username',
    password: 'your_password',
    database: 'your_database'
});

// 获取部门列表的函数
async function getDeptList(deptid) {
    const rows = await new Promise((resolve, reject) => {
        db.query(`SELECT * FROM um_department WHERE dupid = ?`, [deptid], (err, rows) => {
            if (err) reject(err);
            resolve(rows);
        });
    });

    const deptChildren = await Promise.all(rows.map(async row => ({
        ...row,
        deptlist: await getDeptList(row.deptid)
    })));

    return deptChildren;
}

// 主函数
async function main() {
    const topDepts = await new Promise((resolve, reject) => {
        db.query(`SELECT * FROM um_department WHERE dupid = 0`, (err, rows) => {
            if (err) reject(err);
            resolve(rows);
        });
    });

    const deptTree = await Promise.all(topDepts.map(async dept => ({
        ...dept,
        deptlist: await getDeptList(dept.deptid)
    })));

    console.log(deptTree);
}

main().catch(console.error);

解释

1. getDeptList 函数:

   • 这个函数接受一个deptid参数，并查询所有子部门。
   • 使用Promise来处理异步查询结果。
   • 使用await来等待子部门查询完成，并递归调用getDeptList获取子部门的子部门。

2. main 函数:

   • 查询顶级部门。
   • 对每个顶级部门，递归地获取其所有子部门，构建完整的部门树结构。
   • 使用await来确保所有的异步操作都已完成。

通过这种方式，我们能够以一种更清晰、更易于维护的方式来处理复杂的异步操作。