Package ch.rswk.meta.engine

Class DatabaseService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

ch.rswk.meta.engine.AbstractEngineIdleService<DatabaseService.DatabaseServiceConfig>

ch.rswk.meta.engine.DatabaseService

All Implemented Interfaces:

EngineServices.ConfigurableService<DatabaseService.DatabaseServiceConfig>, EngineServices.InfoProvidingService, com.google.common.util.concurrent.Service

@Singleton
public class DatabaseService
extends AbstractEngineIdleService<DatabaseService.DatabaseServiceConfig>

DatabaseService uses c3p0 to manage connections to the configured databases and JDBI for queries.

Make sure to include the JAR that contains the JDBC driver as a Maven dependency or classpath at runtime.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	DatabaseService.DatabaseServiceConfig
static final record	DatabaseService.DatabaseServiceDataSourceConfig

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field	Description
private static final List<Method>	COMBO_POOLED_DATA_SOURCE_METHODS
private final Map<String,org.jdbi.v3.core.Jdbi>	databases
private final Set<DatabaseService.DatabaseServiceDataSourceConfig>	dataSourceConfigs
private final List<com.mchange.v2.c3p0.ComboPooledDataSource>	dataSources
private static final org.slf4j.Logger	LOG
private static final Protocol.ErrorReplyFactory	UNKNOWN_DB_ERROR

Fields inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

runtime

Constructor Summary

Constructors

Constructor	Description
DatabaseService(DatabaseService.DatabaseServiceConfig config, Set<DatabaseService.DatabaseServiceDataSourceConfig> dataSourceConfigs, EngineRuntime runtime)

Method Summary

Modifier and Type	Method	Description
org.jdbi.v3.core.Jdbi	getDatabase(String dbName)
Optional<com.fasterxml.jackson.databind.node.ObjectNode>	getServiceInfo()
private static com.mchange.v2.c3p0.ComboPooledDataSource	newDataSource(DatabaseService.DatabaseServiceDataSourceConfig config)
protected void	shutDown()
protected void	startUp()

Methods inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

configClass, configReference, onConfigWatcherNotification, serviceId, serviceName

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ch.rswk.meta.engine.EngineServices.ConfigurableService

config, handleConfigWatcherNotification, onConfigChanged

Field Details

LOG

private static final org.slf4j.Logger LOG

COMBO_POOLED_DATA_SOURCE_METHODS

private static final List<Method> COMBO_POOLED_DATA_SOURCE_METHODS

UNKNOWN_DB_ERROR

private static final Protocol.ErrorReplyFactory UNKNOWN_DB_ERROR

dataSourceConfigs

private final Set<DatabaseService.DatabaseServiceDataSourceConfig> dataSourceConfigs

dataSources

private final List<com.mchange.v2.c3p0.ComboPooledDataSource> dataSources

databases

private final Map<String,org.jdbi.v3.core.Jdbi> databases

Constructor Details

DatabaseService

@Inject
public DatabaseService(DatabaseService.DatabaseServiceConfig config,
 Set<DatabaseService.DatabaseServiceDataSourceConfig> dataSourceConfigs,
 EngineRuntime runtime)

Method Details

getDatabase

public org.jdbi.v3.core.Jdbi getDatabase(String dbName)

getServiceInfo

public Optional<com.fasterxml.jackson.databind.node.ObjectNode> getServiceInfo()

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class AbstractEngineIdleService<DatabaseService.DatabaseServiceConfig>

Throws:

Exception

newDataSource

private static com.mchange.v2.c3p0.ComboPooledDataSource newDataSource(DatabaseService.DatabaseServiceDataSourceConfig config)

shutDown

protected void shutDown()
                 throws Exception

Overrides:

shutDown in class AbstractEngineIdleService<DatabaseService.DatabaseServiceConfig>

Throws:

Exception