如何用Node.js和mssql连接两台服务器的SQL数据库并构建连接池

问题原因 #

mssql库的sql.connect()方法默认采用单例模式：第一次调用时会创建一个默认连接池，后续调用如果没有指定唯一的poolName参数，会直接复用已存在的第一个池，完全忽略传入的新配置。这就是你两次调用却得到相同连接池的核心原因。

正确实现方式 #

要创建两个独立的不同服务器连接池，必须手动实例化ConnectionPool对象，而非依赖sql.connect()的快捷方式。每个ConnectionPool实例都是完全独立的，分别对应不同的数据库配置。

示例代码：

const sql = require('mssql');

async function MakeConnection(config1, config2) {
    // 手动创建两个独立的连接池实例
    const poolA = new sql.ConnectionPool(config1);
    const poolB = new sql.ConnectionPool(config2);

    // 并行连接两个池
    await Promise.all([poolA.connect(), poolB.connect()]);

    console.log('池A配置：', poolA.config.server);
    console.log('池B配置：', poolB.config.server);

    // 返回两个独立池供后续使用
    return { poolA, poolB };
}

跨服务器查询的两种可行思路 #

1. 应用层关联数据：从两个池分别查询数据，在Node.js代码中完成结果合并

   async function crossServerQuery(poolA, poolB) {
       // 从服务器A获取数据
       const resultA = await poolA.request().query('SELECT id, name FROM TableA');
       // 从服务器B获取数据
       const resultB = await poolB.request().query('SELECT id, value FROM TableB');
       // 根据关联字段合并结果
       const combined = resultA.recordset.map(itemA => ({
           ...itemA,
           ...resultB.recordset.find(itemB => itemB.id === itemA.id)
       }));
       return combined;
   }
   

2. 数据库端配置链接服务器（仅适用于SQL Server）：在其中一个数据库上配置指向另一服务器的链接，直接通过单个连接池执行跨服务器关联查询（需数据库管理员权限配置）

   // 假设服务器A已配置指向服务器B的链接服务器LinkedServerB
   async function linkedServerQuery(poolA) {
       const result = await poolA.request().query(`
           SELECT a.name, b.value
           FROM TableA a
           JOIN LinkedServerB.DBName.dbo.TableB b ON a.id = b.id
       `);
       return result.recordset;
   }
   

关键注意事项 #

• 每个连接池使用完毕后，务必调用pool.close()释放资源，避免内存泄漏
• 可在连接池配置中设置pool.max参数调整最大连接数，满足多连接需求
• 确保两台服务器的数据库配置（主机、端口、账号、数据库名）完全正确

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