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-09-15 15:46:10 +02:00
parent c8fdf2634d ab9672cae3
commit e6ee9c7090
2 changed files with 6 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
ems-core/src/main/java/it/integry/ems/sync/MultiDBTransaction/BasicConnectionPool.java
View File

@@ -61,7 +61,7 @@ public class BasicConnectionPool {
}
}
private void initializeConnections() throws Exception {
private void initializeConnections() {
final List<AvailableConnectionsModel> availableConnections =
settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(false);
@@ -111,15 +111,9 @@ public class BasicConnectionPool {
private void registerDataSourceIfNotExists(AvailableConnectionsModel connectionModel) throws Exception {
String dbName = connectionModel.getDbName();
registeredDatasources.computeIfAbsent(dbName, k -> {
try {
return createNewDataSource(connectionModel);
} catch (Exception e) {
logger.error("Errore creazione lazy DataSource per {}", dbName, e);
throw new RuntimeException(e);
}
});
if (!registeredDatasources.containsKey(dbName)) {
registeredDatasources.put(dbName, createNewDataSource(connectionModel));
}
}
}

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

@@ -52,11 +52,13 @@ public class MultiDBTransactionManager implements AutoCloseable {
public MultiDBTransactionManager() {
connectionPool = ApplicationContextProvider.getApplicationContext().getBean(BasicConnectionPool.class);
settingsModel = ApplicationContextProvider.getApplicationContext().getBean(SettingsModel.class);
emsDBConst = ApplicationContextProvider.getApplicationContext().getBean(EmsDBConst.class);
}
public MultiDBTransactionManager(BasicConnectionPool connectionPool) throws Exception {
this.connectionPool = connectionPool;
settingsModel = ApplicationContextProvider.getApplicationContext().getBean(SettingsModel.class);
emsDBConst = ApplicationContextProvider.getApplicationContext().getBean(EmsDBConst.class);
}
public MultiDBTransactionManager(AvailableConnectionsModel connectionsModel) throws Exception {