Sequelize多模型文件关联报错及控制器调用方法失效问题

初始关联报错根因 #

首次出现的ProductMember is not associated to Product错误，核心原因是你定义在模型上的associate方法从未被执行。
你虽然在每个模型文件里单独写了关联配置，但没有在所有模型加载完成后统一调用这些associate方法，Sequelize没有注册这些关联关系，做预加载查询时自然会报关联不存在的错误。 #

结构调整后findByPk is not a function报错根因 #

你采用的统一加载模型、批量注册关联的思路是正确的，但代码里存在两处错误导致调用失效：

1. 模型文件内部写法错误：你在模型导出的工厂函数里写了未定义的db变量调用逻辑，模型定义过程直接失败，返回的不是合法的Sequelize模型实例。
2. 控制器引入逻辑错误：调整结构后模型由db初始化文件统一注册，你仍然直接从../models/user.js路径引入，拿到的是导出的工厂函数而非初始化完成的模型类，自然不存在findByPk这类模型方法；后续尝试db.sequelize.User的写法也不对，db.sequelize是数据库连接实例，不会挂载模型，所以会报undefined错误。

分步修复操作 #

1. 修正所有模型文件写法 #

所有模型文件严格遵循以下结构，以user.js为例：

const { DataTypes } = require("sequelize");
// 导出工厂函数，参数由db初始化文件传入
module.exports = (sequelize) => {
  const User = sequelize.define(
    "User",
    {
      id: {
        type: DataTypes.INTEGER,
        primaryKey: true,
        autoIncrement: true,
        allowNull: false,
      },
      email: {
        type: DataTypes.STRING(255),
        allowNull: false,
        unique: true,
        isEmail: true,
      },
      username: {
        type: DataTypes.STRING(15),
        allowNull: false,
        unique: true,
      },
    },
    {
      tableName: "users",
    }
  );

  User.associate = (models) => {
    User.belongsToMany(models.Product, {
      through: models.ProductMember,
      foreignKey: "user_id",
      otherKey: "product_id",
    });
    User.hasMany(models.ProductMember, {
      foreignKey: "user_id",
      allowNull: false,
    });
    User.belongsToMany(models.Product, {
      through: models.UserFavouriteProducts,
      foreignKey: "user_id",
      otherKey: "product_id",
    });
  };

  // 返回定义完成的模型实例
  return User;
};

其余product.js、productMember.js按相同规则调整：

• 删除模型文件内所有const sequelize = require("../db")的引入语句
• 用函数传入的sequelize参数调用define方法，不要引用未定义的变量
• 保留原有的associate关联配置
• 函数末尾返回定义好的模型实例

2. 修正数据库初始化文件 #

补充环境变量默认值，修正模型加载逻辑，完整代码如下：

const fs = require('fs');
const path = require('path');
const basename = path.basename(module.filename);
const modelsDir = path.join(__dirname, '../models');
const db = {};

const { Sequelize, DataTypes } = require("sequelize");
const config = require("./db.config.js");
// 默认使用development环境配置，避免环境变量缺失导致连接失败
const env = process.env.NODE_ENV || 'development';
const sequelize = new Sequelize(config[env]);

// 遍历加载models目录下所有模型文件
fs.readdirSync(modelsDir)
  .filter(file => {
    return (file.indexOf('.') !== 0) && (file !== basename) && (file.slice(-3) === '.js');
  })
  .forEach(file => {
    const modelFactory = require(path.join(modelsDir, file));
    const model = modelFactory(sequelize, DataTypes);
    db[model.name] = model;
  });

// 所有模型加载完成后，批量执行associate方法注册关联
Object.keys(db).forEach(modelName => {
  if (db[modelName].associate) {
    db[modelName].associate(db);
  }
});

db.sequelize = sequelize;
db.Sequelize = Sequelize;

module.exports = db;

3. 修正控制器的模型引入方式 #

所有需要调用模型的业务文件，统一引入db初始化文件，从db对象上获取已注册的模型：

// 正确引入方式
const db = require("../db");
const User = db.User;

const ensureLoggedIn = async (req, res, next) => {
  // 其他业务逻辑
  const user = await User.findByPk(id);
  // 后续逻辑
}

验证方法 #

修改完成后可按以下顺序验证：

• 调用db.sequelize.authenticate()确认数据库连接正常
• 打印db.User、db.Product、db.ProductMember，确认associations属性下已挂载所有配置的关联关系
• 测试普通查询、带include的预加载查询，确认无报错

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