首页 文章

如何执行Sequelize join

提问于
浏览
0

我有一个在nodejs中运行的Express应用程序,并使用Sequelize来处理MySQL数据库 . 在我的数据库逻辑中,我有一个从 ChatRoomUserChatRoom 的1对多关系 . 当我尝试使用此代码预先形成连接时:

var userId = 1;

db.ChatRoom.findAll({ include: [{
                model: db.UserChatRoom,
                where: {
                    ucrIdChatUser:userId 
                },
                required: false
            }]})

我在控制台上收到以下错误消息:

Unhandled rejection Error: UserChatRoom is not associated to ChatRoom!
    at validateIncludedElement

我想让连接查询工作,并希望得到帮助 . 我试图在 index.js 结束时强制执行关联 . 此脚本在应用程序启动时加载此文件夹中的模型,并从Sequlize网站获取 .

注意: UserChatRoom.ucrIdChatRoomUserChat.idChatRoom 的外键

楷模:

module.exports = function(sequelize, DataType){
    var ChatRoom = sequelize.define("ChatRoom",{
        idChatUser: {
            type: DataType.INTEGER,
            autoIncrement: true,
            primaryKey: true
        },
        crName: {
            type: DataType.STRING,
            allowNull: false
        },
        crDateInserted: {
            type: DataType.DATE
        },
        crDateUpdated: {
            type: DataType.DATE
        },
        crIsOpen: {
            type: DataType.INTEGER,
            defaultValue: 0
        }

    })

    return ChatRoom;

}

module.exports = function(sequelize, DataType){
    var UserChatRoom = sequelize.define("UserChatRoom",{
        idUserChatUser: {
            type: DataType.INTEGER,
            autoIncrement: true,
            primaryKey: true
        },
        ucrIdChatUser: {
            type: DataType.INTEGER
        },
        ucrIdChatRoom: {
            type: DataType.INTEGER
        },
        ucrDateInserted: {
            type: DataType.DATE
        },
        ucrDateUpdated: {
            type: DataType.DATE
        }

    })

    return UserChatRoom;

}

index.js

"use strict";

var fs        = require("fs");
var path      = require("path");
var Sequelize = require("sequelize");
var env       = process.env.NODE_ENV || "development";
var config    = require(path.join(__dirname, '..', 'config', 'config.json'))[env];

if (process.env.DATABASE_URL) {
  var sequelize = new Sequelize(process.env.DATABASE_URL,config);
} else {
  var sequelize = new Sequelize(config.database, config.username, config.password, config);
}

var db        = {};

fs
  .readdirSync(__dirname)
  .filter(function(file) {
    return (file.indexOf(".") !== 0) && (file !== "index.js")  && (file.slice(-3) === '.js');
  })
  .forEach(function(file) {
    var model = sequelize.import(path.join(__dirname, file));
    db[model.name] = model;
  });

Object.keys(db).forEach(function(modelName) {
  if ("associate" in db[modelName]) {
    db[modelName].associate(db);
  }
});

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

db.UserChatRoom.hasOne(db.ChatUser);
db.UserChatRoom.hasOne(db.ChatRoom, { foreignKey: 'ucrIdChatRoom' , foreignKeyConstraint:true });

db.ChatUser.belongsTo(db.UserChatRoom, { foreignKey: 'ucrIdChatRoom' , foreignKeyConstraint:true});

db.ChatRoomMessage.hasOne(db.UserChatRoom, { foreignKey: 'crmIdUserChatRoom' , foreignKeyConstraint:true });

module.exports = db;

1 回答

  • 1

    你必须以两种方式定义关系 . UserChatRoom有一个ChatRoom,ChatRoom属于UserChatRoom . 此外,您的关系应放在每个模型中,而不是放在索引中 .

    module.exports = function(sequelize, DataType){
        var ChatRoom = sequelize.define("ChatRoom",{
            idChatUser: {
                type: DataType.INTEGER,
                autoIncrement: true,
                primaryKey: true
            },
            //etc
    
        }, {
          classMethods: {
            //models/index.js calls this function
            associate: function(models) {
              ChatRoom.belongsTo(UserCharRoom, {foreignKey: 'something'});
            }
          }
        })
    
        return ChatRoom;
    
    }
    

相关问题