Node.js中MySQL查询执行时机异常及代码修复咨询

嘿，我来帮你搞定这个Node.js + MySQL的异步问题！

你碰到的两个问题——所有查询都在程序末尾执行、getSymbol返回值不符合预期，本质都是因为Node.js里的mysql模块查询是异步非阻塞操作。

简单说：con.query()并不会等数据库返回结果再往下走，它会先把查询任务丢进事件队列，然后直接执行后面的console.log(s)和return s。这时候s还是初始的空字符串，而真正的查询要等整个同步代码跑完，才会在事件循环里被处理，所以才会出现查询扎堆在末尾执行、返回值不对的情况。

另外你的代码还有个小逻辑bug：if (result.length < 1)的时候你去取result[0].Symbol，这时候result是空数组，肯定会报错，逻辑搞反了——应该是result.length > 0的时候才取对应值。

这里给你两种靠谱的修复方式，推荐用第二种，代码更简洁安全：

方案1：用Promise封装原有mysql查询 #

把getSymbol改成返回Promise的函数，这样就能用await或者.then()等待异步结果：

var mysql = require('mysql');
var con = mysql.createConnection({ 
  host: database.host, 
  user: database.user, 
  password: database.password, 
  database: database.database 
});

function getSymbol(id) {
  return new Promise((resolve, reject) => {
    // 重点：改用参数化查询！直接拼接id会有SQL注入风险
    con.query("SELECT * FROM Symbol WHERE PlayerID = ?", [id], function (err, result, fields) {
      if (err) {
        reject(err); // 把错误抛出给调用方处理
        return;
      }
      console.log(result);
      if (result.length > 0) {
        resolve(result[0].Symbol); // 查询到结果就返回Symbol
      } else {
        resolve("!"); // 没查到返回约定的"!"
      }
    });
  });
}

// 调用示例：必须在async函数里用await，或者用.then()
async function getPlayerSymbol() {
  try {
    const symbol = await getSymbol("你的玩家ID");
    console.log("拿到的Symbol：", symbol); // 这里就能拿到正确结果了
  } catch (err) {
    console.error("查询出错：", err);
  }
}

getPlayerSymbol();

方案2：改用mysql2模块（原生支持Promise） #

mysql2是官方推荐的mysql模块升级版本，原生支持Promise，还自带连接池功能（比单个连接更稳定），用起来更顺手：
首先安装依赖：

npm install mysql2

然后改写代码：

const mysql = require('mysql2/promise'); // 导入Promise版本

// 用连接池替代单个连接，自动管理连接生命周期
const pool = mysql.createPool({
  host: database.host,
  user: database.user,
  password: database.password,
  database: database.database,
  connectionLimit: 10, // 连接池最大连接数
  waitForConnections: true
});

async function getSymbol(id) {
  try {
    // 直接用await等待查询结果，参数化查询依然不能忘
    const [rows] = await pool.query("SELECT * FROM Symbol WHERE PlayerID = ?", [id]);
    console.log(rows);
    return rows.length > 0 ? rows[0].Symbol : "!";
  } catch (err) {
    console.error("查询失败：", err);
    throw err; // 把错误抛出给调用方
  }
}

// 调用方式和上面一致
async function main() {
  const symbol = await getSymbol("测试玩家ID");
  console.log("最终拿到的Symbol：", symbol);
}

main();

完全没必要！Node.js处理异步数据库操作非常成熟，只要搞懂了Promise/async-await的逻辑，修改现有代码比从头用Python重写效率高多了。而且Node.js在IO密集型场景（比如数据库查询）的表现也很出色，没必要换语言。

内容的提问来源于stack exchange，提问作者wig on the run