dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-27 20:46:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

delete cascade fix

Browse Source
This commit is contained in:
Jan Prochazka
2023-02-12 11:43:02 +01:00
parent 4e194539d9
commit fb8174b3e9
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
packages/datalib/src/deleteCascade.ts
View File

@@ -55,7 +55,7 @@ function processDependencies(
schemaName: fk.schemaName, schemaName: fk.schemaName,
}, },
alias: 't0', alias: 't0',
relations: subFkPath.map((fkItem, fkIndex) => ({ relations: [...subFkPath].reverse().map((fkItem, fkIndex) => ({
joinType: 'INNER JOIN', joinType: 'INNER JOIN',
alias: `t${fkIndex + 1}`, alias: `t${fkIndex + 1}`,
name: { name: {
@@ -123,7 +123,16 @@ export function getDeleteCascades(changeSet: ChangeSet, dbinfo: DatabaseInfo): C
const table = dbinfo.tables.find(x => x.pureName == baseCmd.pureName && x.schemaName == baseCmd.schemaName); const table = dbinfo.tables.find(x => x.pureName == baseCmd.pureName && x.schemaName == baseCmd.schemaName);
if (!table.primaryKey) continue; if (!table.primaryKey) continue;
processDependencies(changeSet, result, allForeignKeys, [], table, baseCmd, dbinfo, [table.pureName]); const itemResult: ChangeSetDeleteCascade[] = [];
processDependencies(changeSet, itemResult, allForeignKeys, [], table, baseCmd, dbinfo, [table.pureName]);
for (const item of itemResult) {
const existing = result.find(x => x.title == item.title);
if (existing) {
existing.commands.push(...item.commands);
} else {
result.push(item);
}
}
// let resItem = result.find(x => x.title == baseCmd.pureName); // let resItem = result.find(x => x.title == baseCmd.pureName);
// if (!resItem) { // if (!resItem) {