Package org.axonframework.common.jdbc

Class ConnectionExecutor

java.lang.Object

org.axonframework.common.jdbc.ConnectionExecutor

All Implemented Interfaces:

TransactionalExecutor<Connection>

@Internal
public class ConnectionExecutor
extends Object
implements TransactionalExecutor<Connection>

A TransactionalExecutor implementation for JDBC Connections.

Since:

5.0.2

Author:

John Hendrikx

Constructor Summary

Constructors

Constructor	Description
ConnectionExecutor(ConnectionProvider provider)	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
<R> CompletableFuture<R>	apply(ThrowingFunction<Connection,R,Exception> function)	Executes a transactional operation that returns a result.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.common.tx.TransactionalExecutor

accept

Constructor Details

ConnectionExecutor

public ConnectionExecutor(@Nonnull
 ConnectionProvider provider)

Creates a new instance.

Parameters:

provider - A ConnectionProvider, cannot be null.

Throws:

NullPointerException - If any argument is null.

Method Details

apply

public <R> CompletableFuture<R> apply(@Nonnull
 ThrowingFunction<Connection,R,Exception> function)

Description copied from interface: TransactionalExecutor

Executes a transactional operation that returns a result.

Implementations are responsible for managing the lifecycle of the provided resource, including obtaining, closing, commit and rollback.

Specified by:

apply in interface TransactionalExecutor<Connection>

Type Parameters:

R - The type of the result returned by the function.

Parameters:

function - A function that accepts the transactional resource of type T and produces a result of type R; cannot be null.

Returns:

A CompletableFuture which when it completes contains the result of the provided function, never null.