如何使用Node.js（mysql2）从SQL查询获取数据并在函数外部使用

嘿，你遇到的这个问题核心在于Node.js的异步执行特性，和Python那种同步阻塞的逻辑不一样。Python里函数执行到return会直接返回结果，但Node.js中connection.query是异步操作，它的回调函数会在SQL查询完成后才执行，这时候外部的console.log(sqlGetNewId())早就跑完了，自然拿不到数据。

下面给你两种常用的解决方案：

方案一：使用回调函数 #

把需要使用数据的逻辑放到回调里，或者通过回调函数把结果传递出去：

const mysql = require("mysql2");

function sqlGetNewId(connection, callback) {
  const sql = `SELECT * FROM item WHERE 1`;
  connection.query(sql, function(err, results) {
    if(err) {
      console.log(err);
      callback(err, null);
      return;
    }
    const count = results.length;
    callback(null, count); // 把结果通过回调传出去
    connection.end();
  });
}

// 使用方式
const connection = mysql.createConnection({
  // 你的数据库配置：host, user, password, database等
});

sqlGetNewId(connection, (err, count) => {
  if(err) {
    // 处理错误
    return;
  }
  console.log(count); // 这里就能拿到结果并使用了
});

方案二：使用Promise + async/await（推荐） #

mysql2其实支持Promise接口，我们可以用它来封装异步操作，配合async/await写出和Python逻辑类似的同步风格代码：

const mysql = require("mysql2/promise"); // 引入Promise版本的mysql2

async function sqlGetNewId() {
  // 创建连接（也可以用连接池）
  const connection = await mysql.createConnection({
    // 你的数据库配置
  });
  
  try {
    const sql = `SELECT * FROM item WHERE 1`;
    const [results] = await connection.query(sql); // await等待查询完成
    return results.length;
  } catch (err) {
    console.log(err);
    throw err; // 抛出错误让外部处理
  } finally {
    await connection.end(); // 确保连接关闭
  }
}

// 使用方式
(async () => {
  try {
    const count = await sqlGetNewId();
    console.log(count); // 这里可以正常获取并使用结果
  } catch (err) {
    // 处理错误
  }
})();

为什么这样可行？ #

• await会暂停async函数的执行，直到Promise状态变为resolved，这样就能像Python一样等待SQL查询完成后再获取结果。
• 用try/catch可以优雅地处理查询过程中的错误，和Python的try/except逻辑一致。

内容的提问来源于stack exchange，提问作者VR BOX TULA