Node.js动态传入数据库名连接SQL Server失败问题求助

我尝试从前端传入数据库名来连接SQL Server数据库，测试了两种实现方式，其中一种可行，另一种无法正常工作。

方法1（可行） #

app.post('/getDropDown/crop',async(req,res)=>{   
    let dropdownModel = {}
    await sql.connect(
        `Server=cloud.com,1433;
        Database=${req.params.crop};
        User Id=imuser;Password=abc;
        trustServerCertificate=true`,err=>{
        if (err) console.log(err)
        new sql.Request().query(`
        SELECT DISTINCT TBNAME AS "Experiment", TBYEAR AS "Year", TBFLD_NAME AS "Trait"
        FROM dbo.EXP01 t1
        JOIN dbo.EXP02 t2 ON t1.TBID = t2.TBKEXPT
        JOIN dbo.TRD01 t3 ON t2.TBKTRAIT = t3.TBID`,(err,result)=>{ 
            dropdownModel['Year']= Array.from(new Set(result.recordsets[0].map((item)=>item.Year)))      
            dropdownModel['Trait'] = Array.from(new Set(result.recordsets[0].map((item)=>item.Trait)))
            dropdownModel['Exp'] = Array.from(new Set(result.recordsets[0].map((item)=>item.Experiment)))      
            res.send({"data":dropdownModel})          
        })
    })
})

为避免重复编写完整连接字符串，我尝试将连接逻辑抽离为独立函数/模块，但方法2无法正常工作：

方法2（不可行） #

function createDB(dname){
    let connection = 
    `Server=cloud.com,1433,
    Database=${dname},
    User Id=imuser,Password=abc,
    trustServerCertificate=true`  
    return connection
}

app.get('/getDropDown/:crop',async(req,res)=>{
    await sql.connect(createDB(`${req.params.crop}`),err=>{
        if (err) console.log(err)
        new sql.Request().query(`
        SELECT DISTINCT TBNAME AS "Experiment", TBYEAR AS "Year", TBFLD_NAME AS "Trait"
        FROM dbo.EXP01 t1
        JOIN dbo.EXP02 t2 ON t1.TBID = t2.TBKEXPT
        JOIN dbo.TRD01 t3 ON t2.TBKTRAIT = t3.TBID`,(err,result)=>{
            console.log(result)
            })
        }
    )
})

我参考了相关资料编写方法2，但未解决问题，希望得到如何将连接字符串从服务中抽离为可复用函数的帮助。

问题分析与修正方案 #

方法2无法工作的核心问题有两个：

1. 连接字符串格式错误：SQL Server的连接字符串参数分隔符是分号;，但你在createDB函数里用了逗号,，导致连接参数解析失败。
2. 异步逻辑混用问题：同时使用await和回调函数，会导致逻辑异常，建议统一使用Promise/async-await写法，避免回调嵌套。

修正后的可复用连接函数及路由代码：

// 可复用的连接字符串生成函数
function createDBConnectionString(dname) {
    return `Server=cloud.com,1433;Database=${dname};User Id=imuser;Password=abc;trustServerCertificate=true`;
}

// 修正后的路由逻辑，统一用async-await写法
app.get('/getDropDown/:crop', async (req, res) => {
    try {
        // 生成连接字符串并建立连接
        await sql.connect(createDBConnectionString(req.params.crop));
        
        // 执行查询
        const result = await new sql.Request().query(`
            SELECT DISTINCT TBNAME AS "Experiment", TBYEAR AS "Year", TBFLD_NAME AS "Trait"
            FROM dbo.EXP01 t1
            JOIN dbo.EXP02 t2 ON t1.TBID = t2.TBKEXPT
            JOIN dbo.TRD01 t3 ON t2.TBKTRAIT = t3.TBID
        `);
        
        // 处理返回数据
        const dropdownModel = {
            Year: Array.from(new Set(result.recordsets[0].map(item => item.Year))),
            Trait: Array.from(new Set(result.recordsets[0].map(item => item.Trait))),
            Exp: Array.from(new Set(result.recordsets[0].map(item => item.Experiment)))
        };
        
        res.send({ data: dropdownModel });
    } catch (err) {
        // 统一错误处理
        console.error(err);
        res.status(500).send({ error: '数据库连接或查询失败' });
    } finally {
        // 确保连接关闭（按需添加，部分SQL库会自动管理连接）
        await sql.close();
    }
});

额外优化建议 #

• 将固定配置（如Server地址、账号密码）抽离到环境变量中，避免硬编码，提升安全性和可维护性：

  // 从环境变量读取配置
  const config = {
      server: process.env.DB_SERVER || 'cloud.com,1433',
      user: process.env.DB_USER || 'imuser',
      password: process.env.DB_PASSWORD || 'abc',
      trustServerCertificate: true
  };
  
  function createDBConnectionString(dname) {
      return `Server=${config.server};Database=${dname};User Id=${config.user};Password=${config.password};trustServerCertificate=${config.trustServerCertificate}`;
  }
  

• 如果需要频繁切换数据库，考虑使用连接池管理，避免重复建立连接带来的性能损耗。

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