关系表上的NodeJS PostgreSQL Express SequelizeEagerLoadingError

Question

我遇到了无法从 NodeJS PostgreSQL 和 Express 访问关系数据表的问题。

首先是我的简单表格：

如你所见，我的“jenis”表与“kategori”表有关联，一个jenis可以有多个categori，一个categori只能包含一个jenis。

这是我在 Postgres Sequelize 上的迁移：

jenis-migration.js

"use strict";
module.exports = {
  up: async (queryInterface, Sequelize) => {
    await queryInterface.createTable("Umkm_Jenis", {
      id: {
        allowNull: false,
        autoIncrement: true,
        primaryKey: true,
        type: Sequelize.INTEGER,
      },
      nama: {
        type: Sequelize.STRING,
      },
      createdAt: {
        allowNull: false,
        type: Sequelize.DATE,
      },
      updatedAt: {
        allowNull: false,
        type: Sequelize.DATE,
      },
    });
  },
  down: async (queryInterface, Sequelize) => {
    await queryInterface.dropTable("Umkm_Jenis");
  },
};

categori-migration.js

"use strict";
module.exports = {
  up: async (queryInterface, Sequelize) => {
    await queryInterface.createTable("Umkm_Kategori", {
      id: {
        allowNull: false,
        autoIncrement: true,
        primaryKey: true,
        type: Sequelize.INTEGER,
      },
      jenis_id: {
        type: Sequelize.INTEGER,
        allowNull: false,
      },
      nama: {
        type: Sequelize.STRING,
        allowNull: false,
      },
      createdAt: {
        allowNull: false,
        type: Sequelize.DATE,
      },
      updatedAt: {
        allowNull: false,
        type: Sequelize.DATE,
      },
    });
  },
  down: async (queryInterface, Sequelize) => {
    await queryInterface.dropTable("Umkm_Kategori");
  },
};

jenis.model.js

"use strict";
const { Model } = require("sequelize");
module.exports = (sequelize, DataTypes) => {
  class Umkm_Jenis extends Model {
    /**
     * Helper method for defining associations.
     * This method is not a part of Sequelize lifecycle.
     * The `models/index` file will call this method automatically.
     */
    static associate(models) {
      // define association here
      this.hasMany(models.Umkm_Kategori, {
        foreignKey: "jenis_id",
        as: "umkm_kategori",
      });
    }
  }
  Umkm_Jenis.init(
    {
      nama: DataTypes.STRING,
    },
    {
      sequelize,
      modelName: "Umkm_Jenis",
      freezeTableName: true,
    }
  );
  return Umkm_Jenis;
};

categori-model.js

"use strict";
const { Model } = require("sequelize");
module.exports = (sequelize, DataTypes) => {
  class Umkm_Kategori extends Model {
    /**
     * Helper method for defining associations.
     * This method is not a part of Sequelize lifecycle.
     * The `models/index` file will call this method automatically.
     */
    static associate(models) {
      // define association here
      this.belongsTo(models.Umkm_Jenis, {
        foreignKey: "jenis_id",
        as: "umkm_jenis",
      });
    }
  }
  Umkm_Kategori.init(
    {
      jenis_id: DataTypes.INTEGER,
      nama: DataTypes.STRING,
    },
    {
      sequelize,
      modelName: "Umkm_Kategori",
      freezeTableName: true,
    }
  );
  return Umkm_Kategori;
};

我在 postgres 上为 jenis 和 categori 表创建了一些播种机数据。

现在我希望我的 getAllKategori API 使用我建立的关系实际包含“jenis”表中的值。下面是我的 apiController 类别：

exports.findAllKategori = async (req, res) => {
  //check if theres a filter applied
  const nama = req.query.nama;
  const condition = nama ? { nama: { [Op.iLike]: `%${nama}%` } } : null;

  try {
    const response = Kategori.findAll({
      where: condition,
      include: [{ model: db.jenis, as: "umkm_jenis", required: false }],
    });
    const data = await response;
    return res.status(200).send(data);
  } catch (error) {
    console.log(error);
    return res.status(500).send(error);
  }
};

但是当我尝试从 POSTMAN 访问 API 时，它显示 SequelizeEagerLoadingError。

如果我在 categoriController 上评论了这一行：

  include: [{ model: db.jenis, as: "umkm_jenis", required: false }],

然后尝试再次点击 api，它成功显示了我所有的数据。

我已经在这个论坛上阅读了一些类似的问题，但似乎都没有。

感谢您抽出宝贵时间！

更新

下面是models/index.js文件

"use strict";

const fs = require("fs");
const path = require("path");
const Sequelize = require("sequelize");
const basename = path.basename(__filename);
const env = process.env.NODE_ENV || "development";
const config = require(__dirname + "/../config/config.json")[env];
const db = {};

let sequelize;
if (config.use_env_variable) {
  sequelize = new Sequelize(process.env[config.use_env_variable], config);
} else {
  sequelize = new Sequelize(
    config.database,
    config.username,
    config.password,
    config
  );
}

fs.readdirSync(__dirname)
  .filter((file) => {
    return (
      file.indexOf(".") !== 0 && file !== basename && file.slice(-3) === ".js"
    );
  })
  .forEach((file) => {
    const model = require(path.join(__dirname, file))(
      sequelize,
      Sequelize.DataTypes
    );
    db[model.name] = model;
  });

Object.keys(db).forEach((modelName) => {
  if (db[modelName].associate) {
    db[modelName].associate(db);
  }
});

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

db.kategori = require("./umkm_kategori")(sequelize, Sequelize);
db.jenis = require("./umkm_jenis")(sequelize, Sequelize);
db.produk = require("./umkm_produk")(sequelize, Sequelize);
db.review = require("./umkm_review")(sequelize, Sequelize);

module.exports = db;

console.log(错误)

Answer 1

您已经使用此代码段注册了所有模型和关联：

const model = require(path.join(__dirname, file))(
      sequelize,
      Sequelize.DataTypes
    );
    db[model.name] = model;

和

Object.keys(db).forEach((modelName) => {
  if (db[modelName].associate) {
    db[modelName].associate(db);
  }
});

所以这段代码再次注册模型，只需删除它并使用上面定义的模型名称。

db.kategori = require("./umkm_kategori")(sequelize, Sequelize);
db.jenis = require("./umkm_jenis")(sequelize, Sequelize);
db.produk = require("./umkm_produk")(sequelize, Sequelize);
db.review = require("./umkm_review")(sequelize, Sequelize);