Node.js封装MySQL查询方法返回结果始终为undefined如何解决

核心错误点 #

• 异步返回值链路断裂：connection.query是Node.js典型的异步非阻塞API，这是入门阶段最容易踩的时序类经典坑。你在query回调内部写的return result，是这个匿名回调函数本身的返回值，既不会被外层的getAll方法捕获，也不会作为getAll的返回值向外传递。代码实际执行时，getAll会在调用完connection.query后立刻执行后续逻辑走到函数结束，全程没有设置过对外的返回值，外部调用自然拿到undefined。
• 连接关闭时机错误：你在调用connection.query后立刻执行connection.end()，由于查询是异步流程，大概率会出现在查询请求还没完成收发时就强制断开连接，轻则导致查询拿不到结果，重则抛出连接异常。

可落地的修正写法 #

回调透传模式 #

把结果通过外部传入的回调函数传递，等查询流程完全结束后再关闭连接：

// 来自a.js文件
class BlaBla {
  getAll(onQueryDone) {
    const connection = this.mysql.createConnection(this.details);
    connection.connect((connectErr) => {
      if (connectErr) return onQueryDone(connectErr, null);
      
      connection.query("SELECT * FROM todo", function(error, result, fields) {
        // 等查询流程走完再关闭连接
        connection.end();
        if (error) return onQueryDone(error, null);
        onQueryDone(null, result);
      });
    })
  }
}

// 其他模块调用
const blaBla = new BlaBla();
blaBla.getAll((err, result) => {
  if (err) throw err;
  // 此处可拿到正常查询结果
  console.log(result);
})

Promise封装模式（推荐适配async/await写法） #

让getAll方法直接返回Promise对象，支持用接近同步风格的写法等待异步查询结果，避免回调嵌套：

class BlaBla {
  getAll() {
    // getAll 直接返回Promise实例
    return new Promise((resolve, reject) => {
      const connection = this.mysql.createConnection(this.details);
      connection.connect();
      
      connection.query("SELECT * FROM todo", function(error, result) {
        connection.end();
        if (error) return reject(error);
        // 把查询结果通过resolve向外抛出
        resolve(result);
      });
    })
  }
}

// 其他模块调用，搭配async语法即可
const todos = await blaBla.getAll();
console.log(todos);

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