core/io.github.octaviusframework.db.core.jdbc/DefaultJdbcTransactionProvider

DefaultJdbcTransactionProvider

internal class DefaultJdbcTransactionProvider(val dataSource: DataSource) : JdbcTransactionProvider

Default implementation of JdbcTransactionProvider using ThreadLocal to manage transactions. This implementation does not depend on any external transaction managers (like Spring).

It supports:

Nested transactions via Savepoints.
Propagation (REQUIRED, REQUIRES_NEW).
Automatic restoration of connection state (isolation level, read-only) after transaction completion.
Transaction timeouts via PostgreSQL 'statement_timeout'.

Constructors

DefaultJdbcTransactionProvider

constructor(dataSource: DataSource)

Properties

dataSource

open override val dataSource: DataSource

The underlying data source used for obtaining connections.

Functions

applyTimeout

open override fun applyTimeout(statement: Statement)

Applies the current transaction timeout to the given statement.

execute

open override fun <T> execute(propagation: TransactionPropagation, isolation: IsolationLevel, readOnly: Boolean, timeoutSeconds: Int?, block: (TransactionStatus) -> T): T

Executes a block of code within a transaction context.

getConnection

open override fun getConnection(): Connection

Obtains a connection for the current execution context. If a transaction is active, returns the connection bound to that transaction. Otherwise, returns a new connection from the dataSource.

releaseConnection

open override fun releaseConnection(connection: Connection)

Releases the given connection. If the connection is part of an active transaction, it is NOT closed. Otherwise, it is returned to the pool (closed).