修改MySQL查询函数为async/await后为何无法正确返回数据？

先结合代码实例拆解核心问题：

第一种写法：直接返回Promise #

// database.js
const util = require('util');
const pool = /* 你的数据库连接池配置 */;

function query(sql) {
  // 直接返回promisify转换后的查询结果（一个Promise对象）
  return util.promisify(pool.query).call(pool, sql);
}

这个query是普通函数，返回的Promise会在数据库查询出错时进入rejected状态，所以controller里的try/catch能正常捕获错误：

// controller.js
async function fetchData() {
  try {
    const data = await query('SELECT * FROM your_table');
    // 处理正常结果
  } catch (err) {
    // 捕获并处理查询错误
    console.error('查询失败:', err);
  }
}

第二种错误的async写法：吞掉了错误 #

如果你的async函数是这么写的，就会出现“无法正常工作”的问题：

// 错误的async写法 database.js
async function query(sql) {
  try {
    return await util.promisify(pool.query).call(pool, sql);
  } catch (err) {
    // 只捕获错误但不向上传递
    console.log('内部捕获错误:', err);
  }
}

问题出在async函数的特性：只要函数内部没有未被捕获的错误，async函数会自动把返回值包装成resolved状态的Promise。这里你在内部catch了错误，但没有重新抛出，也没有返回Promise.reject(err)，相当于把错误“吞掉”了。

此时controller里await这个函数时，即使查询出错，得到的也是一个resolved的Promise（值为undefined，因为catch块没有return），所以上层的try/catch不会进入catch分支，你自然看不到错误处理逻辑生效，误以为“无法正常工作”。

正确的async函数写法 #

如果要在内部做统一错误处理（比如日志），同时让上层能捕获错误，必须在catch后重新抛出错误：

// 正确的async写法 database.js
async function query(sql) {
  try {
    return await util.promisify(pool.query).call(pool, sql);
  } catch (err) {
    // 统一日志处理
    console.error('数据库查询异常:', err);
    // 重新抛出错误，让上层controller的catch捕获
    throw err;
    // 或者返回Promise.reject(err)，效果完全一致
    // return Promise.reject(err);
  }
}

核心差异总结 #

• 第一种写法：普通函数直接返回Promise，错误会沿着Promise链传递，上层try/catch能直接捕获。
• 第二种错误写法：async函数内部捕获错误但未传递，导致Promise状态始终为resolved，上层无法感知错误。
• 本质是async函数的自动包装机制：只要内部没有未捕获的异常，就返回resolved Promise；只有抛出错误或await了rejected的Promise且未捕获，才会返回rejected Promise。

内容的提问来源于stack exchange，提问作者jaehoyj