将自定义MySQL2连接池接入Knex时遭遇查询阻塞问题

你的问题出在直接将mysql2的连接池/原始连接传入Knex的connection()方法，Knex无法正确处理这类外部连接的生命周期，导致连接未被释放，阻塞了事件循环，最终查询卡住。以下是具体解决方案：

方案一：让Knex直接管理mysql2连接池（推荐） #

无需手动创建mysql2连接池，Knex内部会基于mysql2实现连接池管理，配置更简单且不易出错：

import knex from "knex";

// 直接配置Knex使用mysql2并管理连接池
const knexC = knex({
  client: "mysql2",
  connection: {
    host: "localhost",
    user: "user",
    password: "pass",
    database: "db",
  },
  // 可选：自定义连接池参数，根据业务需求调整
  pool: {
    min: 2,
    max: 10,
    acquireTimeoutMillis: 60000,
  },
});

(async () => {
  try {
    const res = await knexC("user").select("*");
    console.log(res);
  } catch (err) {
    console.error("查询失败:", err);
  } finally {
    // 脚本执行完毕后销毁连接池，避免内存泄漏
    await knexC.destroy();
  }
})();

方案二：手动使用mysql2连接池时的正确姿势 #

如果必须用自己创建的mysql2连接池，需要用Knex的wrapConnection方法包装连接，并且用完必须释放连接回池：

import knex from "knex";
import mysql from "mysql2/promise";

export const mysqlPool = mysql.createPool({
  host: "localhost",
  user: "user",
  password: "pass",
  database: "db",
});

const knexC = knex({
  client: "mysql2",
});

(async () => {
  let connection;
  try {
    // 从mysql2池获取连接
    connection = await mysqlPool.getConnection();
    // 用Knex包装连接，让Knex能正确处理它
    const wrappedConnection = knexC.client.wrapConnection(connection, knexC.client);
    
    const newRes = await knexC("user").connection(wrappedConnection).select("*");
    console.log(newRes);
  } catch (err) {
    console.error("查询失败:", err);
  } finally {
    // 必须释放连接回池，否则连接会被耗尽
    if (connection) connection.release();
    // 销毁Knex实例
    await knexC.destroy();
  }
})();

问题根源解释 #

• Knex的connection()方法仅接受Knex自身创建的连接，或经过它包装的外部连接。直接传入mysql2的Pool/原始连接，Knex无法识别连接的释放逻辑，导致连接被永久占用，事件循环阻塞，查询无法返回结果。
• 手动获取mysql2连接后，如果不调用release()，连接池会被耗尽，后续所有请求都会卡住。

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