Integry/IntegryManagementSystem
19
0
Fork 0
Code Actions Packages Projects Releases Activity

Merge branch 'master' into develop

Browse Source
This commit is contained in:
Mina Ruggiero
2024-03-11 17:49:36 +01:00
parent e2029ede7a 09be88a375
commit 2ac011c47c
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
ems-core/src/main/java/it/integry/ems/sync/SyncManager.java
View File

@@ -10,6 +10,7 @@ import it.integry.ems.service.MailService;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager; import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems_model.base.EntityBase; import it.integry.ems_model.base.EntityBase;
import it.integry.ems_model.base.EntityInterface; 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.exception.EntityException;
import it.integry.ems_model.service.SetupGest; import it.integry.ems_model.service.SetupGest;
import it.integry.ems_model.types.OperationType; 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 " " else case when recalc_columns = '' then null else recalc_columns end end AS recalc_columns "
+ " from stb_subscription " + " from stb_subscription "
+ " where table_name=" + UtilityDB.valueToString(entitySource.getTableName().toUpperCase()) + " AND flag_attivo='S' "; + " where table_name=" + UtilityDB.valueToString(entitySource.getTableName().toUpperCase()) + " AND flag_attivo='S' ";
List<HashMap<String, Object>> datiSync = UtilityDB.executeSimpleQuery(connection, sql);
// List<HashMap<String, Object>> datiSync = UtilityDB.executeSimpleQuery(connection, sql);
PreparedStatement ps = connection.prepareStatement(sql);
ResultSet rs = ps.executeQuery();
List<HashMap<String, Object>> datiSync = ResultSetMapper.mapResultSetToHashMap(rs);
rs.close();
ps.close();
for(HashMap<String, Object> dati:datiSync){ for(HashMap<String, Object> dati:datiSync){
String whereCond = (String) dati.get("where_cond_sql"); String whereCond = (String) dati.get("where_cond_sql");
String database = (String) dati.get("user_name"); String database = (String) dati.get("user_name");