diff --git a/ems-core/src/main/java/it/integry/ems/migration/_base/BaseMigration.java b/ems-core/src/main/java/it/integry/ems/migration/_base/BaseMigration.java index f175d352f3..fbec87d1d5 100644 --- a/ems-core/src/main/java/it/integry/ems/migration/_base/BaseMigration.java +++ b/ems-core/src/main/java/it/integry/ems/migration/_base/BaseMigration.java @@ -177,16 +177,8 @@ public abstract class BaseMigration implements MigrationModelInterface { return val != null && val == 1; } - protected boolean existColumn(String tableName, String columnName) throws SQLException, IOException { - return UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(advancedDataSource.getConnection(), - Query.format("SELECT CAST(COUNT(*) AS BIT)\n" + - "FROM sys.syscolumns\n" + - "WHERE name = %s\n" + - " AND OBJECT_NAME(id) = %s", columnName, tableName)); - } - protected void renameColumn(String tableName, String oldColumnname, String newColumnName) throws SQLException, IOException { - if (existColumn(tableName, oldColumnname)) { + if (existsColumn(tableName, oldColumnname)) { String sql = "exec sp_rename 'dbo." + tableName + "." + oldColumnname + "', " + newColumnName + ", 'COLUMN'"; executeStatement(sql); diff --git a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20241202145553.java b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20241202145553.java index 5cd4442f48..9fe5204830 100644 --- a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20241202145553.java +++ b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20241202145553.java @@ -14,7 +14,7 @@ public class Migration_20241202145553 extends BaseMigration implements Migration if (isCustomerDb(IntegryCustomerDB.Siciliani_DMS)) return; - if (!existColumn("mtb_lisa_costo_data", "part_iva" )) + if (!existsColumn("mtb_lisa_costo_data", "part_iva" )) executeStatement("ALTER TABLE mtb_lisa_costo_data ADD part_iva varchar(20)"); } diff --git a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250224114817.java b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250224114817.java index 518b9aa376..e3df2c1857 100644 --- a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250224114817.java +++ b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250224114817.java @@ -10,7 +10,7 @@ public class Migration_20250224114817 extends BaseMigration implements Migration if (isHistoryDB()) return; - if (existsTable("apuliac_agg_prz_csv") && !existColumn("apuliac_agg_prz_csv", "altro")){ + if (existsTable("apuliac_agg_prz_csv") && !existsColumn("apuliac_agg_prz_csv", "altro")){ executeStatement("alter table apuliac_agg_prz_csv add altro varchar(max)"); } } diff --git a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250225124406.java b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250225124406.java index ccc9557932..41d8f24f48 100644 --- a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250225124406.java +++ b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250225124406.java @@ -15,7 +15,7 @@ public class Migration_20250225124406 extends BaseMigration implements Migration if (isCustomerDb(IntegryCustomerDB.Siciliani_DMS)) return; - if (!existColumn("mtb_aart", "flag_stampa_docu_vend")) + if (!existsColumn("mtb_aart", "flag_stampa_docu_vend")) executeStatement( "alter table mtb_aart add flag_stampa_docu_vend bit not null default 1"); }