driver-spring-integration/io.github.octaviusframework.driver.spring

Package-level declarations

Types

open class OctaviusJdbcTransactionManager(val dataSource: DataSource) : AbstractPlatformTransactionManager, ResourceTransactionManager

A transaction manager for a DataSource that runs each transaction through an OctaviusSession, so a failure of the database or the connection leaves it as the driver's own exception.

OctaviusSessionHolder

internal open class OctaviusSessionHolder(val session: OctaviusSession) : ResourceHolderSupport

Holds the session bound to the current transaction: by OctaviusJdbcTransactionManager for a transaction it begins, and by OctaviusTemplate for one another manager began, or for synchronization with no transaction behind it.

OctaviusSessionKey

internal data class OctaviusSessionKey(val dataSource: DataSource)

What an OctaviusSession is bound to the current transaction under.

OctaviusSessionSynchronization

internal class OctaviusSessionSynchronization(holder: OctaviusSessionHolder, key: OctaviusSessionKey, springTransaction: Boolean) : ResourceHolderSynchronization<OctaviusSessionHolder, OctaviusSessionKey>

Ends the transaction-scoped session at the right point in Spring's completion sequence.

OctaviusSpringAutoConfiguration

@AutoConfiguration(after = [DataSourceAutoConfiguration::class, TransactionManagerCustomizationAutoConfiguration::class], before = [DataSourceTransactionManagerAutoConfiguration::class, TransactionAutoConfiguration::class])

@ConditionalOnClass(value = [OctaviusSession::class, DataSource::class])

@ConditionalOnSingleCandidate(value = DataSource::class)

open class OctaviusSpringAutoConfiguration

Spring Boot auto-configuration for the Octavius driver.

OctaviusTemplate

class OctaviusTemplate(dataSource: DataSource)

Runs a block on an OctaviusSession: the running transaction's where there is one, otherwise one over a connection borrowed for the call.

TransactionTimeoutScope

enum TransactionTimeoutScope : Enum<TransactionTimeoutScope>

What a Spring transaction timeout - @Transactional(timeout = …), a TransactionTemplate's, or spring.transaction.default-timeout - is enforced on.

Functions

closeRollingBack

internal fun OctaviusSession.closeRollingBack()

Closes the session after rolling back the transaction a pool with auto-commit off leaves open on its connection - for a session no Spring transaction is running under any more.

connectionRefusal

internal fun connectionRefusal(ex: Exception, dataSource: DataSource): OctaviusException

The driver's exception for a connection dataSource would not hand over: the one in ex's cause chain where the data source was carrying a driver failure, and otherwise an InitializationException restating the refusal - CONNECTION_UNAVAILABLE for a transient one, which is how a pool reports having none free, and CONNECTION_ERROR for the rest.