2021-07-01 14:32:50 +02:00
|
|
|
/**
|
|
|
|
* @module relations
|
|
|
|
*/
|
|
|
|
|
|
|
|
'use strict';
|
|
|
|
|
|
|
|
const _ = require('lodash/fp');
|
|
|
|
|
2021-07-05 18:35:16 +02:00
|
|
|
const hasInversedBy = _.has('inversedBy');
|
|
|
|
const hasMappedBy = _.has('mappedBy');
|
|
|
|
|
|
|
|
const isBidirectional = attribute => hasInversedBy(attribute) || hasMappedBy(attribute);
|
|
|
|
const isOwner = attribute => !isBidirectional(attribute) || hasInversedBy(attribute);
|
|
|
|
const shouldUseJoinTable = attribute => attribute.useJoinTable !== false;
|
|
|
|
|
2021-07-01 14:32:50 +02:00
|
|
|
/**
|
|
|
|
* Creates a relation metadata
|
|
|
|
*
|
|
|
|
* @param {string} attributeName
|
|
|
|
* @param {Attribute} attribute
|
|
|
|
* @param {ModelMetadata} meta
|
|
|
|
* @param {Metadata} metadata
|
|
|
|
*/
|
|
|
|
const createRelation = (attributeName, attribute, meta, metadata) => {
|
|
|
|
if (_.has(attribute.relation, relationFactoryMap)) {
|
|
|
|
return relationFactoryMap[attribute.relation](attributeName, attribute, meta, metadata);
|
|
|
|
}
|
|
|
|
|
2021-07-08 18:15:32 +02:00
|
|
|
throw new Error(`Unknown relation ${attribute.relation}`);
|
2021-07-01 14:32:50 +02:00
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
polymorphic relations
|
|
|
|
|
|
|
|
OneToOneX
|
|
|
|
ManyToOneX
|
|
|
|
OnetoManyX
|
|
|
|
ManytoManyX
|
|
|
|
XOneToOne
|
|
|
|
XManyToOne
|
|
|
|
XOnetoMany
|
|
|
|
XManytoMany
|
|
|
|
|
|
|
|
XOneToOneX
|
|
|
|
XManyToOneX
|
|
|
|
XOnetoManyX
|
|
|
|
XManytoManyX
|
|
|
|
*/
|
|
|
|
};
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Creates a oneToOne relation metadata
|
|
|
|
*
|
|
|
|
* if owner then
|
|
|
|
* if with join table then
|
|
|
|
* create join table
|
|
|
|
* else
|
|
|
|
* create joinColumn
|
|
|
|
* if bidirectional then
|
|
|
|
* set inverse attribute joinCol or joinTable info correctly
|
|
|
|
* else
|
|
|
|
* this property must be set by the owner side
|
|
|
|
* verify the owner side is valid // should be done before or at the same time ?
|
|
|
|
*
|
|
|
|
* @param {string} attributeName
|
|
|
|
* @param {Attribute} attribute
|
|
|
|
* @param {ModelMetadata} meta
|
|
|
|
* @param {Metadata} metadata
|
|
|
|
* @retuns void
|
|
|
|
*/
|
|
|
|
const createOneToOne = (attributeName, attribute, meta, metadata) => {
|
|
|
|
if (isOwner(attribute)) {
|
|
|
|
if (shouldUseJoinTable(attribute)) {
|
|
|
|
createJoinTable(metadata, {
|
|
|
|
attribute,
|
|
|
|
attributeName,
|
|
|
|
meta,
|
|
|
|
});
|
|
|
|
} else {
|
|
|
|
createJoinColum(metadata, {
|
|
|
|
attribute,
|
|
|
|
attributeName,
|
|
|
|
meta,
|
|
|
|
});
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
// TODO: verify other side is valid
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Creates a oneToMany relation metadata
|
|
|
|
*
|
|
|
|
* if unidirectional then
|
|
|
|
* create join table
|
|
|
|
* if bidirectional then
|
|
|
|
* cannot be owning side
|
|
|
|
* do nothing
|
|
|
|
*
|
|
|
|
* @param {string} attributeName
|
|
|
|
* @param {Attribute} attribute
|
|
|
|
* @param {ModelMetadata} meta
|
|
|
|
* @param {Metadata} metadata
|
|
|
|
*/
|
|
|
|
const createOneToMany = (attributeName, attribute, meta, metadata) => {
|
|
|
|
if (!isBidirectional(attribute)) {
|
|
|
|
createJoinTable(metadata, {
|
|
|
|
attribute,
|
|
|
|
attributeName,
|
|
|
|
meta,
|
|
|
|
});
|
|
|
|
} else {
|
|
|
|
if (isOwner(attribute)) {
|
|
|
|
throw new Error(
|
|
|
|
'one side of a oneToMany cannot be the owner side in a bidirectional relation'
|
|
|
|
);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Creates a manyToOne relation metadata
|
|
|
|
*
|
|
|
|
* if unidirectional then
|
|
|
|
* if with join table then
|
|
|
|
* create join table
|
|
|
|
* else
|
|
|
|
* create join column
|
|
|
|
* else
|
|
|
|
* must be the owner side
|
|
|
|
* if with join table then
|
|
|
|
* create join table
|
|
|
|
* else
|
|
|
|
* create join column
|
|
|
|
* set inverse attribute joinCol or joinTable info correctly
|
|
|
|
*
|
|
|
|
* @param {string} attributeName
|
|
|
|
* @param {Attribute} attribute
|
|
|
|
* @param {ModelMetadata} meta
|
|
|
|
* @param {Metadata} metadata
|
|
|
|
*/
|
|
|
|
const createManyToOne = (attributeName, attribute, meta, metadata) => {
|
|
|
|
if (isBidirectional(attribute) && !isOwner(attribute)) {
|
|
|
|
throw new Error('The many side of a manyToOne must be the owning side');
|
|
|
|
}
|
|
|
|
|
|
|
|
if (shouldUseJoinTable(attribute)) {
|
|
|
|
createJoinTable(metadata, {
|
|
|
|
attribute,
|
|
|
|
attributeName,
|
|
|
|
meta,
|
|
|
|
});
|
|
|
|
} else {
|
|
|
|
createJoinColum(metadata, {
|
|
|
|
attribute,
|
|
|
|
attributeName,
|
|
|
|
meta,
|
|
|
|
});
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Creates a manyToMany relation metadata
|
|
|
|
*
|
|
|
|
* if unidirectional
|
|
|
|
* create join table
|
|
|
|
* else
|
|
|
|
* if owner then
|
|
|
|
* if with join table then
|
|
|
|
* create join table
|
|
|
|
* else
|
|
|
|
* do nothing
|
|
|
|
*
|
|
|
|
* @param {string} attributeName
|
|
|
|
* @param {Attribute} attribute
|
|
|
|
* @param {ModelMetadata} meta
|
|
|
|
* @param {Metadata} metadata
|
|
|
|
*/
|
|
|
|
const createManyToMany = (attributeName, attribute, meta, metadata) => {
|
|
|
|
if (!isBidirectional(attribute) || isOwner(attribute)) {
|
|
|
|
createJoinTable(metadata, {
|
|
|
|
attribute,
|
|
|
|
attributeName,
|
|
|
|
meta,
|
|
|
|
});
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
const relationFactoryMap = {
|
|
|
|
oneToOne: createOneToOne,
|
|
|
|
oneToMany: createOneToMany,
|
|
|
|
manyToOne: createManyToOne,
|
|
|
|
manyToMany: createManyToMany,
|
|
|
|
};
|
|
|
|
|
2021-07-07 18:04:39 +02:00
|
|
|
const createJoinColum = (metadata, { attribute, attributeName /*meta */ }) => {
|
2021-07-01 14:32:50 +02:00
|
|
|
const targetMeta = metadata.get(attribute.target);
|
|
|
|
|
2021-07-07 18:04:39 +02:00
|
|
|
const joinColumnName = _.snakeCase(`${attributeName}_id`);
|
2021-07-01 14:32:50 +02:00
|
|
|
const joinColumn = {
|
|
|
|
name: joinColumnName,
|
|
|
|
referencedColumn: 'id',
|
|
|
|
referencedTable: targetMeta.tableName,
|
|
|
|
};
|
|
|
|
|
|
|
|
Object.assign(attribute, { owner: true, joinColumn });
|
|
|
|
|
|
|
|
if (isBidirectional(attribute)) {
|
|
|
|
const inverseAttribute = targetMeta.attributes[attribute.inversedBy];
|
|
|
|
// TODO: do not invert here but invert in the query ? => means we need to use owner info in the query layer
|
|
|
|
Object.assign(inverseAttribute, {
|
|
|
|
joinColumn: {
|
|
|
|
name: joinColumn.referencedColumn,
|
|
|
|
referencedColumn: joinColumn.name,
|
|
|
|
},
|
|
|
|
});
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
const createJoinTable = (metadata, { attributeName, attribute, meta }) => {
|
|
|
|
const targetMeta = metadata.get(attribute.target);
|
|
|
|
|
|
|
|
if (!targetMeta) {
|
|
|
|
throw new Error(`Unknow target ${attribute.target}`);
|
|
|
|
}
|
|
|
|
|
|
|
|
const joinTableName = _.snakeCase(`${meta.tableName}_${attributeName}_links`);
|
|
|
|
|
2021-07-05 18:35:16 +02:00
|
|
|
let joinColumnName = _.snakeCase(`${meta.singularName}_id`);
|
|
|
|
let inverseJoinColumnName = _.snakeCase(`${targetMeta.singularName}_id`);
|
|
|
|
|
|
|
|
// if relation is slef referencing
|
|
|
|
if (joinColumnName === inverseJoinColumnName) {
|
|
|
|
inverseJoinColumnName = `inv_${inverseJoinColumnName}`;
|
|
|
|
}
|
2021-07-01 14:32:50 +02:00
|
|
|
|
|
|
|
metadata.add({
|
|
|
|
uid: joinTableName,
|
|
|
|
tableName: joinTableName,
|
|
|
|
attributes: {
|
|
|
|
[joinColumnName]: {
|
|
|
|
type: 'integer',
|
|
|
|
column: {
|
|
|
|
unsigned: true,
|
|
|
|
},
|
|
|
|
},
|
|
|
|
[inverseJoinColumnName]: {
|
|
|
|
type: 'integer',
|
|
|
|
column: {
|
|
|
|
unsigned: true,
|
|
|
|
},
|
|
|
|
},
|
|
|
|
// TODO: add extra pivot attributes -> user should use an intermediate entity
|
|
|
|
},
|
|
|
|
foreignKeys: [
|
|
|
|
{
|
|
|
|
name: `${joinTableName}_fk`,
|
|
|
|
columns: [joinColumnName],
|
|
|
|
referencedColumns: ['id'],
|
|
|
|
referencedTable: meta.tableName,
|
|
|
|
onDelete: 'CASCADE',
|
|
|
|
},
|
|
|
|
{
|
|
|
|
name: `${joinTableName}_inv_fk`,
|
|
|
|
columns: [inverseJoinColumnName],
|
|
|
|
referencedColumns: ['id'],
|
|
|
|
referencedTable: targetMeta.tableName,
|
|
|
|
onDelete: 'CASCADE',
|
|
|
|
},
|
|
|
|
],
|
|
|
|
});
|
|
|
|
|
|
|
|
const joinTable = {
|
|
|
|
name: joinTableName,
|
|
|
|
joinColumn: {
|
|
|
|
name: joinColumnName,
|
|
|
|
referencedColumn: 'id',
|
|
|
|
},
|
|
|
|
inverseJoinColumn: {
|
|
|
|
name: inverseJoinColumnName,
|
|
|
|
referencedColumn: 'id',
|
|
|
|
},
|
|
|
|
};
|
|
|
|
|
|
|
|
attribute.joinTable = joinTable;
|
|
|
|
|
|
|
|
if (isBidirectional(attribute)) {
|
|
|
|
const inverseAttribute = targetMeta.attributes[attribute.inversedBy];
|
|
|
|
|
|
|
|
if (!inverseAttribute) {
|
2021-07-08 18:15:32 +02:00
|
|
|
throw new Error(
|
|
|
|
`inversedBy attribute ${attribute.inversedBy} not found target ${targetMeta.uid}`
|
|
|
|
);
|
2021-07-01 14:32:50 +02:00
|
|
|
}
|
|
|
|
|
2021-07-02 02:26:14 +02:00
|
|
|
inverseAttribute.joinTable = {
|
2021-07-01 14:32:50 +02:00
|
|
|
name: joinTableName,
|
|
|
|
joinColumn: joinTable.inverseJoinColumn,
|
|
|
|
inverseJoinColumn: joinTable.joinColumn,
|
|
|
|
};
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
module.exports = {
|
|
|
|
createRelation,
|
2021-07-05 18:35:16 +02:00
|
|
|
|
|
|
|
isBidirectional,
|
2021-07-01 14:32:50 +02:00
|
|
|
};
|