Sequelize多库连接下model.init()覆盖不同连接模型实例问题

问题场景 #

应用启动时为多租户对接各自数据库，将模型实例存储在Map中，但先初始化的租户模型连接会被后续租户的Model.init()操作覆盖。

模型定义 #

import { Model } from 'sequelize';

export class ExampleModel extends Model {
    static init(sequelize, options) {
        return super.init(
            {/* 模型字段定义 */}, 
            {
                sequelize, // 该连接会被后续init调用覆盖
                ...options
            }
        );
    }
}

初始化代码 #

for (const tenant of tenants) {
   modelMap.set(tenant, new Map());
   const tenantDB = new Sequelize(/* 租户数据库配置 */);
   
   ExampleModel.init(tenantDB, {});
   modelMap.get(tenant).set('ExampleModel', ExampleModel);
}

问题表现 #

1. 初始化租户1的数据库连接conn1后，验证模型连接正确：

modelMap.get(<tenant1>).get('ExampleModel').options.sequelize.connectionManager.config.database
-> conn1 // 结果正确

2. 初始化租户2的数据库连接conn2后，租户1的模型连接被覆盖：

modelMap.get(<tenant1>).get('ExampleModel').options.sequelize.connectionManager.config.database
-> conn2 // 结果错误，连接被覆盖

问题根源 #

Sequelize的Model.init()方法是修改类的静态属性，同一个Model类的所有调用会共享这些静态属性。多次调用同一个类的init()，后续配置会直接覆盖之前的静态属性（包括sequelize连接实例），导致所有租户的模型最终指向最后一次初始化的数据库连接。

解决方案：为每个租户创建独立的模型类 #

不要复用同一个Model类，通过工厂函数为每个租户生成独立的模型子类，确保每个模型类的静态属性互不干扰。

1. 改造模型为工厂函数 #

import { Model } from 'sequelize';

// 工厂函数：为每个数据库连接生成独立的模型类
export function createExampleModel(sequelize) {
  class ExampleModel extends Model {}

  ExampleModel.init(
    {/* 模型字段定义 */},
    {
      sequelize,
      modelName: 'ExampleModel', // 保持模型名称一致，不影响数据库表名
      // 其他模型配置
    }
  );

  return ExampleModel;
}

2. 修改初始化逻辑 #

for (const tenant of tenants) {
  modelMap.set(tenant, new Map());
  const tenantDB = new Sequelize(/* 租户数据库配置 */);
  
  // 为当前租户生成专属的模型实例
  const tenantExampleModel = createExampleModel(tenantDB);
  modelMap.get(tenant).set('ExampleModel', tenantExampleModel);
}

验证结果 #

改造完成后，每个租户的模型都会绑定对应的数据库连接，不会再出现覆盖问题：

// 租户1的模型连接
modelMap.get(<tenant1>).get('ExampleModel').options.sequelize.connectionManager.config.database
-> conn1 // 结果正确

// 租户2的模型连接
modelMap.get(<tenant2>).get('ExampleModel').options.sequelize.connectionManager.config.database
-> conn2 // 结果正确

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