Node.js MySQL REST API代码优化咨询：连接抽离与关闭问题

1. 抽离createConnection逻辑到单独文件 #

你给出的db.js思路已经很靠谱了，我们可以把它再完善下，甚至升级成连接池（比单次连接更高效），具体步骤如下：

首先创建独立的db.js文件，这里分两种方案：

方案一：基于你提供的单次连接（适合小流量测试场景）

const mysql = require('mysql2/promise');

// 把配置单独抽离，后期改参数更方便
const dbConfig = {
  host: 'localhost',
  user: 'user',
  password: 'pass',
  database: 'database'
};

// 导出获取连接的异步函数
module.exports = async function getDbConnection() {
  try {
    const connection = await mysql.createConnection(dbConfig);
    console.log('数据库连接成功');
    return connection;
  } catch (err) {
    console.error('数据库连接失败:', err);
    throw err; // 抛出错误让上层业务逻辑处理
  }
};

然后在userModel.js里引入使用：

const getDbConnection = require('./db');

async function createUser(userData) {
  const connection = await getDbConnection();
  try {
    const [result] = await connection.execute(
      'INSERT INTO users (name, email) VALUES (?, ?)',
      [userData.name, userData.email]
    );
    return result.insertId;
  } finally {
    // 这里先留个伏笔，后面说关闭连接的问题
    await connection.end();
  }
}

方案二：使用连接池（推荐生产环境）

单次连接在高并发场景下会有性能瓶颈，mysql2/promise原生支持连接池，能自动复用空闲连接，效率高很多：

const mysql = require('mysql2/promise');

const dbConfig = {
  host: 'localhost',
  user: 'user',
  password: 'pass',
  database: 'database',
  waitForConnections: true,
  connectionLimit: 10, // 按需调整最大连接数
  queueLimit: 0
};

// 创建连接池并直接导出
const pool = mysql.createPool(dbConfig);

module.exports = pool;

在userModel.js里直接用连接池：

const pool = require('./db');

async function createUser(userData) {
  const [result] = await pool.execute(
    'INSERT INTO users (name, email) VALUES (?, ?)',
    [userData.name, userData.email]
  );
  return result.insertId;
}

这种方式完全不用手动管理连接的创建和销毁，连接池会自动处理，省心又高效。

2. 是否需要在每次API调用后关闭数据库连接？ #

这个要看你用的是单次连接还是连接池：

• 如果是用方案一的单次连接：每次调用后必须关闭（connection.end()），否则连接会一直占用，时间长了会导致数据库连接耗尽。但这种方式每次请求都要创建新连接，开销很大，不适合高并发场景。
• 如果是用方案二的连接池：绝对不要手动关闭连接！连接池的设计核心就是让连接复用，你调用execute或者query后，连接会自动放回池子里，供下一次请求使用。如果手动关闭了池里的连接，反而会导致连接池需要重新创建连接，浪费资源。

简单总结：生产环境优先用连接池，不用手动关闭连接；小流量测试用单次连接的话，记得在finally块里关闭连接，避免连接泄漏。

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