如何正确使用 async/await 封装数据库查询并确保同步执行效果-js教程-PHP中文网

如何正确使用 async/await 封装数据库查询并确保同步执行效果

本文详解 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()。