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

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.

ResourceHolderSynchronization unbinds it over a suspension, so a REQUIRES_NEW transaction inside another does not find the outer one's session.

Constructors

constructor(holder: OctaviusSessionHolder, key: OctaviusSessionKey, springTransaction: Boolean)

Properties

order

open override val order: Int

Functions

afterCommit

open fun afterCommit()

afterCompletion

open fun afterCompletion(status: Int)

beforeCommit

open fun beforeCommit(readOnly: Boolean)

beforeCompletion

open fun beforeCompletion()

cleanupResource

protected open fun cleanupResource(resourceHolder: OctaviusSessionHolder?, resourceKey: OctaviusSessionKey?, committed: Boolean)

flush

open fun flush()

flushResource

protected open fun flushResource(resourceHolder: OctaviusSessionHolder?)

getOrder

open override fun getOrder(): Int

Ahead of Spring's own connection synchronization, which releases the connection at DataSourceUtils.CONNECTION_SYNCHRONIZATION_ORDER. Ending the session runs statements on that connection, so it has to come first.

processResourceAfterCommit

protected open fun processResourceAfterCommit(resourceHolder: OctaviusSessionHolder?)

releaseResource

protected open override fun releaseResource(resourceHolder: OctaviusSessionHolder, resourceKey: OctaviusSessionKey)

resume

open fun resume()

savepoint

open fun savepoint(savepoint: Any?)

savepointRollback

open fun savepointRollback(savepoint: Any?)

shouldReleaseAfterCompletion

protected open fun shouldReleaseAfterCompletion(resourceHolder: OctaviusSessionHolder?): Boolean

shouldReleaseBeforeCompletion

protected open override fun shouldReleaseBeforeCompletion(): Boolean

Moves the release of a session in a transaction Spring began from beforeCompletion to afterCompletion. Before completion a failed transaction is still failed, every statement gets 25P02, and a session that cannot reset its connection gives it up - one connection for every transaction that failed on the server. After completion the connection answers again, and Spring has not released it yet.

shouldUnbindAtCompletion

protected open fun shouldUnbindAtCompletion(): Boolean

suspend

open fun suspend()