Node.js Sequelize如何实现动态切换数据库，库名从路由参数获取

问题结论 #

Sequelize 实例完成初始化后，没有提供官方方法直接修改已有连接配置切换数据库，但可以通过以下两种方案实现动态切换数据库的需求：

方案1：执行USE语句临时切换当前连接的数据库 #

如果你的场景使用单连接而非连接池，或者可以接受连接级别的临时切换，可以直接执行原生SQL的USE语句修改当前连接的默认数据库：

router.route("/route-name", async (req, res) => {
    const database_name = req.query.database_name;
    // 务必做合法性校验，避免SQL注入风险
    if (!/^[a-zA-Z0-9_]+$/.test(database_name)) {
        return res.status(400).send('非法的数据库名称');
    }
    try {
        // 切换数据库
        await sequelize.query(`USE \`${database_name}\``);
        // 后续正常执行查询即可，操作的就是新切换的数据库
        const data = await sequelize.query('SELECT * FROM your_table');
        res.send(data);
    } catch (err) {
        res.status(500).send('数据库操作失败：' + err.message);
    }
});

注意：如果配置了连接池，该方案会存在串库风险。因为连接池中的连接会被复用，修改某一个连接的默认数据库后，该连接被其他请求复用时会默认使用修改后的数据库，可能导致数据操作到错误的库。

方案2：动态创建Sequelize实例（更推荐） #

针对连接池场景或者多租户多数据库的场景，更稳妥的方案是为每个数据库单独创建Sequelize实例，并且做缓存复用，避免每次请求重复创建实例带来的性能损耗：

// 全局缓存已创建的Sequelize实例
const sequelizeInstances = new Map();

function getSequelizeInstance(dbName) {
    if (sequelizeInstances.has(dbName)) {
        return sequelizeInstances.get(dbName);
    }
    // 复制原有配置，替换数据库名
    const newConfig = { ...config, database: dbName };
    const instance = new Sequelize(newConfig.database, newConfig.username, newConfig.password, newConfig);
    sequelizeInstances.set(dbName, instance);
    return instance;
}

// 路由内使用
router.route("/route-name", async (req, res) => {
    const database_name = req.query.database_name;
    if (!/^[a-zA-Z0-9_]+$/.test(database_name)) {
        return res.status(400).send('非法的数据库名称');
    }
    try {
        const dynamicSequelize = getSequelizeInstance(database_name);
        // 可以提前测试连接可用性
        await dynamicSequelize.authenticate();
        // 执行对应数据库的查询
        const data = await dynamicSequelize.query('SELECT * FROM your_table');
        res.send(data);
    } catch (err) {
        res.status(500).send('数据库操作失败：' + err.message);
    }
});

提示：如果数据库实例数量很多，可以加过期策略，长时间不用的实例自动关闭连接并从缓存中清除，避免占用过多连接资源。

注意事项 #

• 所有用户传入的数据库名称必须做严格的格式校验，禁止直接拼接未校验的内容到SQL语句中，避免SQL注入风险
• 确保配置的数据库账号对所有需要切换的数据库都有对应操作权限
• 如果涉及模型操作，动态实例需要重新注册对应模型，或者使用dynamicSequelize.models来访问对应实例下的模型

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