From edafed5d4ec843ec8dbba6eb9588686df3498623 Mon Sep 17 00:00:00 2001 From: MinaR Date: Mon, 11 Mar 2024 17:49:29 +0100 Subject: [PATCH] modificata la creazione del resultset --- .../src/main/java/it/integry/ems/sync/SyncManager.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/ems-core/src/main/java/it/integry/ems/sync/SyncManager.java b/ems-core/src/main/java/it/integry/ems/sync/SyncManager.java index 274421622f..2c31078017 100644 --- a/ems-core/src/main/java/it/integry/ems/sync/SyncManager.java +++ b/ems-core/src/main/java/it/integry/ems/sync/SyncManager.java @@ -10,6 +10,7 @@ import it.integry.ems.service.MailService; import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager; import it.integry.ems_model.base.EntityBase; import it.integry.ems_model.base.EntityInterface; +import it.integry.ems_model.db.ResultSetMapper; import it.integry.ems_model.exception.EntityException; import it.integry.ems_model.service.SetupGest; import it.integry.ems_model.types.OperationType; @@ -170,7 +171,14 @@ public class SyncManager { " else case when recalc_columns = '' then null else recalc_columns end end AS recalc_columns " + " from stb_subscription " + " where table_name=" + UtilityDB.valueToString(entitySource.getTableName().toUpperCase()) + " AND flag_attivo='S' "; - List> datiSync = UtilityDB.executeSimpleQuery(connection, sql); + +// List> datiSync = UtilityDB.executeSimpleQuery(connection, sql); + PreparedStatement ps = connection.prepareStatement(sql); + ResultSet rs = ps.executeQuery(); + List> datiSync = ResultSetMapper.mapResultSetToHashMap(rs); + rs.close(); + ps.close(); + for(HashMap dati:datiSync){ String whereCond = (String) dati.get("where_cond_sql"); String database = (String) dati.get("user_name");