Sequelize多数据库连接问题：如何关联不同Schema/Model

错误根源 #

你碰到的TypeError: Cannot read properties of undefined (reading 'define')，核心问题是加载模型时传入的sequelize参数没正确指向对应的数据库实例：

• 你给mainDB.sequelize和posAdminDB.sequelize赋值的是全局sequelize变量（大概率未定义）
• 加载模型时直接传了sequelize，而非你创建好的mainDB或posAdminDB实例

修正步骤 #

1. 正确导入Sequelize核心模块

const { Sequelize, DataTypes } = require('sequelize');

2. 删除无效的实例属性赋值

mainDB和posAdminDB本身就是Sequelize实例，不需要额外添加sequelize属性，直接使用即可。删掉以下代码：

mainDB.Sequelize = Sequelize;
mainDB.sequelize = sequelize;

posAdminDB.Sequelize = Sequelize;
posAdminDB.sequelize = sequelize;

3. 为不同数据库实例加载对应模型

加载模型时，传入对应的数据库实例和DataTypes：

// 给mainDB绑定用户模型
mainDB.users = require("../models/user/user")(mainDB, DataTypes);

// 给posAdminDB绑定模型（如果是不同结构的用户表，建议单独创建模型文件，比如user_admin.js）
posAdminDB.adminUsers = require("../models/user/user_admin")(posAdminDB, DataTypes);

4. 完整修正后代码示例

const { Sequelize, DataTypes } = require('sequelize');
const dbConfig = require('./path-to-your-dbConfig');
const adminDB = require('./path-to-your-adminDBConfig');

// 创建数据库1实例
const mainDB = new Sequelize(dbConfig.DB, dbConfig.USER, dbConfig.PASSWORD, {
    dialect: dbConfig.DIALECT,
    host: dbConfig.HOST,
    port: dbConfig.PORT,
    define: {
        timestamps: false,
    },
    operatorsAliases: 0,
    pool: {
        max: dbConfig.pool.max,
        min: dbConfig.pool.min, // 修正你之前的笔误mix→min
        acquire: dbConfig.pool.acquire,
        idle: dbConfig.pool.idle,
    },
});

// 创建数据库2实例
const posAdminDB = new Sequelize(adminDB.DB, adminDB.USER, adminDB.PASSWORD, {
    dialect: adminDB.DIALECT,
    host: adminDB.HOST,
    port: adminDB.PORT,
    define: {
        timestamps: false,
    },
    operatorsAliases: 0,
    pool: {
        max: adminDB.pool.max,
        min: adminDB.pool.min, // 同样修正笔误mix→min
        acquire: adminDB.pool.acquire,
        idle: adminDB.pool.idle,
    },
});

// 绑定模型到对应数据库实例
mainDB.users = require("../models/user/user")(mainDB, DataTypes);
posAdminDB.adminUsers = require("../models/user/user_admin")(posAdminDB, DataTypes);

// 数据库认证（用async/await替代链式then，更易维护）
(async () => {
    try {
        await mainDB.authenticate();
        console.log("Connection has been established with DB:1 successfully");
        
        await posAdminDB.authenticate();
        console.log("Connection has been established with DB:2 successfully");
    } catch (error) {
        console.error("Unable to connect to the database:", error);
    }
})();

额外注意点 #

• 若两个数据库的用户表结构不同，务必为每个数据库单独创建模型文件，避免逻辑混乱
• 你之前的连接池配置里mix是拼写错误，必须改成min，否则会导致连接池参数失效
• 使用async/await处理异步认证逻辑，代码可读性和可维护性更强

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