/*
* Hibernate, Relational Persistence for Idiomatic Java
*
* License: GNU Lesser General Public License (LGPL), version 2.1 or later.
* See the lgpl.txt file in the root directory or <http://www.gnu.org/licenses/lgpl-2.1.html>.
*/
package org.hibernate.resource.transaction.spi;
import org.hibernate.engine.transaction.spi.IsolationDelegate;
import org.hibernate.engine.transaction.spi.TransactionObserver;
import org.hibernate.jpa.spi.JpaCompliance;
Models the coordination of all transaction related flows.
Author: Steve Ebersole
/**
* Models the coordination of all transaction related flows.
*
* @author Steve Ebersole
*/
public interface TransactionCoordinator {
Access to the builder that generated this coordinator
/**
* Access to the builder that generated this coordinator
*/
TransactionCoordinatorBuilder getTransactionCoordinatorBuilder();
Get the delegate used by the local transaction driver to control the underlying transaction
Returns: The control delegate.
/**
* Get the delegate used by the local transaction driver to control the underlying transaction
*
* @return The control delegate.
*/
TransactionDriver getTransactionDriverControl();
Get access to the local registry of Synchronization instances
Returns: The local Synchronization registry
/**
* Get access to the local registry of Synchronization instances
*
* @return The local Synchronization registry
*/
SynchronizationRegistry getLocalSynchronizations();
JpaCompliance getJpaCompliance();
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 /**
* Indicates an explicit request to join a transaction. This is mainly intended to handle the JPA requirement
* around {@link javax.persistence.EntityManager#joinTransaction()}, and generally speaking only has an impact in
* JTA environments
*/
void explicitJoin();
Determine if there is an active transaction that this coordinator is already joined to.
Returns: true
if there is an active transaction this coordinator is already joined to; false
otherwise.
/**
* Determine if there is an active transaction that this coordinator is already joined to.
*
* @return {@code true} if there is an active transaction this coordinator is already joined to; {@code false}
* otherwise.
*/
boolean isJoined();
Used by owner of the JdbcSession as a means to indicate that implicit joining should be done if needed.
/**
* Used by owner of the JdbcSession as a means to indicate that implicit joining should be done if needed.
*/
void pulse();
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. Throws: - HibernateException – Indicates a problem checking the transaction status.
Returns: true
if the transaction is still active; false
otherwise.
/**
* Is this transaction still active?
* <p/>
* 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 {@link java.sql.Connection}, only when
* it is initiated from here.
*
* @return {@code true} if the transaction is still active; {@code false} otherwise.
*
* @throws org.hibernate.HibernateException Indicates a problem checking the transaction status.
*/
boolean isActive();
Retrieve an isolation delegate appropriate for this transaction strategy.
Returns: An isolation delegate.
/**
* Retrieve an isolation delegate appropriate for this transaction strategy.
*
* @return An isolation delegate.
*/
IsolationDelegate createIsolationDelegate();
Adds an observer to the coordinator.
observers are not to be cleared on transaction completion.
Params: - observer – The observer to add.
/**
* Adds an observer to the coordinator.
* <p/>
* observers are not to be cleared on transaction completion.
*
* @param observer The observer to add.
*/
void addObserver(TransactionObserver observer);
Removed an observer from the coordinator.
Params: - observer – The observer to remove.
/**
* Removed an observer from the coordinator.
*
* @param observer The observer to remove.
*/
void removeObserver(TransactionObserver observer);
void setTimeOut(int seconds);
int getTimeOut();
default boolean isTransactionActive() {
return isTransactionActive( true );
}
default boolean isTransactionActive(boolean isMarkedRollbackConsideredActive) {
return isJoined() && getTransactionDriverControl().isActive( isMarkedRollbackConsideredActive );
}
default void invalidate(){}
Provides the means for "local transactions" (as transaction drivers) to control the
underlying "physical transaction" currently associated with the TransactionCoordinator.
Author: Steve Ebersole
/**
* Provides the means for "local transactions" (as transaction drivers) to control the
* underlying "physical transaction" currently associated with the TransactionCoordinator.
*
* @author Steve Ebersole
*/
interface TransactionDriver {
Begin the physical transaction
/**
* Begin the physical transaction
*/
void begin();
Commit the physical transaction
/**
* Commit the physical transaction
*/
void commit();
Rollback the physical transaction
/**
* Rollback the physical transaction
*/
void rollback();
TransactionStatus getStatus();
void markRollbackOnly();
default boolean isActive(boolean isMarkedRollbackConsideredActive) {
final TransactionStatus status = getStatus();
return TransactionStatus.ACTIVE == status
|| ( isMarkedRollbackConsideredActive && TransactionStatus.MARKED_ROLLBACK == status );
}
// todo : org.hibernate.Transaction will need access to register local Synchronizations.
// depending on how we integrate TransactionCoordinator/TransactionDriverControl with
// org.hibernate.Transaction that might be best done by:
// 1) exposing registerSynchronization here (if the Transaction is just passed this)
// 2) using the exposed TransactionCoordinator#getLocalSynchronizations (if the Transaction is passed the TransactionCoordinator)
//
// if
}
}