JavaScript函数封装MySQL查询时 return返回undefined的问题排查

本质是JavaScript 异步任务的执行时序与作用域隔离规则导致的，具体可以拆成三点理解：

• mysql库的connection.query是异步非阻塞方法：调用这个方法后，JS线程根本不会等数据库查询走完整个流程，会立刻往下执行外层getData函数的剩余逻辑，等整个外层函数跑完全程，因为函数里没有写任何对外的return语句，默认就会返回undefined。
• 你写在查询回调里的return this.data，是属于这个匿名回调函数的返回值，只会被这个回调自己用，外层的getData函数根本收不到这个返回值，和外层函数的返回逻辑完全没关系。
• 你之前测试时，在回调里直接打印日志能拿到正确结果，是因为打印代码本身就被放在了查询完成的回调里——等数据库响应回来、回调被触发的时候，自然能拿到正确的行数据，但这个触发时机，比外层getData函数返回undefined的时机晚得多。

核心思路是不要试图把异步回调内部的返回值，直接通过外层同步函数的return语句传递出去，可选两种常用实现方式：

方式1：用Promise封装异步查询，配合async/await写同步风格代码 #

这是目前项目开发最常用的写法，可读性最高：

1. 基于mysql2库（或原mysql库的Promise适配版本）初始化支持Promise的连接实例
2. 把getData标记为async函数，用await等待查询结果完成后再return
3. 调用getData的位置必须配套加await，不能在同步逻辑里直接调用拿返回值

示例代码：

// 初始化Promise模式的数据库连接
const promiseConn = connection.promise();

async function getData(userID, guildID) {
    // 先做参数校验，避免空值拼表名报错
    if (!userID || !guildID) return null;
    // 用?作为参数占位符，避免SQL注入风险
    const [rows] = await promiseConn.query(
        `SELECT * FROM data_${guildID} WHERE id = ?`,
        [userID]
    );
    // 等查询真正完成后，再返回结果
    return rows[0];
}

// 正确调用方式：把调用逻辑放在async函数里加await
async function printUserData() {
    const userInfo = await getData(对应的userID, 对应的guildID);
    console.log(userInfo);
}
printUserData();

方式2：保留原生回调写法，通过自定义回调传递结果 #

如果不想引入async/await，就不要依赖外层函数的return传值，而是把外部需要执行的逻辑通过回调参数传入，等查询完成后触发回调：

function getData(userID, guildID, resultCallback) {
    if (!userID || !guildID) return resultCallback(null, null);
    connection.query(
        `SELECT * FROM data_${guildID} WHERE id = ?`,
        [userID],
        (err, rows) => {
            if (err) return resultCallback(err);
            // 查询完成后，把错误和结果传给自定义回调
            resultCallback(null, rows[0]);
        }
    )
}

// 正确调用方式：把需要拿到数据后执行的逻辑写在回调里
getData(对应的userID, 对应的guildID, (err, userInfo) => {
    if (err) throw err;
    console.log(userInfo);
})

• 不要每次调用getData都手动触发connect()然后立刻end()连接：长期来看用连接池复用连接的性能远高于每次新建、断开连接
• 原代码直接把userID、guildID拼接到SQL字符串的写法有SQL注入风险，务必使用数据库驱动提供的参数占位符传值
• 原代码在回调里直接throw err的写法无法被外层捕获，应该通过回调/Promise的reject把错误传递到外层处理

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