我有一个在nodejs中运行的Express应用程序,并使用Sequelize来处理MySQL数据库 . 在我的数据库逻辑中,我有一个从 ChatRoom
到 UserChatRoom
的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.ucrIdChatRoom
是 UserChat.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 回答
你必须以两种方式定义关系 . UserChatRoom有一个ChatRoom,ChatRoom属于UserChatRoom . 此外,您的关系应放在每个模型中,而不是放在索引中 .