com.atlassian.sal.core.rdbms

Class DefaultTransactionalExecutor

java.lang.Object

com.atlassian.sal.core.rdbms.DefaultTransactionalExecutor

All Implemented Interfaces:

TransactionalExecutor

public class DefaultTransactionalExecutor
extends Object
implements TransactionalExecutor

Default implementation that invokes HostConnectionAccessor.

Created by DefaultTransactionalExecutorFactory

Since:

3.0

Constructor Summary

Constructors

Constructor and Description
DefaultTransactionalExecutor(HostConnectionAccessor hostConnectionAccessor, boolean readOnly, boolean newTransaction)

Method Summary

Methods

Modifier and Type	Method and Description
<A> A	execute(ConnectionCallback<A> callback) Execute a callback which is supplied a Connection, within a transaction.
TransactionalExecutor	existingTransaction() Alter this executor so that the connection executes within an existing transaction or creates a new one if one is not present
TransactionalExecutor	newTransaction() Alter this executor so that it executes in a new transaction, regardless of any existing
TransactionalExecutor	readOnly() Alter this executor so that the connection is read-only
TransactionalExecutor	readWrite() Alter this executor so that the connection is read-write

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTransactionalExecutor

public DefaultTransactionalExecutor(@Nonnull
                            HostConnectionAccessor hostConnectionAccessor,
                            boolean readOnly,
                            boolean newTransaction)

Method Detail

execute

public <A> A execute(@Nonnull
            ConnectionCallback<A> callback)

Description copied from interface: TransactionalExecutor

Execute a callback which is supplied a Connection, within a transaction.

After successful execution, the transaction will be committed. If the transaction is within the scope of a larger transaction i.e. requiresNew has been set, it will be scheduled for commit, pending successful completion of the target transaction.

If any exception is thrown by callback, the transaction will be immediately rolled back.

Do not attempt to retain or reuse the Connection outside of the scope of callback or within a different thread. Connection is usually not considered thread safe.

A UnsupportedOperationException will be thrown on invoking any of the following:

• Connection.setAutoCommit(boolean)
• Connection.commit()
• Connection.close()
• Connection.rollback()
• Connection.setReadOnly(boolean)
• Connection.setReadOnly(boolean)
• Connection.abort(java.util.concurrent.Executor)
• Connection.setCatalog(String)
• Connection.setSchema(String)
• Connection.setTransactionIsolation(int)
• Connection.setNetworkTimeout(java.util.concurrent.Executor, int)

Specified by:

execute in interface TransactionalExecutor

Parameters:

callback - mandatory, may return Void

Returns:

return value of callback

readOnly

@Nonnull
public TransactionalExecutor readOnly()

Description copied from interface: TransactionalExecutor

Alter this executor so that the connection is read-only

Specified by:

readOnly in interface TransactionalExecutor

Returns:

this executor

readWrite

@Nonnull
public TransactionalExecutor readWrite()

Description copied from interface: TransactionalExecutor

Alter this executor so that the connection is read-write

Specified by:

readWrite in interface TransactionalExecutor

Returns:

this executor

newTransaction

@Nonnull
public TransactionalExecutor newTransaction()

Description copied from interface: TransactionalExecutor

Alter this executor so that it executes in a new transaction, regardless of any existing

Specified by:

newTransaction in interface TransactionalExecutor

Returns:

this executor

existingTransaction

@Nonnull
public TransactionalExecutor existingTransaction()

Description copied from interface: TransactionalExecutor

Alter this executor so that the connection executes within an existing transaction or creates a new one if one is not present

Specified by:

existingTransaction in interface TransactionalExecutor

Returns:

this executor