Sequelize 模型关联深度解析：解决 hasMany 错误与循环引用

const { DataTypes } = require("sequelize");
const { sequelize } = require("./index"); // 假设index.js管理sequelize实例

const Users = sequelize.define("Users", {
    username: {
        type: DataTypes.STRING,
        allowNull: false,
        unique: true,
        validate: {
            min: 5,
            max: 30,
            notNull: true,
        },
    },
});

// 不再在此处定义 Users.hasMany(Comments)

module.exports = Users;

const { DataTypes } = require("sequelize");
const { sequelize } = require("./index"); // 假设index.js管理sequelize实例

const Comments = sequelize.define("Comments", {
    comment: {
        type: DataTypes.STRING,
        allowNull: false,
        validate: {
            min: 1,
            max: 50,
        },
    },
});

// 不再在此处定义 Comments.belongsTo(Users)

module.exports = Comments;

const Users = require("./user");
const Comments = require("./comment");
const { sequelize } = require("./index"); // 导入sequelize实例

/**
 * 定义所有模型之间的关联关系。
 * 这个函数应该在所有模型被定义之后，且在数据库同步/应用程序启动之前调用。
 */
const defineAssociations = () => {
    // 定义 Users 和 Comments 之间的一对多关系
    Users.hasMany(Comments, {
        foreignKey: "userId", // Comments 表中存储 Users ID 的字段
        onDelete: "cascade", // 当 Users 被删除时，相关的 Comments 也被删除
    });

    Comments.belongsTo(Users, {
        foreignKey: "userId", // Comments 表中存储 Users ID 的字段
        onDelete: "cascade", // 当 Users 被删除时，相关的 Comments 也被删除
    });

    // 可以在这里定义其他模型的所有关联...
};

/**
 * 初始化数据库，包括定义关联和同步模型。
 * @returns {Promise<void>}
 */
const initializeDatabase = async () => {
    defineAssociations(); // 首先定义关联
    await sequelize.sync({ alter: true }); // 然后同步数据库，根据模型定义更新表结构
    console.log("数据库模型已同步并关联定义完成。");
};

module.exports = {
    defineAssociations,
    initializeDatabase,
};

const express = require("express");
const app = express();
const { initializeDatabase } = require("./models/associations"); // 导入初始化函数
const { sequelize } = require("./models/index"); // 导入sequelize实例，用于连接测试等

// 导入路由，例如：
const commentRoutes = require("./routes/commentRoutes");

// 中间件等配置...
app.use(express.json());

// 使用路由
app.use("/api/comments", commentRoutes);

// 数据库初始化和服务器启动
const startServer = async () => {
    try {
        await sequelize.authenticate(); // 测试数据库连接
        console.log("数据库连接成功。");

        await initializeDatabase(); // 定义关联并同步模型

        const PORT = process.env.PORT || 3000;
        app.listen(PORT, () => {
            console.log(`服务器运行在端口 ${PORT}`);
        });
    } catch (error) {
        console.error("无法连接到数据库或启动服务器:", error);
        process.exit(1); // 退出应用
    }
};

startServer();

const Comments = require("../models/comment");
const Users = require("../models/user"); // 同样需要导入 Users 模型，但不是为了定义关联

const getComments = async (req, res) => {
    try {
        const comments = await Comments.findAll({
            include: [{
                model: Users, // 指定要包含的模型
                attributes: ["username"] // 只获取 username 字段，避免敏感信息泄露
            }],
        });
        res.status(200).json(comments);
    } catch (error) {
        console.error("获取评论失败:", error);
        res.status(500).json({ message: "获取评论失败", error: error.message });
    }
};

module.exports = {
    getComments,
};