db syn logical fix

packages/tools/src/alterPlan.ts

@@ -111,7 +111,12 @@ export class AlterPlan {
   };
 
   public operations: AlterOperation[] = [];
-  constructor(public db: DatabaseInfo, public dialect: SqlDialect, public opts: DbDiffOptions) {}
+  constructor(
+    public wholeOldDb: DatabaseInfo,
+    public wholeNewDb: DatabaseInfo,
+    public dialect: SqlDialect,
+    public opts: DbDiffOptions
+  ) {}
 
   createTable(table: TableInfo) {
     this.operations.push({
@@ -225,7 +230,7 @@ export class AlterPlan {
   }
 
   _getDependendColumnConstraints(column: ColumnInfo, dependencyDefinition) {
-    const table = this.db.tables.find(x => x.pureName == column.pureName && x.schemaName == column.schemaName);
+    const table = this.wholeOldDb.tables.find(x => x.pureName == column.pureName && x.schemaName == column.schemaName);
     if (!table) return [];
     const fks = dependencyDefinition?.includes('dependencies')
       ? table.dependencies.filter(fk => fk.columns.find(col => col.refColumnName == column.columnName))
@@ -385,7 +390,7 @@ export class AlterPlan {
         return [];
       }
 
-      const table = this.db.tables.find(
+      const table = this.wholeNewDb.tables.find(
         x => x.pureName == op[objectField].pureName && x.schemaName == op[objectField].schemaName
       );
       this.recreates.tables += 1;

packages/tools/src/computeDiffRows.ts

@@ -83,7 +83,7 @@ export function computeDbDiffRows(
     res.push(
       ..._.sortBy(
         computeDiffRowsCore(sourceDb[objectTypeField], targetDb[objectTypeField], (a, b) =>
-          defs.test(a, b, opts, targetDb, driver)
+          defs.test(a, b, opts, sourceDb, targetDb, driver)
         ).map(row => ({
           ...row,
           sourceSchemaName: row?.source?.schemaName,

packages/tools/src/diffTools.ts

@@ -373,10 +373,11 @@ export function testEqualTables(
   a: TableInfo,
   b: TableInfo,
   opts: DbDiffOptions,
-  db: DatabaseInfo,
+  wholeOldDb: DatabaseInfo,
+  wholeNewDb: DatabaseInfo,
   driver: EngineDriver
 ) {
-  const plan = new AlterPlan(db, driver.dialect, opts);
+  const plan = new AlterPlan(wholeOldDb, wholeNewDb, driver.dialect, opts);
   planAlterTable(plan, a, b, opts);
   // console.log('plan.operations', a, b, plan.operations);
   return plan.operations.length == 0;
@@ -390,10 +391,11 @@ export function createAlterTablePlan(
   oldTable: TableInfo,
   newTable: TableInfo,
   opts: DbDiffOptions,
-  db: DatabaseInfo,
+  wholeOldDb: DatabaseInfo,
+  wholeNewDb: DatabaseInfo,
   driver: EngineDriver
 ): AlterPlan {
-  const plan = new AlterPlan(db, driver.dialect, opts);
+  const plan = new AlterPlan(wholeOldDb, wholeNewDb, driver.dialect, opts);
   if (oldTable == null) {
     plan.createTable(newTable);
   } else if (newTable == null) {
@@ -409,10 +411,11 @@ export function createAlterDatabasePlan(
   oldDb: DatabaseInfo,
   newDb: DatabaseInfo,
   opts: DbDiffOptions,
-  db: DatabaseInfo,
+  wholeOldDb: DatabaseInfo,
+  wholeNewDb: DatabaseInfo,
   driver: EngineDriver
 ): AlterPlan {
-  const plan = new AlterPlan(db, driver.dialect, opts);
+  const plan = new AlterPlan(wholeOldDb, wholeNewDb, driver.dialect, opts);
 
   for (const objectTypeField of ['tables', 'views', 'procedures', 'matviews', 'functions']) {
     for (const oldobj of oldDb[objectTypeField] || []) {
@@ -456,14 +459,15 @@ export function getAlterTableScript(
   oldTable: TableInfo,
   newTable: TableInfo,
   opts: DbDiffOptions,
-  db: DatabaseInfo,
+  wholeOldDb: DatabaseInfo,
+  wholeNewDb: DatabaseInfo,
   driver: EngineDriver
 ) {
   if ((!oldTable && !newTable) || !driver) {
     return { sql: '', recreates: [] };
   }
 
-  const plan = createAlterTablePlan(oldTable, newTable, opts, db, driver);
+  const plan = createAlterTablePlan(oldTable, newTable, opts, wholeOldDb, wholeNewDb, driver);
   const dmp = driver.createDumper();
   if (!driver.dialect.disableExplicitTransaction) dmp.beginTransaction();
   plan.run(dmp);
@@ -478,10 +482,11 @@ export function getAlterDatabaseScript(
   oldDb: DatabaseInfo,
   newDb: DatabaseInfo,
   opts: DbDiffOptions,
-  db: DatabaseInfo,
+  wholeOldDb: DatabaseInfo,
+  wholeNewDb: DatabaseInfo,
   driver: EngineDriver
 ) {
-  const plan = createAlterDatabasePlan(oldDb, newDb, opts, db, driver);
+  const plan = createAlterDatabasePlan(oldDb, newDb, opts, wholeOldDb, wholeNewDb, driver);
   const dmp = driver.createDumper();
   if (!driver.dialect.disableExplicitTransaction) dmp.beginTransaction();
   plan.run(dmp);