如何将MySQL的Promise封装转换为async/await精简写法及相关疑问

你当前手动封装Promise的写法是可运行的，但可以通过工具消除重复的Promise模板代码，不需要每次都手动写new Promise包裹逻辑，有两种常用实现方案：

方案1：使用Node内置的util.promisify转换回调方法 #

const mysql = require("mysql");
const { promisify } = require("util"); // 引入Node内置的promisify工具

const pool = mysql.createPool({
  connectionLimit: 10,
  password: "",
  user: "root",
  database: "usersdb",
  host: "localhost",
  port: "3306",
});

// 将回调风格的query方法转换为返回Promise的方法，注意绑定pool的上下文
const query = promisify(pool.query).bind(pool);

let usersDB = {};

// 直接用async/await写法，代码大幅简化
usersDB.all = async () => {
  return await query("SELECT * FROM users");
};

usersDB.one = async (id) => {
  const results = await query("SELECT * FROM users WHERE id = ?", [id]);
  return results[0];
};

module.exports = usersDB;

方案2：使用支持Promise的mysql2库（更推荐） #

直接安装mysql2依赖，该库官方提供了Promise风格的API，不需要手动转换回调方法：

// 提前安装依赖：npm install mysql2
const mysql = require("mysql2/promise"); // 直接引入Promise版本的API

const pool = mysql.createPool({
  connectionLimit: 10,
  password: "",
  user: "root",
  database: "usersdb",
  host: "localhost",
  port: "3306",
});

let usersDB = {};

// mysql2的query返回值为[查询结果, 字段元数据]，解构取第一位即可拿到数据
usersDB.all = async () => {
  const [results] = await pool.query("SELECT * FROM users");
  return results;
};

usersDB.one = async (id) => {
  const [results] = await pool.query("SELECT * FROM users WHERE id = ?", [id]);
  return results[0];
};

module.exports = usersDB;

注：async函数本质还是返回Promise，上述方法中如果你偏好更简洁的写法，也可以省略async/await直接返回query调用的结果，效果完全一致。

完全合理，属于Express异步路由的标准最佳实践：

• 每个路由的处理逻辑是独立的，各自用async标记异步处理器，通过await调用数据库方法，逻辑清晰无回调嵌套
• 你当前的写法通过try/catch捕获异步操作的异常，统一打印日志并返回500状态码，符合错误处理的规范
• 这种写法的可维护性远高于回调嵌套或者链式.then的写法，没有任何问题

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