org.hibernate.resource.transaction.backend.jdbc.internal

Class JdbcResourceLocalTransactionCoordinatorImpl

java.lang.Object

org.hibernate.resource.transaction.backend.jdbc.internal.JdbcResourceLocalTransactionCoordinatorImpl

All Implemented Interfaces:

TransactionCoordinator

public class JdbcResourceLocalTransactionCoordinatorImpl
extends Object
implements TransactionCoordinator

An implementation of TransactionCoordinator based on managing a transaction through the JDBC Connection via JdbcResourceTransaction

Author:

Steve Ebersole

See Also:

JdbcResourceTransaction

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JdbcResourceLocalTransactionCoordinatorImpl.TransactionDriverControlImpl The delegate bridging between the local (application facing) transaction and the "physical" notion of a transaction via the JDBC Connection.

Nested classes/interfaces inherited from interface org.hibernate.resource.transaction.TransactionCoordinator

TransactionCoordinator.TransactionDriver

Method Summary

Modifier and Type	Method and Description
void	addObserver(TransactionObserver observer) Adds an observer to the coordinator.
IsolationDelegate	createIsolationDelegate() Retrieve an isolation delegate appropriate for this transaction strategy.
void	explicitJoin() Indicates an explicit request to join a transaction.
SynchronizationRegistry	getLocalSynchronizations() Get access to the local registry of Synchronization instances
int	getTimeOut()
TransactionCoordinatorBuilder	getTransactionCoordinatorBuilder()
TransactionCoordinator.TransactionDriver	getTransactionDriverControl() Get the delegate used by the local transaction driver to control the underlying transaction
boolean	isActive() Is this transaction still active? Answers on a best effort basis.
boolean	isJoined() Determine if there is an active transaction that this coordinator is already joined to.
void	pulse() Used by owner of the JdbcSession as a means to indicate that implicit joining should be done if needed.
void	removeObserver(TransactionObserver observer) Removed an observer from the coordinator.
void	setTimeOut(int seconds)

Methods inherited from class java.lang.Object

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

Method Detail

getTransactionDriverControl

public TransactionCoordinator.TransactionDriver getTransactionDriverControl()

Description copied from interface: TransactionCoordinator

Get the delegate used by the local transaction driver to control the underlying transaction

Specified by:

getTransactionDriverControl in interface TransactionCoordinator

Returns:

The control delegate.

explicitJoin

public void explicitJoin()

Description copied from interface: TransactionCoordinator

Indicates an explicit request to join a transaction. This is mainly intended to handle the JPA requirement around EntityManager.joinTransaction(), and generally speaking only has an impact in JTA environments

Specified by:

explicitJoin in interface TransactionCoordinator

isJoined

public boolean isJoined()

Description copied from interface: TransactionCoordinator

Determine if there is an active transaction that this coordinator is already joined to.

Specified by:

isJoined in interface TransactionCoordinator

Returns:

true if there is an active transaction this coordinator is already joined to; false otherwise.

pulse

public void pulse()

Description copied from interface: TransactionCoordinator

Used by owner of the JdbcSession as a means to indicate that implicit joining should be done if needed.

Specified by:

pulse in interface TransactionCoordinator

getLocalSynchronizations

public SynchronizationRegistry getLocalSynchronizations()

Description copied from interface: TransactionCoordinator

Get access to the local registry of Synchronization instances

Specified by:

getLocalSynchronizations in interface TransactionCoordinator

Returns:

The local Synchronization registry

isActive

public boolean isActive()

Description copied from interface: TransactionCoordinator

Is this transaction still active?

Answers on a best effort basis. For example, in the case of JDBC based transactions we cannot know that a transaction is active when it is initiated directly through the JDBC Connection, only when it is initiated from here.

Specified by:

isActive in interface TransactionCoordinator

Returns:

true if the transaction is still active; false otherwise.

createIsolationDelegate

public IsolationDelegate createIsolationDelegate()

Description copied from interface: TransactionCoordinator

Retrieve an isolation delegate appropriate for this transaction strategy.

Specified by:

createIsolationDelegate in interface TransactionCoordinator

Returns:

An isolation delegate.

getTransactionCoordinatorBuilder

public TransactionCoordinatorBuilder getTransactionCoordinatorBuilder()

Specified by:

getTransactionCoordinatorBuilder in interface TransactionCoordinator

Returns:

setTimeOut

public void setTimeOut(int seconds)

Specified by:

setTimeOut in interface TransactionCoordinator

getTimeOut

public int getTimeOut()

Specified by:

getTimeOut in interface TransactionCoordinator

addObserver

public void addObserver(TransactionObserver observer)

Description copied from interface: TransactionCoordinator

Adds an observer to the coordinator.

observers are not to be cleared on transaction completion.

Specified by:

addObserver in interface TransactionCoordinator

Parameters:

observer - The observer to add.

removeObserver

public void removeObserver(TransactionObserver observer)

Description copied from interface: TransactionCoordinator

Removed an observer from the coordinator.

Specified by:

removeObserver in interface TransactionCoordinator

Parameters:

observer - The observer to remove.