Package ru.tinkoff.kora.database.jdbc

Class JdbcDatabase

java.lang.Object

ru.tinkoff.kora.database.jdbc.JdbcDatabase

All Implemented Interfaces:

ru.tinkoff.kora.application.graph.Lifecycle, ru.tinkoff.kora.application.graph.Wrapped<DataSource>, ru.tinkoff.kora.common.readiness.ReadinessProbe, JdbcConnectionFactory

public class JdbcDatabase
extends Object
implements ru.tinkoff.kora.application.graph.Lifecycle, ru.tinkoff.kora.application.graph.Wrapped<DataSource>, JdbcConnectionFactory, ru.tinkoff.kora.common.readiness.ReadinessProbe

Nested Class Summary

Nested classes/interfaces inherited from interface ru.tinkoff.kora.application.graph.Wrapped

ru.tinkoff.kora.application.graph.Wrapped.UnwrappedValue<T extends Object>

Constructor Summary

Constructors

Constructor	Description
JdbcDatabase(JdbcDatabaseConfig databaseConfig, ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetry telemetry)
JdbcDatabase(JdbcDatabaseConfig config, ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetryFactory telemetryFactory)
JdbcDatabase(JdbcDatabaseConfig config, ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetryFactory telemetryFactory, Executor executor)
JdbcDatabase(JdbcDatabaseConfig databaseConfig, ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetry telemetry, Executor executor)

Method Summary

Modifier and Type	Method	Description
Connection	currentConnection()
void	init()
Connection	newConnection()
ru.tinkoff.kora.common.readiness.ReadinessProbeFailure	probe()
void	release()
ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetry	telemetry()
DataSource	value()
<T> T	withConnection(JdbcHelper.SqlFunction1<Connection,T> callback)

Methods inherited from class java.lang.Object

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

Methods inherited from interface ru.tinkoff.kora.database.jdbc.JdbcConnectionFactory

inTx, inTx, inTx, inTx, query, withConnection, withConnection, withConnection

Constructor Details

JdbcDatabase

public JdbcDatabase(JdbcDatabaseConfig config,
 ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetryFactory telemetryFactory)

JdbcDatabase

public JdbcDatabase(JdbcDatabaseConfig databaseConfig,
 ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetry telemetry)

JdbcDatabase

public JdbcDatabase(JdbcDatabaseConfig config,
 ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetryFactory telemetryFactory,
 @Nullable
 Executor executor)

JdbcDatabase

public JdbcDatabase(JdbcDatabaseConfig databaseConfig,
 ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetry telemetry,
 @Nullable
 Executor executor)

Method Details

init

public void init()
          throws SQLException

Specified by:

init in interface ru.tinkoff.kora.application.graph.Lifecycle

Throws:

SQLException

release

public void release()

Specified by:

release in interface ru.tinkoff.kora.application.graph.Lifecycle

value

public DataSource value()

Specified by:

value in interface ru.tinkoff.kora.application.graph.Wrapped<DataSource>

newConnection

@Nullable
public Connection newConnection()

Specified by:

newConnection in interface JdbcConnectionFactory

telemetry

public ru.tinkoff.kora.database.common.telemetry.DataBaseTelemetry telemetry()

Specified by:

telemetry in interface JdbcConnectionFactory

currentConnection

@Nullable
public Connection currentConnection()

Specified by:

currentConnection in interface JdbcConnectionFactory

withConnection

public <T> T withConnection(JdbcHelper.SqlFunction1<Connection,T> callback)
                     throws RuntimeSqlException

Specified by:

withConnection in interface JdbcConnectionFactory

Throws:

RuntimeSqlException

probe

public ru.tinkoff.kora.common.readiness.ReadinessProbeFailure probe()
                                                             throws Exception

Specified by:

probe in interface ru.tinkoff.kora.common.readiness.ReadinessProbe

Throws:

Exception