我正在尝试进行 Sequelize 查询，但它一直告诉我我的模型没有关联。但我确实声明了一个关联...我想我根本不像我想象的那样理解关联...
我制作了一个存储库，您可以克隆它来亲自查看问题:https://github.com/WaltzApp/sequelize-troubleshooting
我认为我遇到这个问题的原因是 Sequelize 不支持复合外键，所以我必须在连接中使用自定义 on 子句，但它没有按预期工作，因为我无法在关联本身中指定相同的连接方法。这就解释了为什么我有时会得到 Sequelize 打印出功能完美的 SQL，但查询仍然失败(大概是因为虽然数据库查询成功，但将结果转换为 Sequelize entiteis 失败)。
此复制工作的先前版本也复制如下:
相关型号
用户角色:
module.exports = (sequelize, DataTypes) => {
const usersRoles = sequelize.define('usersRoles',
{
key: {
type: DataTypes.UUID,
primary: true,
},
userUid: {
type: DataTypes.UUID,
allowNull: false,
},
roleUid: {
type: DataTypes.UUID,
allowNull: false,
},
oemUid: {
type: DataTypes.UUID,
allowNull: true,
},
propertyManagerUid: {
type: DataTypes.UUID,
allowNull: true,
},
tenantUid: {
type: DataTypes.UUID,
allowNull: true,
},
[MORE FIELDS IRRELEVANT TO MY PROBLEM]
},
{
tableName: 'usersRoles',
indexes: [
{
name: 'userRoleOem',
fields: ['userUid', 'roleUid', 'oemUid'],
unique: true,
where: {
oemUid: { $ne: null },
propertyManagerUid: null,
tenantUid: null,
},
},
{
name: 'userRolePropertyManager',
fields: ['userUid', 'roleUid', 'propertyManagerUid'],
unique: true,
where: {
oemUid: null,
propertyManagerUid: { $ne: null },
tenantUid: null,
},
},
{
name: 'userRoleTenant',
fields: ['userUid', 'roleUid', 'tenantUid'],
unique: true,
where: {
oemUid: null,
propertyManagerUid: null,
tenantUid: { $ne: null },
},
},
{
name: 'compositePK',
fields: ['userUid', 'roleUid', 'oemUid', 'propertyManagerUid', 'tenantUid'],
unique: true,
},
],
freezeTableName: true,
timestamps: false,
});
usersRoles.removeAttribute('id');
usersRoles.associate = (models) => {
models.usersRoles.belongsTo(models.oems, { foreignKey: 'oemUid' });
models.usersRoles.belongsTo(models.propertyManagers, { foreignKey: 'propertyManagerUid' });
models.usersRoles.belongsTo(models.tenants, { foreignKey: 'tenantUid' });
models.usersRoles.belongsTo(models.users, { foreignKey: 'userUid' });
models.usersRoles.belongsTo(models.roles, { foreignKey: 'roleUid' });
models.usersRoles.belongsTo(models.invitations, { as: 'invitation', foreignKey: 'compositePK' });
};
return usersRoles;
};
邀请:
module.exports = (sequelize, DataTypes) => {
const invitations = sequelize.define('invitations',
{
uid: {
type: DataTypes.UUID,
primaryKey: true,
},
guestUid: {
type: DataTypes.UUID,
allowNull: true,
},
mappingGroupUid: {
type: DataTypes.UUID,
allowNull: true,
},
invitedByUid: {
type: DataTypes.UUID,
allowNull: false,
},
adminUid: {
type: DataTypes.UUID,
allowNull: true,
},
propertyManagerUid: {
type: DataTypes.UUID,
allowNull: true,
},
tenantUid: {
type: DataTypes.UUID,
allowNull: true,
},
[MORE FIELDS IRRELEVANT TO MY PROBLEM]
}, {
tableName: 'invitations',
freezeTableName: true,
timestamps: false,
});
invitations.associate = (models) => {
models.invitations.belongsTo(models.propertyManagers, { foreignKey: 'propertyManagerUid' });
models.invitations.belongsTo(models.tenants, { foreignKey: 'tenantUid' });
models.invitations.belongsTo(models.mappingGroups, { foreignKey: 'mappingGroupUid' });
models.invitations.belongsTo(models.users, { as: 'guest', foreignKey: 'guestUid' });
models.invitations.belongsTo(models.users, { as: 'invitedBy', foreignKey: 'invitedByUid' });
models.invitations.belongsTo(models.users, { as: 'admin', foreignKey: 'adminUid' });
models.invitations.hasMany(models.usersRoles, { as: 'invitation', foreignKey: 'compositePK' });
};
return invitations;
};
请注意，上面我将 invitations 和 usersRoles 模型与行 models.invitations.hasMany(models.usersRoles, {foreignKey: 'compositePK' } 关联起来)。
查询
const path = require('path');
const glob = require('glob');
const Promise = require('bluebird');
const Sequelize = require('sequelize');
const configs = require('./test/_helpers/getConfigs');
const models = {};
const performQuery = (db) => {
const { usersRoles, invitations } = db; // eslint-disable-line max-len
const sql = {
include: {
model: invitations,
as: 'invitation',
on: {
user: Sequelize.where(
Sequelize.col('usersRoles.userUid'),
'=',
Sequelize.col('invitation.guestUid')),
propertyManager: Sequelize.where(
Sequelize.col('usersRoles.propertyManagerUid'),
'=',
Sequelize.col('invitation.propertyManagerUid')),
tenant: Sequelize.where(
Sequelize.col('usersRoles.tenantUid'),
'=',
Sequelize.col('invitation.tenantUid')),
},
},
};
return usersRoles.findAll(sql);
};
const sequelize = new Sequelize(
configs.get('DB_NAME'),
configs.get('DB_USER'),
configs.get('DB_PSSWD'),
{
dialect: configs.get('DB_TYPE'),
host: configs.get('DB_HOST'),
port: configs.get('DB_PORT'),
});
const modelsPath = path.join(__dirname, 'sequelize/models');
const globOpts = {
cwd: modelsPath,
ignore: '**/index.js',
realPath: false,
nosort: true,
nodir: true,
};
glob('**/*.js', globOpts, (err, files) => {
Promise.map(files, (file) => {
const model = sequelize.import(path.join(modelsPath, file));
models[model.name] = model;
})
.then(() => {
Object.keys(models).forEach((modelName) => {
if (models[modelName].associate) {
models[modelName].associate(models);
}
});
return performQuery(models);
})
.then((res) => {
console.log('SUCCESS', res);
}, (reason) => {
console.error('FAILED', reason);
});
});
输出
FAILED { SequelizeEagerLoadingError: invitations is not associated to usersRoles!
at Function._getIncludedAssociation (.../node_modules/sequelize/lib/model.js:573:13)
at Function._validateIncludedElement (.../node_modules/sequelize/lib/model.js:489:53)
at options.include.options.include.map.include (.../node_modules/sequelize/lib/model.js:385:37)
at Array.map (native)
at Function._validateIncludedElements (.../node_modules/sequelize/lib/model.js:381:39)
at Promise.try.then.then (.../node_modules/sequelize/lib/model.js:1525:14)
at tryCatcher (.../node_modules/bluebird/js/release/util.js:16:23)
at Promise._settlePromiseFromHandler (.../node_modules/bluebird/js/release/promise.js:512:31)
at Promise._settlePromise (.../node_modules/bluebird/js/release/promise.js:569:18)
at Promise._settlePromise0 (.../node_modules/bluebird/js/release/promise.js:614:10)
at Promise._settlePromises (.../node_modules/bluebird/js/release/promise.js:693:18)
at Async._drainQueue (.../node_modules/bluebird/js/release/async.js:133:16)
at Async._drainQueues (.../node_modules/bluebird/js/release/async.js:143:10)
at Immediate.Async.drainQueues (.../node_modules/bluebird/js/release/async.js:17:14)
at runCallback (timers.js:637:20)
at tryOnImmediate (timers.js:610:5)
at processImmediate [as _immediateCallback] (timers.js:582:5) name: 'SequelizeEagerLoadingError' }
进一步尝试 我尝试将以下行添加到邀请模型中:
models.usersRoles.belongsTo(models.invitations);
在这种情况下，Sequelize 会打印一些 SQL，这些 SQL 在执行时完全按照预期工作，但显然它没有正确执行，因为查询仍然不起作用，而是显示 SequelizeDatabaseError:relation "usersRoles"不存在。
Executing (default): SELECT "usersRoles"."key", "usersRoles"."userUid", "usersRoles"."roleUid", "usersRoles"."oemUid", "usersRoles"."propertyManagerUid", "usersRoles"."doorSchedule", "usersRoles"."cardId", "usersRoles"."notifyBy", "usersRoles"."contactEmail", "usersRoles"."tenantUid", "usersRoles"."createdAt", "usersRoles"."compositePK", "usersRoles"."invitationUid", "invitation"."uid" AS "invitation.uid", "invitation"."status" AS "invitation.status", "invitation"."guestUid" AS "invitation.guestUid", "invitation"."firstName" AS "invitation.firstName", "invitation"."lastName" AS "invitation.lastName", "invitation"."email" AS "invitation.email", "invitation"."mobile" AS "invitation.mobile", "invitation"."mappingGroupUid" AS "invitation.mappingGroupUid", "invitation"."doorSchedule" AS "invitation.doorSchedule", "invitation"."invitedByUid" AS "invitation.invitedByUid", "invitation"."adminUid" AS "invitation.adminUid", "invitation"."acceptedAt" AS "invitation.acceptedAt", "invitation"."rejectedAt" AS "invitation.rejectedAt", "invitation"."propertyManagerUid" AS "invitation.propertyManagerUid", "invitation"."tenantUid" AS "invitation.tenantUid", "invitation"."contactEmail" AS "invitation.contactEmail", "invitation"."notifyBy" AS "invitation.notifyBy", "invitation"."createdAt" AS "invitation.createdAt", "invitation"."updatedAt" AS "invitation.updatedAt" FROM "usersRoles" AS "usersRoles" LEFT OUTER JOIN "invitations" AS "invitation" ON "usersRoles"."userUid"="invitation"."guestUid" AND "usersRoles"."propertyManagerUid"="invitation"."propertyManagerUid" AND "usersRoles"."tenantUid"="invitation"."tenantUid"; Query failure { SequelizeDatabaseError: relation "usersRoles" does not exist
最佳答案
您永远不会调用 Model.associate() 方法，因此模型不会相互关联。诀窍在于关联可能需要尚未定义的模型，因此关联必须排在最后。加载模型后，循环遍历它们并调用 model.associate(models) 来创建关联。
userRole 定义也不包含与邀请 的关联。在 Sequelize 中，必须从要查询的一侧定义关系，或者如果您计划从两个对象查询关系，则必须从两者定义关系。由于 invitations 有许多 userRoles，我假设 userRoles 属于 invitations。您在查询中将该表引用为 invitation，因此您可能需要使用 as 属性为关联添加别名。
用户角色
models.usersRoles.belongsTo(models.invitations, {
as: 'invitation',
foreignKey: 'compositePK',
});
关于node.js - 为什么 Sequelize 认为我的模型不相关？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47064573/