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

delete cascade

Browse Source
This commit is contained in:
Jan Prochazka
2021-09-28 12:28:09 +02:00
parent 2c2b4fc08f
commit aad39227b7
2 changed files with 23 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
packages/datalib/src/ChangeSet.ts
View File

@@ -333,6 +333,7 @@ export function getDeleteCascades(changeSet: ChangeSet, dbinfo: DatabaseInfo): C
const allForeignKeys = _.flatten(dbinfo.tables.map(x => x.foreignKeys));
for (const baseCmd of changeSet.deletes) {
const table = dbinfo.tables.find(x => x.pureName == baseCmd.pureName && x.schemaName == baseCmd.schemaName);
if (!table.primaryKey) continue;
const dependencies = allForeignKeys.filter(
x => x.refSchemaName == table.schemaName && x.refTableName == table.pureName
);
@@ -385,7 +386,7 @@ export function getDeleteCascades(changeSet: ChangeSet, dbinfo: DatabaseInfo): C
conditions: [
extractCondition(baseCmd, 't2'),
// @ts-ignore
...fk.columns.map(column => ({
...table.primaryKey.columns.map(column => ({
conditionType: 'binary',
operator: '=',
left: {
@@ -395,7 +396,7 @@ export function getDeleteCascades(changeSet: ChangeSet, dbinfo: DatabaseInfo): C
},
right: {
exprType: 'column',
columnName: column.refColumnName,
columnName: column.columnName,
source: {
name: {
pureName: fk.refTableName,
@@ -419,6 +420,17 @@ export function getDeleteCascades(changeSet: ChangeSet, dbinfo: DatabaseInfo): C
}
resItem.commands.push(refCmd);
}
let resItem = res.find(x => x.title == baseCmd.pureName);
if (!resItem) {
resItem = {
title: baseCmd.pureName,
commands: [],
};
res.push(resItem);
}
resItem.commands.push(deleteToSql(baseCmd));
}
return res;