Package fr.codinbox.connector.commons.database

Class DatabaseConnectorServiceImpl

java.lang.Object

fr.codinbox.connector.commons.database.DatabaseConnectorServiceImpl

All Implemented Interfaces:

DatabaseConnectorService

public class DatabaseConnectorServiceImpl
extends Object
implements DatabaseConnectorService

Default implementation of DatabaseConnectorService that discovers and manages database connections from environment variables.

See Also:

• DatabaseConnectorService
• DatabaseConnectionImpl

Constructor Summary

Constructors

Constructor	Description
DatabaseConnectorServiceImpl(@NotNull Logger logger)	Creates a new database connector service.

Method Summary

Modifier and Type	Method	Description
@NotNull Optional<DatabaseConnection>	getConnection(@NotNull String id)	Retrieves a database connection by its identifier.
void	init()	Initializes all database connections discovered from environment variables.
void	shutdown()	Shuts down all managed database connection pools.

Methods inherited from class java.lang.Object

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

Constructor Details

DatabaseConnectorServiceImpl

public DatabaseConnectorServiceImpl(@NotNull
 @NotNull Logger logger)

Creates a new database connector service.

Parameters:

logger - the logger for diagnostic messages

Method Details

init

public void init()
          throws ConnectionInitException

Description copied from interface: DatabaseConnectorService

Initializes all database connections discovered from environment variables.

Loads the MariaDB JDBC driver and creates HikariCP pools for each configured connection.

Specified by:

init in interface DatabaseConnectorService

Throws:

ConnectionInitException - if a connection with exit-on-failure enabled fails to initialize

shutdown

public void shutdown()

Description copied from interface: DatabaseConnectorService

Shuts down all managed database connection pools.

Specified by:

shutdown in interface DatabaseConnectorService

getConnection

@NotNull
public @NotNull Optional<DatabaseConnection> getConnection(@NotNull
 @NotNull String id)

Description copied from interface: DatabaseConnectorService

Retrieves a database connection by its identifier.

Specified by:

getConnection in interface DatabaseConnectorService

Parameters:

id - the connection identifier (case-sensitive, as extracted from environment variables)

Returns:

an Optional containing the connection, or empty if no connection exists with that id