本文详解 node.js 中 async/await 在 sql 查询中的典型误用与修复方案，重点解决因回调嵌套、未正确 await promise 导致的“看似异步”问题，并提供基于 idb-pconnector 的可运行示例。
本文详解 node.js 中 async/await 在 sql 查询中的典型误用与修复方案，重点解决因回调嵌套、未正确 await promise 导致的“看似异步”问题，并提供基于 idb-pconnector 的可运行示例。
在 Node.js 中，async/await 并非让异步代码“变同步”，而是以同步风格编写和组织 Promise 链——其前提是：所有异步操作必须返回 Promise，且必须被 await 显式等待。原代码中最大的错误在于将 stmt.exec() 误用为回调模式（传入 (x) => {...}），而 idb-pconnector 的 exec() 方法在 Promise 模式下不接受回调参数；一旦传入回调，它会退化为传统异步调用，返回 undefined，导致 await 实际等待的是 undefined，而非查询结果 Promise。
✅ 正确做法是：确保 exec() 调用不带回调参数，使其返回一个可 await 的 Promise：
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);
// 清理资源（注意：应在获取结果后执行，且推荐使用 finally 或 try/catch 包裹）
stmt.close();
connection.disconn();
connection.close();
return result; // 返回查询结果数组，供上层消费
} catch (error) {
console.error('Database query failed:', error);
throw error; // ❗关键：不要仅 console.error 后返回 undefined；应 re-throw 或返回有意义的错误值
}
}
async function main() {
try {
const data = await get_data(); // ✅ 真正等待 resolve 的结果
console.log('Query succeeded:', JSON.stringify(data.slice(0, 2))); // 示例：打印前两行
} catch (error) {
console.error('Failed to fetch data:', error.message);
}
}
// ✅ 直接调用 main()，无需 let data = main() —— 因为 main() 是 async 函数，返回 Promise
main();
⚠️ 注意事项：
-
避免混合回调与 async/await：
stmt.exec(sql, callback)和await stmt.exec(sql)是互斥的两种调用方式，混用将导致逻辑断裂； -
资源清理需谨慎：
stmt.close()和connection.*应在await获取结果后执行；若需更高健壮性，建议用finally块或封装成资源管理函数； -
错误处理要明确：
catch中不应仅console.error()然后静默返回（如return console.error(...)实际返回undefined），而应throw error让调用链统一处理，或返回标准化错误对象； -
顶层调用无需赋值给变量：
let data = main()得到的是一个 pending Promise，不是数据；应直接main()并在内部处理结果。
通过以上修正，get_data() 真正成为可等待的数据获取函数，main() 中的 await get_data() 将按预期阻塞（逻辑上）直至数据库响应完成，从而实现清晰、可维护、符合直觉的异步流程控制。
