|
|
@ -63,20 +63,22 @@ public class IndividuallySchemaMigratorImpl extends AbstractSchemaMigrator { |
|
|
|
namespace, |
|
|
|
namespace, |
|
|
|
targets |
|
|
|
targets |
|
|
|
); |
|
|
|
); |
|
|
|
|
|
|
|
boolean tableValid = true; |
|
|
|
for ( Table table : namespace.getTables() ) { |
|
|
|
for ( Table table : namespace.getTables() ) { |
|
|
|
if ( schemaFilter.includeTable( table ) && table.isPhysicalTable() ) { |
|
|
|
if ( schemaFilter.includeTable( table ) && table.isPhysicalTable() ) { |
|
|
|
checkExportIdentifier( table, exportIdentifiers ); |
|
|
|
checkExportIdentifier( table, exportIdentifiers ); |
|
|
|
final TableInformation tableInformation = existingDatabase.getTableInformation( table.getQualifiedTableName() ); |
|
|
|
final TableInformation tableInformation = existingDatabase.getTableInformation( table.getQualifiedTableName() ); |
|
|
|
if ( tableInformation == null ) { |
|
|
|
if ( tableInformation == null ) { |
|
|
|
createTable( table, dialect, metadata, formatter, options, targets ); |
|
|
|
tableValid &= createTable( table, dialect, metadata, formatter, options, targets ); |
|
|
|
} |
|
|
|
} |
|
|
|
else if ( tableInformation != null && tableInformation.isPhysicalTable() ) { |
|
|
|
else if ( tableInformation != null && tableInformation.isPhysicalTable() ) { |
|
|
|
tablesInformation.addTableInformation( tableInformation ); |
|
|
|
tablesInformation.addTableInformation( tableInformation ); |
|
|
|
migrateTable( table, tableInformation, dialect, metadata, formatter, options, targets ); |
|
|
|
tableValid &= migrateTable( table, tableInformation, dialect, metadata, formatter, options, targets ); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (tableValid) { |
|
|
|
for (Table table : namespace.getTables()) { |
|
|
|
for (Table table : namespace.getTables()) { |
|
|
|
if (schemaFilter.includeTable(table) && table.isPhysicalTable()) { |
|
|
|
if (schemaFilter.includeTable(table) && table.isPhysicalTable()) { |
|
|
|
final TableInformation tableInformation = tablesInformation.getTableInformation(table); |
|
|
|
final TableInformation tableInformation = tablesInformation.getTableInformation(table); |
|
|
@ -90,6 +92,7 @@ public class IndividuallySchemaMigratorImpl extends AbstractSchemaMigrator { |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
return tablesInformation; |
|
|
|
return tablesInformation; |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|