GlobalSuspendStatementInterceptor

interface GlobalSuspendStatementInterceptor : SuspendStatementInterceptor

Represents a SuspendStatementInterceptor that is loaded whenever a R2dbcTransaction instance is initialized.

Members

Functions

afterCommit

Link copied to clipboard

open suspend fun afterCommit(transaction: R2dbcTransaction)

Performs steps after a transaction is committed.

afterExecution

Link copied to clipboard

open suspend fun afterExecution(transaction: R2dbcTransaction, contexts: List<StatementContext>, executedStatement: R2dbcPreparedStatementApi)

Performs steps after an executedStatement, from the provided contexts, is complete in transaction.

afterRollback

Link copied to clipboard

open suspend fun afterRollback(transaction: R2dbcTransaction)

Performs steps after a rollback operation is issued on a transaction.

afterStatementPrepared

Link copied to clipboard

open suspend fun afterStatementPrepared(transaction: R2dbcTransaction, preparedStatement: R2dbcPreparedStatementApi)

Performs steps after preparedStatement has been created in a transaction, but before the statement has been executed.

beforeCommit

Link copied to clipboard

open suspend fun beforeCommit(transaction: R2dbcTransaction)

Performs steps before a transaction is committed.

beforeExecution

Link copied to clipboard

open suspend fun beforeExecution(transaction: R2dbcTransaction, context: StatementContext)

Performs steps before a statement, from the provided context, is executed in a transaction.

beforeRollback

Link copied to clipboard

open suspend fun beforeRollback(transaction: R2dbcTransaction)

Performs steps before a rollback operation is issued on a transaction.

keepUserDataInTransactionStoreOnCommit

Link copied to clipboard

open fun keepUserDataInTransactionStoreOnCommit(userData: Map<Key<*>, Any?>): Map<Key<*>, Any?>

Returns a mapping of userData that ensures required information is not lost from the transaction scope once the transaction is committed. This function will be called directly ahead of the call to beforeCommit().