本文详解 Node.js 中 async/await 与 Promise 风格数据库操作的正确写法，指出常见误区（如错误地在回调中 await 非 Promise 函数），并通过 idb-pconnector 示例展示如何真正实现“逻辑同步”的异步 SQL 查询。
本文详解 node.js 中 async/await 与 promise 风格数据库操作的正确写法，指出常见误区（如错误地在回调中 `await` 非 promise 函数），并通过 idb-pconnector 示例展示如何真正实现“逻辑同步”的异步 sql 查询。
在 Node.js 中，async/await 并不会让异步操作“变同步”，而是提供一种更清晰、更接近同步语义的 Promise 操作方式——前提是被 await 的函数本身返回一个 Promise。原代码的根本问题在于：stmt.exec() 被错误地传入了一个回调函数，导致它退化为传统的回调模式，而非 Promise 模式；此时 await 实际上等待的是 undefined（因为 stmt.exec(...callback) 默认不返回 Promise），因此 result 始终为 undefined。
✅ 正确做法是：调用支持 Promise 返回的 exec() 方法（无回调参数）。以 idb-pconnector 为例，其 Statement.exec(sql) 在无回调时自动返回 Promise，可直接 await：
const { Connection, Statement } = require('idb-pconnector');
async function get_data() {
const sql_stmt = 'SELECT * FROM QIWS.QCUSTCDT';
const connection = new Connection({ url: '*LOCAL' });
const stmt = new Statement(connection);
try {
// ✅ 正确：无回调，返回 Promise，可 await
const result = await stmt.exec(sql_stmt);
// 清理资源（注意：应在获取结果后执行）
stmt.close();
connection.disconn();
connection.close();
return result; // 返回实际数据，供上层 await 获取
} catch (error) {
console.error('SQL 执行失败:', error);
throw error; // 推荐 re-throw 而非仅 console.error，便于上层统一捕获
}
}
async function main() {
try {
const data = await get_data(); // ✅ 真正拿到查询结果
console.log('查询成功，共', data.length, '条记录');
console.log(JSON.stringify(data, null, 2));
// 此处可继续处理数据，例如渲染网页、返回 API 响应等
} catch (error) {
console.error('主流程异常:', error);
}
}
// ✅ 直接调用，无需额外 let data = main() —— main() 本身是 async，返回 Promise
main();⚠️ 关键注意事项：
-
不要混用回调与
await：stmt.exec(sql, callback)是回调风格，不返回 Promise；stmt.exec(sql)（无回调）才返回 Promise。 -
资源清理需放在
await之后、return之前，否则可能在查询未完成时提前关闭连接。 -
错误处理建议
throw error而非仅console.error，确保异常能被外层catch捕获，避免静默失败。 -
顶层调用
main()即可，无需let data = main()后再console.log(data)——因为main()返回的是 Promise 实例，不是查询结果；若需在外部访问结果，应通过.then()或在另一个async函数中await main()。
通过以上修正，get_data() 真正成为可 await 的异步函数，main() 中的 const result = await get_data() 将严格按顺序执行：等待 SQL 完成 → 获取数据 → 继续后续逻辑，从而实现预期的“同步式”控制流。
