Node.js mssql 到 SQL 服务器的多个并发连接相互干扰

我想我会更新这个以防其他人遇到类似的问题。@AlwaysLearning 为我提供了一个链接，指向 mssql npm 文档的一部分，该文档解释了连接池，并在需要访问多个数据库时这样做。我建议通读一遍。

原来mssql的.connect()函数是全局的。如果调用 .connect() 函数时全局池已经连接，它将解析为已经连接的池。这给我带来了麻烦，因为当快速连续发送两个请求时，我的应用程序中会发生以下情况：

1. 请求 1 将连接到数据库 A
2. 请求 2 将尝试连接到数据库 B
3. 由于数据库 A 已经在全局池中连接，请求 2 拿起数据库 A 连接
4. 请求 2 的 SQL 查询失败，因为它对数据库 A 无效

为了解决这个问题，您需要开发一些连接池管理代码。通过这种方式，您可以确保每个必需的数据库连接都有单独的连接池。此外，这是一种加快查询速度的简单方法，因为您不需要每次发出请求时都重新连接到数据库。

npm 文档提供了几个示例帮助文件，但我发现它们对我来说并不理想，而且我无法在我的环境中编译所有代码。我将代码自定义为以下内容：

mssql-connection-pooling.js：

const { ConnectionPool } = require('mssql')
const pools = {}
 
// create a new connection pool
function CreatePool(config) {
    let key = JSON.stringify(config)

    if (GetPool(key))
        throw new Error('Pool already exists')

    pools[key] = (new ConnectionPool(config)).connect()
    return pools[key]
}

// get a connection pool from all pools
function GetPool(name) {
  if (pools[name])
    return pools[name]
  else
    return null
}

// if pool already exists, return it, otherwise create it
function GetCreateIfNotExistPool(config)  {
    let key = JSON.stringify(config)

    let pool = GetPool(key)
    if(pool)
        return pool
    else
        return CreatePool(config)
}

// close a single pool
function ClosePool(config) {
    let key = JSON.stringify(config)

    if (pools[key]) {
        const pool = pools[key];
        delete pools[key];
        pool.close()
        return true
    }
    return false
}

// close all the pools
function CloseAllPools() {
    pools.forEach((pool) => {
        pool.close()
    })
    pools = {}
    return true
}
 
module.exports = {
  ClosePool,
  CloseAllPools,
  CreatePool,
  GetPool,
  GetCreateIfNotExistPool
}

我创建了 GetCreateIfNotExistPool() 函数，您提供了一个数据库连接配置对象。该函数检查池中是否为给定的连接配置存储了一个打开的连接。如果有，它只返回连接池。如果没有，它会创建它然后返回它。

用法示例：

const sql = require("mssql");
let mssql = require('./mssql-pool-management.js')

let exampleDBConfigA = {
    user: 'test',
    password: 'password,
    server: 'SqlServerA', 
    database: 'DatabaseA'
};
let exampleDBConfigB = {
    user: 'test',
    password: 'password,
    server: 'SqlServerB', 
    database: 'DatabaseB'
};

...

// Request 1
try {
    let sqlPool = await mssql.GetCreateIfNotExistPool(exampleDBConfigA)
    let request = new sql.Request(sqlPool)

    // query code
}
catch(error) {
    //error handling
}

...

// Request 2
try {
    let sqlPool = await mssql.GetCreateIfNotExistPool(exampleDBConfigB)
    let request = new sql.Request(sqlPool)

    // query code
}
catch(error) {
    //error handling
}

在这个例子中，请求 1 和 2 可以同时调用，它们的连接不会干扰！