Module org.neo4j.driver

Package org.neo4j.driver.internal.async

Class UnmanagedTransaction

java.lang.Object

org.neo4j.driver.internal.async.UnmanagedTransaction

All Implemented Interfaces:

TerminationAwareStateLockingExecutor

public class UnmanagedTransaction
extends Object
implements TerminationAwareStateLockingExecutor

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	CANT_COMMIT_COMMITTED_MSG
protected static final String	CANT_COMMIT_ROLLED_BACK_MSG
protected static final String	CANT_COMMIT_ROLLING_BACK_MSG
protected static final String	CANT_ROLLBACK_COMMITTED_MSG
protected static final String	CANT_ROLLBACK_COMMITTING_MSG
protected static final String	CANT_ROLLBACK_ROLLED_BACK_MSG
static final String	EXPLICITLY_TERMINATED_MSG

Constructor Summary

Constructors

Modifier	Constructor	Description
	UnmanagedTransaction(DriverBoltConnection connection, org.neo4j.bolt.connection.DatabaseName databaseName, org.neo4j.bolt.connection.AccessMode accessMode, String impersonatedUser, Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer, long fetchSize, org.neo4j.bolt.connection.NotificationConfig notificationConfig, ApiTelemetryWork apiTelemetryWork, Consumer<String> databaseNameConsumer, Logging logging, DriverObservationProvider observationProvider)
protected	UnmanagedTransaction(DriverBoltConnection connection, org.neo4j.bolt.connection.DatabaseName databaseName, org.neo4j.bolt.connection.AccessMode accessMode, String impersonatedUser, Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer, long fetchSize, ResultCursorsHolder resultCursors, org.neo4j.bolt.connection.NotificationConfig notificationConfig, ApiTelemetryWork apiTelemetryWork, Consumer<String> databaseNameConsumer, Logging logging, DriverObservationProvider observationProvider)

Method Summary

Modifier and Type	Method	Description
CompletionStage<UnmanagedTransaction>	beginAsync(Set<Bookmark> initialBookmarks, TransactionConfig config, String txType, boolean flush, Observation parentObservation)
CompletionStage<Void>	closeAsync(boolean commit, Observation parentObservation)
CompletionStage<Void>	closeAsync(Observation parentObservation)
CompletionStage<Void>	commitAsync(Observation parentObservation)
DriverBoltConnection	connection()
<T> T	execute(Function<Throwable,T> causeOfTerminationConsumer)	Locks the state and executes the supplied Consumer with a cause of termination if the state is terminated.
boolean	isOpen()
void	markTerminated(Throwable cause)
CompletionStage<Void>	rollbackAsync(Observation parentObservation)
CompletionStage<ResultCursor>	runAsync(Query query, Observation parentObservation, Class<?> resultType)
CompletionStage<RxResultCursor>	runRx(Query query, Observation parentObservation)
CompletionStage<Void>	terminateAsync()

Methods inherited from class java.lang.Object

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

Field Details

EXPLICITLY_TERMINATED_MSG

public static final String EXPLICITLY_TERMINATED_MSG

See Also:

• Constant Field Values

CANT_COMMIT_COMMITTED_MSG

protected static final String CANT_COMMIT_COMMITTED_MSG

See Also:

• Constant Field Values

CANT_ROLLBACK_COMMITTED_MSG

protected static final String CANT_ROLLBACK_COMMITTED_MSG

See Also:

• Constant Field Values

CANT_COMMIT_ROLLED_BACK_MSG

protected static final String CANT_COMMIT_ROLLED_BACK_MSG

See Also:

• Constant Field Values

CANT_ROLLBACK_ROLLED_BACK_MSG

protected static final String CANT_ROLLBACK_ROLLED_BACK_MSG

See Also:

• Constant Field Values

CANT_COMMIT_ROLLING_BACK_MSG

protected static final String CANT_COMMIT_ROLLING_BACK_MSG

See Also:

• Constant Field Values

CANT_ROLLBACK_COMMITTING_MSG

protected static final String CANT_ROLLBACK_COMMITTING_MSG

See Also:

• Constant Field Values

Constructor Details

UnmanagedTransaction

public UnmanagedTransaction(DriverBoltConnection connection,
 org.neo4j.bolt.connection.DatabaseName databaseName,
 org.neo4j.bolt.connection.AccessMode accessMode,
 String impersonatedUser,
 Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer,
 long fetchSize,
 org.neo4j.bolt.connection.NotificationConfig notificationConfig,
 ApiTelemetryWork apiTelemetryWork,
 Consumer<String> databaseNameConsumer,
 Logging logging,
 DriverObservationProvider observationProvider)

UnmanagedTransaction

protected UnmanagedTransaction(DriverBoltConnection connection,
 org.neo4j.bolt.connection.DatabaseName databaseName,
 org.neo4j.bolt.connection.AccessMode accessMode,
 String impersonatedUser,
 Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer,
 long fetchSize,
 ResultCursorsHolder resultCursors,
 org.neo4j.bolt.connection.NotificationConfig notificationConfig,
 ApiTelemetryWork apiTelemetryWork,
 Consumer<String> databaseNameConsumer,
 Logging logging,
 DriverObservationProvider observationProvider)

Method Details

beginAsync

public CompletionStage<UnmanagedTransaction> beginAsync(Set<Bookmark> initialBookmarks,
 TransactionConfig config,
 String txType,
 boolean flush,
 Observation parentObservation)

closeAsync

public CompletionStage<Void> closeAsync(Observation parentObservation)

closeAsync

public CompletionStage<Void> closeAsync(boolean commit,
 Observation parentObservation)

commitAsync

public CompletionStage<Void> commitAsync(Observation parentObservation)

rollbackAsync

public CompletionStage<Void> rollbackAsync(Observation parentObservation)

runAsync

public CompletionStage<ResultCursor> runAsync(Query query,
 Observation parentObservation,
 Class<?> resultType)

runRx

public CompletionStage<RxResultCursor> runRx(Query query,
 Observation parentObservation)

isOpen

public boolean isOpen()

markTerminated

public void markTerminated(Throwable cause)

connection

public DriverBoltConnection connection()

terminateAsync

public CompletionStage<Void> terminateAsync()

execute

public <T> T execute(Function<Throwable,T> causeOfTerminationConsumer)

Description copied from interface: TerminationAwareStateLockingExecutor

Locks the state and executes the supplied Consumer with a cause of termination if the state is terminated.

Specified by:

execute in interface TerminationAwareStateLockingExecutor

Parameters:

causeOfTerminationConsumer - the consumer accepting