private void completeStrayTransaction() {
  if ( session == null ) {
    // nothing to do
    return;
  }

  if ( ( (SessionImplementor) session ).isClosed() ) {
    // nothing to do
    return;
  }

  if ( !session.isConnected() ) {
    // nothing to do
    return;
  }

  final TransactionCoordinator.TransactionDriver tdc =
      ( (SessionImplementor) session ).getTransactionCoordinator().getTransactionDriverControl();

  if ( tdc.getStatus().canRollback() ) {
    session.getTransaction().rollback();
  }
  session.close();
}
 

public TransactionImpl(
		TransactionCoordinator transactionCoordinator,
		ExceptionConverter exceptionConverter,
		AbstractSharedSessionContract session) {
	this.transactionCoordinator = transactionCoordinator;
	this.exceptionConverter = exceptionConverter;
	this.jpaCompliance = session.getFactory().getSessionFactoryOptions().getJpaCompliance();
	this.session = session;

	if ( session.isOpen() && transactionCoordinator.isActive() ) {
		this.transactionDriverControl = transactionCoordinator.getTransactionDriverControl();
	}
	else {
		LOG.debug( "TransactionImpl created on closed Session/EntityManager" );
	}

	if ( LOG.isDebugEnabled() ) {
		LOG.debugf(
				"On TransactionImpl creation, JpaCompliance#isJpaTransactionComplianceEnabled == %s",
				jpaCompliance.isJpaTransactionComplianceEnabled()
		);
	}
}
 

@Override
public TransactionCoordinator buildTransactionCoordinator(TransactionCoordinatorOwner owner, Options options) {
	if ( owner instanceof JdbcResourceTransactionAccess ) {
		return new JdbcResourceLocalTransactionCoordinatorImpl(
				this,
				owner,
				(JdbcResourceTransactionAccess) owner
		);
	}

	throw new HibernateException(
			"Could not determine ResourceLocalTransactionAccess to use in building TransactionCoordinator"
	);
}
 

@Override
public TransactionCoordinator buildTransactionCoordinator(TransactionCoordinatorOwner owner, Options options) {
	return new JtaTransactionCoordinatorImpl(
			this,
			owner,
			options.shouldAutoJoinTransaction()
	);
}
 

@Override
protected void addSharedSessionTransactionObserver(TransactionCoordinator transactionCoordinator) {
	this.transactionObserver = new TransactionObserver() {
		@Override
		public void afterBegin() {
		}

		@Override
		public void beforeCompletion() {
			if ( isOpen() && getHibernateFlushMode() !=  FlushMode.MANUAL ) {
				managedFlush();
			}
			actionQueue.beforeTransactionCompletion();
			try {
				getInterceptor().beforeTransactionCompletion( getCurrentTransaction() );
			}
			catch (Throwable t) {
				log.exceptionInBeforeTransactionCompletionInterceptor( t );
			}
		}

		@Override
		public void afterCompletion(boolean successful, boolean delayed) {
			afterTransactionCompletion( successful, delayed );
			if ( !isClosed() && autoClose ) {
				managedClose();
			}
		}
	};
	transactionCoordinator.addObserver(transactionObserver);
}
 

@Override
public TransactionCoordinator getTransactionCoordinator() {
	return delegate.getTransactionCoordinator();
}
 

@Override
public TransactionCoordinator getTransactionCoordinator() {
	return shareTransactionContext ? session.getTransactionCoordinator() : null;
}
 

@Override
protected void removeSharedSessionTransactionObserver(TransactionCoordinator transactionCoordinator) {
	super.removeSharedSessionTransactionObserver( transactionCoordinator );
	transactionCoordinator.removeObserver( transactionObserver );
}
 

protected void addSharedSessionTransactionObserver(TransactionCoordinator transactionCoordinator) {
}
 

protected void removeSharedSessionTransactionObserver(TransactionCoordinator transactionCoordinator) {
	transactionCoordinator.invalidate();
}
 

@Override
public TransactionCoordinator getTransactionCoordinator() {
	return transactionCoordinator;
}
 

@Override
public TransactionCoordinator getTransactionCoordinator() {
	return target.getTransactionCoordinator();
}
 

/**
 * Obtain the builder for TransactionCoordinator instances
 *
 * @return The TransactionCoordinatorBuilder
 */
TransactionCoordinator getTransactionCoordinator();
 

TransactionCoordinator getTransactionCoordinator();