Node.js回调函数问题：MySQL查询后speechText变量未定义

兄弟，我懂你刚学Node.js回调时的头疼——异步这玩意儿一开始真的绕！你的问题核心就是异步操作的执行顺序和变量作用域的锅，听我给你掰扯清楚：

问题根源：异步执行的特性 #

MySQL的connection.query()是异步函数，它不会阻塞主线程等待数据库返回结果，而是直接继续执行后面的代码。你遇到的情况大概是这样的：

var speechText;
// 异步查询：这行代码会先“发起”请求，然后直接跳去执行下面的console.log
connection.query('SELECT content FROM speeches WHERE id = 1', function(err, results) {
  // 这个回调函数要等数据库返回结果后才会执行！
  if (err) throw err;
  speechText = results[0].content;
  console.log(speechText); // 这里能正常输出，因为此时数据库结果已经回来了
});
// 这行代码会先于回调函数执行！此时speechText还没被赋值，自然是undefined
console.log(speechText);

另外如果你的var speechText是写在回调函数内部的，那还会有作用域问题——回调内部声明的变量，外面的代码根本访问不到，直接就会报未定义。

两种解决思路 #

1. 把依赖变量的逻辑放进回调函数里 #

这是最直接的方式：所有需要用到speechText的操作，都必须放在回调函数内部（或者从回调里调用专门处理的函数），这样才能保证变量已经被正确赋值：

connection.query('SELECT content FROM speeches WHERE id = 1', function(err, results) {
  if (err) {
    console.error('数据库查询出错:', err);
    return; // 出错就终止，避免后续代码报错
  }
  const speechText = results[0].content;
  console.log(speechText); // 正常输出
  
  // 在这里执行所有需要用speechText的操作，比如调用其他函数
  doSomethingWithSpeech(speechText);
});

// 专门处理speechText的函数
function doSomethingWithSpeech(text) {
  // 比如转语音、存文件等操作
  console.log('处理后的文本:', text.toUpperCase());
}

2. 改用Promise + async/await（更易读的写法） #

如果觉得回调嵌套太麻烦，可以把异步查询包装成Promise，然后用async/await让代码看起来像同步执行的，可读性会好很多：

// 第一步：把connection.query包装成Promise
function queryDatabase(sql) {
  return new Promise((resolve, reject) => {
    connection.query(sql, function(err, results) {
      if (err) {
        reject(err); // 出错时拒绝Promise
      } else {
        resolve(results); // 成功时返回结果
      }
    });
  });
}

// 第二步：用async函数执行查询
async function getAndProcessSpeech() {
  try {
    // await会等待Promise完成，拿到结果后再继续执行
    const results = await queryDatabase('SELECT content FROM speeches WHERE id = 1');
    const speechText = results[0].content;
    console.log(speechText);
    
    // 后续操作同样放在这里
    doSomethingWithSpeech(speechText);
  } catch (err) {
    // 统一处理错误
    console.error('处理过程出错:', err);
  }
}

// 调用函数
getAndProcessSpeech();

额外提醒 #

• 永远不要在异步回调里直接throw err，因为异步环境下的throw可能会导致未捕获的异常，最好用console.error或者Promise的reject来处理错误。
• 如果你的数据库连接是一次性使用的，记得在查询完成后调用connection.end()关闭连接，避免资源泄漏。

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