NodeJS远程访问MySQL时查询顺序错乱、返回结果为空问题求助

NodeJS的所有IO操作（包括数据库连接、查询）默认都是异步非阻塞执行的，你代码中getConnection和query传入的函数叫做回调函数，JS引擎不会等待数据库返回结果才执行后续代码，所以会先运行外层的console.log("Checkpoint")，等数据库响应后才会执行回调里的逻辑。你在回调外尝试获取查询结果的代码会先执行，此时结果还没返回，自然拿不到有效值。

所有需要用到查询结果的逻辑，必须全部放到query的回调函数内部，示例：

conpool.getConnection(function(err, connection) {
  if (err) throw err;
  connection.query("SELECT * FROM orders", function (err, result, fields) {
    // 用完连接记得释放回连接池
    connection.release();
    if (err) throw err;
    // 所有需要用到result的逻辑都写在这里，比如打印、返回给前端、加工处理
    console.log(result);
    console.log("Checkpoint"); // 现在就会在查询结果之后打印
  });
});

注意：如果逻辑层级多，回调会层层嵌套（俗称回调地狱），代码可读性会变差，更推荐用下面的async/await写法，逻辑顺序和你熟悉的Python同步代码一致。

方式A：用mysql2库自带的Promise接口（不需要手动转换API） #

首先安装mysql2：

npm install mysql2

连接池初始化的时候用mysql2/promise引入：

const mysql = require('mysql2/promise');
// 初始化连接池的配置和之前保持一致即可
const conpool = mysql.createPool({
  host: '你的数据库地址',
  user: '用户名',
  password: '密码',
  database: '库名'
});

之后就可以用async/await写同步风格的异步代码了：

// 所有await语法必须放在async标记的函数内
async function getOrders() {
  let connection;
  try {
    // 等待获取连接
    connection = await conpool.getConnection();
    // 等待查询返回结果，result就是查询得到的数据集，和回调里的result完全一致
    const [result] = await connection.query("SELECT * FROM orders");
    // 在这里可以正常使用result，逻辑顺序和Python同步代码完全一样
    console.log(result);
    console.log("Checkpoint");
    return result;
  } catch (err) {
    // 错误统一捕获处理，等价于Python的try except
    console.error('操作失败：', err);
    throw err;
  } finally {
    // 不管成功失败都释放连接
    if (connection) connection.release();
  }
}

// 调用函数
getOrders();

方式B：用util.promisify手动转换原有回调API #

如果你不想换库，也可以用NodeJS自带的util.promisify把回调式API转成返回Promise的函数，再用async/await调用：

const util = require('util');
// 把回调式API转成Promise风格
const getConnection = util.promisify(conpool.getConnection).bind(conpool);

async function getOrders() {
  let connection;
  try {
    connection = await getConnection();
    // 转query方法
    const query = util.promisify(connection.query).bind(connection);
    const result = await query("SELECT * FROM orders");
    console.log(result);
    console.log("Checkpoint");
    return result;
  } catch (err) {
    console.error('操作失败：', err);
    throw err;
  } finally {
    if (connection) connection.release();
  }
}

getOrders();

• 如果你要做接口返回数据，直接在async的路由处理函数里await查询方法，再把结果return即可，不需要额外处理异步时序问题
• 空数组的问题可以先验证数据库orders表是否真的有数据，异步逻辑调整正确后如果还是返回空，再排查SQL语句和权限问题

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