Skip to content

Commit

Permalink
Added config print for JPA EntityMananager configurations
Browse files Browse the repository at this point in the history
Signed-off-by: Alberto Codutti <alberto.codutti@eurotech.com>
  • Loading branch information
Coduz committed Jun 24, 2024
1 parent 66b409d commit e50970e
Show file tree
Hide file tree
Showing 2 changed files with 31 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@

import org.eclipse.kapua.KapuaException;

import org.eclipse.kapua.commons.util.log.ConfigurationPrinter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

Expand Down Expand Up @@ -55,6 +56,8 @@ protected AbstractEntityManagerFactory(String persistenceUnitName, String dataso

// Standalone JPA
entityManagerFactory = Persistence.createEntityManagerFactory(persistenceUnitName, configOverrides);

printEntityManagerConfiguration(persistenceUnitName, datasourceName, configOverrides);
} catch (Throwable ex) {
LOG.error("Error creating EntityManagerFactory", ex);
throw new ExceptionInInitializerError(ex);
Expand All @@ -68,7 +71,6 @@ protected AbstractEntityManagerFactory(String persistenceUnitName, String dataso
}
}

// Entity manager factory methods
/**
* Returns an EntityManager instance.
*
Expand All @@ -81,4 +83,23 @@ public EntityManager createEntityManager()
return new EntityManager(entityManagerFactory.createEntityManager());
}

//
// Private Methods
//

private void printEntityManagerConfiguration(String persistenceUnitName, String datasourceName, Map<String, Object> configOverrides) {
ConfigurationPrinter configurationPrinter =
ConfigurationPrinter.create()
.withLogger(LOG)
.withLogLevel(ConfigurationPrinter.LogLevel.INFO)
.withTitle("Persistence Unit Config: " + persistenceUnitName)
.addParameter("Datasource Name", datasourceName)
.openSection("Configuration Overrides");

for (Map.Entry<String, Object> config : configOverrides.entrySet()) {
configurationPrinter.addParameter(config.getKey(), config.getValue());
}

configurationPrinter.printLog();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -12,16 +12,16 @@
*******************************************************************************/
package org.eclipse.kapua.commons.jpa;

import com.zaxxer.hikari.HikariDataSource;
import org.eclipse.kapua.commons.setting.system.SystemSetting;
import org.eclipse.kapua.commons.setting.system.SystemSettingKey;

import com.zaxxer.hikari.HikariDataSource;

public final class DataSource {

private static HikariDataSource hikariDataSource;

private DataSource() {}
private DataSource() {
}

public static HikariDataSource getDataSource() {
if (hikariDataSource == null) {
Expand All @@ -42,6 +42,12 @@ public static HikariDataSource getDataSource() {

hikariDataSource.setLeakDetectionThreshold(config.getInt(SystemSettingKey.DB_POOL_LEAKDETECTION_THRESHOLD, 0));
}

return hikariDataSource;
}

@Override
public String toString() {
return hikariDataSource.getDriverClassName() + "@" + hikariDataSource.toString();
}
}

0 comments on commit e50970e

Please sign in to comment.