Azure Function查询外部MySQL数据库未获取结果问题排查

你的问题核心是异步操作没有正确等待：connection.query是回调式的异步方法，如果你直接用await但没把它包装成Promise，函数会直接往下执行、提前结束，导致后续回调里的context.log触发警告，同时外部变量根本没来得及被赋值，所以打印出undefined。INSERT能成功是因为它不依赖返回结果，异步操作最终还是执行完了，但SELECT需要拿到结果，就暴露了异步等待的问题。

1. 把回调式的query转成Promise（关键） #

Node.js的MySQL相关包支持Promise化，两种方式任选：

方法一：用util.promisify包装现有connection.query #

const util = require('util');
// 把query方法转成Promise版本，注意绑定connection上下文
const queryAsync = util.promisify(connection.query).bind(connection);

方法二：改用mysql2/promise包（更简洁） #

先安装依赖：

npm install mysql2

然后用Promise版连接池（推荐用连接池而非单连接）：

const mysql = require('mysql2/promise');
const pool = mysql.createPool({
  host: '你的MySQL外部地址',
  user: '数据库用户名',
  password: '数据库密码',
  database: '目标数据库名'
});

2. 用await正确等待查询结果 #

转成Promise后，就能用await同步写法等待查询完成，彻底避免回调导致的异步问题。

示例代码（以mysql2/promise为例）：

module.exports = async function (context, req) {
  try {
    // 等待查询完成，直接拿到结果
    const [rows] = await pool.query('SELECT * FROM 你的表名');
    // 此时函数还在执行周期内，context.log不会触发警告
    context.log('查询结果:', rows);
    // 将结果返回给请求方
    context.res = {
      body: rows
    };
  } catch (err) {
    context.log.error('查询出错:', err);
    context.res = {
      status: 500,
      body: '查询失败'
    };
  }
};

3. 避开错误写法 #

别再用回调嵌套，也别直接await原始的connection.query（它不返回Promise，await无效）：

// 错误示例：await无效，函数提前结束
module.exports = async function (context, req) {
  let result;
  // 这里await不生效，connection.query返回的不是Promise
  await connection.query('SELECT * FROM 表', (err, rows) => {
    result = rows;
    // 此时函数已执行完成，context.log触发警告
    context.log(result);
  });
  // 这里result还是undefined，因为异步回调还没执行
  context.log(result);
};

• 优先用连接池而非单连接：Azure Function是无服务器架构，单连接容易出现连接泄漏、超时问题。
• 必须加try/catch捕获异步错误：避免函数意外崩溃，同时能快速定位问题。

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