如何在运行时切换Node.js的MySQL数据库连接？附代码示例

嘿，看来你想在Node.js里实现运行时切换MySQL数据库连接对吧？我来给你梳理几个实用的方案，比你现在写的固定双连接要灵活得多！

你当前的代码提前创建了两个固定的连接实例，但如果要在业务运行过程中灵活切换（比如根据用户操作、业务逻辑切换不同数据库），可以用下面两种更合理的方式来管理连接：

方案一：动态切换单连接实例 #

我们可以维护一个「当前活跃连接」变量，通过函数来切换不同的数据库配置，同时记得关闭旧连接避免资源泄漏：

var mysql = require('mysql');

// 先定义好所有需要用到的数据库配置
const dbConfigs = {
  test: {
    host: 'localhost',
    user: 'root',
    password: '',
    database: 'test'
  },
  test1: {
    host: 'localhost',
    user: 'root',
    password: '',
    database: 'test1'
  }
};

// 保存当前活跃的数据库连接
let currentConnection;

// 切换数据库的核心函数
function switchToDatabase(dbName) {
  // 如果已有活跃连接，先关闭它
  if (currentConnection) {
    currentConnection.end(err => {
      if (err) console.error('关闭旧连接失败:', err);
    });
  }

  // 根据配置创建新连接并激活
  currentConnection = mysql.createConnection(dbConfigs[dbName]);
  
  currentConnection.connect(err => {
    if (err) throw err;
    console.log(`成功切换到数据库 ${dbName}！`);
  });
  
  return currentConnection;
}

// 示例：初始连接test数据库
switchToDatabase('test');

// 模拟运行时切换到test1数据库（比如在某个API接口、定时任务里调用）
setTimeout(() => {
  const activeConn = switchToDatabase('test1');
  // 用新连接执行查询
  activeConn.query('SELECT 1+1 AS result', (err, results) => {
    if (err) throw err;
    console.log('test1数据库查询结果:', results[0].result);
  });
}, 2000);

方案二：使用连接池（更推荐） #

如果你的应用需要频繁切换数据库，用连接池会更高效——它能自动复用连接，避免频繁创建/销毁连接的性能开销：

var mysql = require('mysql');

// 为每个数据库创建独立的连接池
const dbPools = {
  test: mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: '',
    database: 'test',
    connectionLimit: 10 // 配置连接池最大连接数
  }),
  test1: mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: '',
    database: 'test1',
    connectionLimit: 10
  })
};

// 获取指定数据库的连接池
function getDbPool(dbName) {
  return dbPools[dbName];
}

// 示例：使用test数据库查询
getDbPool('test').query('SELECT * FROM your_table', (err, results) => {
  if (err) throw err;
  console.log('test数据库查询结果:', results);
});

// 运行时切换到test1数据库查询
getDbPool('test1').query('SELECT * FROM another_table', (err, results) => {
  if (err) throw err;
  console.log('test1数据库查询结果:', results);
});

关键注意事项 #

• 用单连接切换时，一定要记得关闭旧连接，否则会造成数据库连接泄漏
• 连接池方式不需要手动管理连接的开闭，性能更优，适合高频切换场景
• 可以根据业务需求随时扩展dbConfigs或dbPools，添加更多数据库配置

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