Package io.micronaut.transaction.impl

Class DefaultTransactionStatus<C>

java.lang.Object

io.micronaut.transaction.impl.AbstractInternalTransaction<C>

io.micronaut.transaction.impl.DefaultTransactionStatus<C>

Type Parameters:

C - The connection type

All Implemented Interfaces:

InternalTransaction<C>, TransactionExecution, TransactionStatus<C>

@Internal
public abstract sealed class DefaultTransactionStatus<C>
extends AbstractInternalTransaction<C>
implements InternalTransaction<C>

The default transaction status.

Since:

4.0.0

Author:

Denis Stepanov

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConnectionStatus<C>	connectionStatus

Fields inherited from class io.micronaut.transaction.impl.AbstractInternalTransaction

synchronizations

Method Summary

Modifier and Type	Method	Description
static <C> DefaultTransactionStatus<C>	existingTx(ConnectionStatus<C> connectionStatus, DefaultTransactionStatus<C> existingTransaction)
C	getConnection()
ConnectionStatus<C>	getConnectionStatus()
Object	getTransaction()
TransactionDefinition	getTransactionDefinition()	The transaction definition.
static <C> DefaultTransactionStatus<C>	newTx(ConnectionStatus<C> connectionStatus, TransactionDefinition definition)
static <C> DefaultTransactionStatus<C>	newTx(ConnectionStatus<C> connectionStatus, TransactionDefinition definition, @Nullable Function<DefaultTransactionStatus<C>,Object> transactionSupplier)
static <C> DefaultTransactionStatus<C>	noTx(ConnectionStatus<C> connectionStatus, TransactionDefinition definition)
static <C> DefaultTransactionStatus<C>	noTx(ConnectionStatus<C> connectionStatus, TransactionDefinition definition, @Nullable Function<DefaultTransactionStatus<C>,Object> transactionSupplier)

Methods inherited from class io.micronaut.transaction.impl.AbstractInternalTransaction

cleanupAfterCompletion, isCompleted, isGlobalRollbackOnly, isLocalRollbackOnly, isRollbackOnly, registerSynchronization, setGlobalRollbackOnly, setRollbackOnly, triggerAfterCommit, triggerAfterCompletion, triggerBeforeCommit, triggerBeforeCompletion

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.transaction.impl.InternalTransaction

cleanupAfterCompletion, isGlobalRollbackOnly, isLocalRollbackOnly, resume, suspend, triggerAfterCommit, triggerAfterCompletion, triggerBeforeCommit, triggerBeforeCompletion

Methods inherited from interface io.micronaut.transaction.TransactionExecution

isCompleted, isNewTransaction, isRollbackOnly, setRollbackOnly

Methods inherited from interface io.micronaut.transaction.TransactionStatus

registerSynchronization

Field Details

connectionStatus

protected final ConnectionStatus<C> connectionStatus

Method Details

newTx

public static <C> DefaultTransactionStatus<C> newTx(ConnectionStatus<C> connectionStatus,
 TransactionDefinition definition)

newTx

public static <C> DefaultTransactionStatus<C> newTx(ConnectionStatus<C> connectionStatus,
 TransactionDefinition definition,
 @Nullable
 @Nullable Function<DefaultTransactionStatus<C>,Object> transactionSupplier)

noTx

public static <C> DefaultTransactionStatus<C> noTx(ConnectionStatus<C> connectionStatus,
 TransactionDefinition definition)

noTx

public static <C> DefaultTransactionStatus<C> noTx(ConnectionStatus<C> connectionStatus,
 TransactionDefinition definition,
 @Nullable
 @Nullable Function<DefaultTransactionStatus<C>,Object> transactionSupplier)

existingTx

public static <C> DefaultTransactionStatus<C> existingTx(ConnectionStatus<C> connectionStatus,
 DefaultTransactionStatus<C> existingTransaction)

getTransaction

public Object getTransaction()

Specified by:

getTransaction in interface TransactionStatus<C>

Returns:

The underlying transaction object if exists.

getConnection

@NonNull
public C getConnection()

Specified by:

getConnection in interface TransactionStatus<C>

Returns:

The associated connection.

getConnectionStatus

public ConnectionStatus<C> getConnectionStatus()

Specified by:

getConnectionStatus in interface TransactionStatus<C>

Returns:

The connection status.

getTransactionDefinition

public TransactionDefinition getTransactionDefinition()

Description copied from interface: TransactionExecution

The transaction definition.

Specified by:

getTransactionDefinition in interface TransactionExecution

Returns:

the transaction definition