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

Merge branch 'master' into develop
All checks were successful
IntegryManagementSystem_Multi/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Giuseppe Scorrano
2025-08-05 09:55:07 +02:00
parent f24ebd5cbc f08b5fe07e
commit 36acbe175a
2 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ems-core/src/main/java/it/integry/ems/sync/MultiDBTransaction/MultiDBTransactionManager.java
View File

@@ -181,12 +181,6 @@ public class MultiDBTransactionManager implements AutoCloseable {
return connection.prepareStatement(sql); return connection.prepareStatement(sql);
} }
public PreparedStatement prepareStatementOnDistributore(String sql) throws Exception {
try (Connection connection = getDistributoreConnection()) {
return connection.prepareStatement(sql);
}
}
public List<Connection> getActiveConnections() throws SQLException { public List<Connection> getActiveConnections() throws SQLException {
return allConnections; return allConnections;
} }

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

@@ -81,6 +81,7 @@ public class SyncManager {
proceedSyncronization(entitySource, entityCloned, lastProfileUsed, multiDBTransactionManager); proceedSyncronization(entitySource, entityCloned, lastProfileUsed, multiDBTransactionManager);
distributoreConnection.commit();
} catch (Exception e) { } catch (Exception e) {
String subscriptor = null; String subscriptor = null;
@@ -104,6 +105,9 @@ public class SyncManager {
e = new SyncException(e, profileDb); e = new SyncException(e, profileDb);
} }
distributoreConnection.rollback();
throw e; throw e;
} }
} }