基于Node.js/Express/Sequelize的多数据库连接配置求助

我正在开发一个数据库查询API，用户需通过凭证登录生成JWT令牌，这部分流程正常。但每个用户对应独立数据库，我用中心数据库存储用户表及各用户的数据库连接信息。目前登录后能获取用户的数据库连接信息并赋值给全局变量，再通过中间件重新分配数据库连接，但始终报错无法连接目标数据库。以下是登录代码和切换数据库中间件代码，求解决方案。

原登录代码 #

// 用户登录接口
async function login(req, res) {
    const { nombre, password } = req.body;
    
    // 从中心库查找用户
    const user = await User.findOne({ where: { nombre } });

    if (!user) {
        return res.status(401).json({ message: 'Credenciales inválidas' });
    }

    // 验证密码
    const passwordMatches = await bcrypt.compare(password, user.password);

    if (!passwordMatches) {
        return res.status(401).json({ message: 'Credenciales inválidas' });
    }

    // 生成JWT令牌
    const token = jwt.sign({ userId: user.id }, jwtConfig.secret);

    // 获取用户对应的企业ID
    const lnIdUsuario = user.id_empresa;

    try {
        // 获取企业数据库连接配置
        const profile = await Profile.findOne({ where: { id: lnIdUsuario } });

        if (!lnIdUsuario) {
            return res.status(400).json({ message: 'Invalid company ID' });
        }

        console.log(profile.dbname_empresa);
        console.log(profile.ip_empresa);
        
        // 全局存储数据库配置
        global.configFile = {
            database: profile.dbname_empresa,
            username: 'dbName',
            password: profile.dbpw_empresa,
            host: profile.ip_empresa,
            port: profile.port_empresa,
            dialect: 'mysql'
        };
    } catch (error) {
        console.error(error);
        res.status(500).json({ message: 'Internal server error.'});
    }
    
    res.json({ token });
    req.session.internalToken = token;
}

原数据库切换中间件 #

const Sequelize = require("sequelize");
const sequelize = require('../config/database.js');

function switchDatabase(req, res, next) {
    const credentials = {
        database: global.configFile.database,
        username: global.configFile.username,
        password: global.configFile.password,
        host: global.configFile.host,
        dialect: 'mysql',
        port: global.configFile.port
    };
    const newConnection = new sequelize(credentials);

    req.app.set('sequelize', newConnection);

    next();
}

核心问题分析 #

• 全局变量线程安全问题：global.configFile会被多并发请求互相覆盖，导致后续请求拿到错误的数据库配置
• Sequelize实例初始化错误：new sequelize(credentials)写法错误，应使用大写Sequelize（与导入的构造函数一致）
• 硬编码用户名：登录代码中username: 'dbName'是固定值，未从用户配置中获取真实数据库用户名
• 无连接验证：新创建的Sequelize实例未验证连接有效性，直接替换会导致后续操作报错
• 配置与用户无绑定：全局存储的配置未与用户令牌/会话关联，无法区分不同用户的数据库连接

修复后的代码实现 #

1. 登录接口修改（移除全局变量，将配置存入JWT） #

// 用户登录接口
async function login(req, res) {
    const { nombre, password } = req.body;
    
    // 从中心库查找用户
    const user = await User.findOne({ where: { nombre } });
    if (!user) {
        return res.status(401).json({ message: '凭证无效' });
    }

    // 验证密码
    const passwordMatches = await bcrypt.compare(password, user.password);
    if (!passwordMatches) {
        return res.status(401).json({ message: '凭证无效' });
    }

    // 验证企业ID有效性
    const lnIdUsuario = user.id_empresa;
    if (!lnIdUsuario) {
        return res.status(400).json({ message: '无效的企业ID' });
    }

    try {
        const profile = await Profile.findOne({ where: { id: lnIdUsuario } });
        if (!profile) {
            return res.status(400).json({ message: '未找到企业数据库配置' });
        }

        // 将数据库配置存入JWT Payload（敏感信息建议加密）
        const tokenPayload = {
            userId: user.id,
            dbConfig: {
                database: profile.dbname_empresa,
                username: profile.dbuser_empresa, // 替换为真实字段名
                password: profile.dbpw_empresa,
                host: profile.ip_empresa,
                port: profile.port_empresa,
                dialect: 'mysql'
            }
        };

        // 生成带配置的JWT令牌
        const token = jwt.sign(tokenPayload, jwtConfig.secret, { expiresIn: '2h' });

        res.json({ token });
        req.session.internalToken = token;
    } catch (error) {
        console.error(error);
        res.status(500).json({ message: '服务器内部错误' });
    }
}

2. 数据库切换中间件修改（从JWT获取配置，验证连接） #

const Sequelize = require("sequelize");
const jwt = require('jsonwebtoken');
const jwtConfig = require('../config/jwtConfig.js'); // 引入JWT配置

async function switchDatabase(req, res, next) {
    try {
        // 解析请求头中的JWT令牌
        const authHeader = req.headers.authorization;
        if (!authHeader || !authHeader.startsWith('Bearer ')) {
            return res.status(401).json({ message: '未提供有效令牌' });
        }

        const token = authHeader.split(' ')[1];
        const decoded = jwt.verify(token, jwtConfig.secret);
        const dbConfig = decoded.dbConfig;

        // 初始化Sequelize实例
        const newConnection = new Sequelize(
            dbConfig.database,
            dbConfig.username,
            dbConfig.password,
            {
                host: dbConfig.host,
                port: dbConfig.port,
                dialect: dbConfig.dialect,
                logging: false // 可选：关闭日志输出
            }
        );

        // 验证数据库连接
        await newConnection.authenticate();

        // 将连接挂载到请求对象，供后续接口使用
        req.sequelize = newConnection;

        next();
    } catch (error) {
        console.error('数据库连接切换失败:', error);
        res.status(500).json({ message: '数据库连接失败' });
    }
}

额外优化建议 #

• 连接池复用：维护一个连接池缓存，以用户ID或数据库名称为key，避免重复创建连接
• 敏感信息加密：JWT Payload是Base64明文，数据库密码等敏感信息需加密后存入
• 错误细化：捕获连接错误时，返回更具体的信息（如主机不可达、用户名密码错误）
• 会话隔离：若使用Session存储配置，需确保会话完全隔离，避免跨用户污染

内容的提问来源于stack exchange，提问作者Alejandro García