A B C D E F G H I L M N O P Q R S T U V W

A

add(ProxyExecutionListener) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener

Add a ProxyExecutionListener.

addAll(Collection<ProxyExecutionListener>) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener

Add a list of ProxyExecutionListener.

addConsumer(BiConsumer<MethodExecutionInfo, StringBuilder>) - Method in class io.r2dbc.proxy.support.MethodExecutionInfoFormatter

Register a consumer that converts MethodExecutionInfo to a String.

addConsumer(BiConsumer<QueryExecutionInfo, StringBuilder>) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Register a BiConsumer that convert QueryExecutionInfo to String.

addIndexBinding(Bindings.IndexBinding) - Method in class io.r2dbc.proxy.core.Bindings

Add an index binding.

addListener(ProxyExecutionListener) - Method in class io.r2dbc.proxy.callback.ProxyConfig

Register ProxyExecutionListener.

addNamedBinding(Bindings.NamedBinding) - Method in class io.r2dbc.proxy.core.Bindings

Add a named binding.

afterAddOnBatch(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Batch.add(String) is called.

afterAddOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Statement.add() is called.

afterBeginTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.beginTransaction() is called.

afterBindNullOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Statement.bindNull(int, Class) or Statement.bindNull(String, Class) are called.

afterBindOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Statement.bind(int, Object) or Statement.bind(String, Object) are called.

afterCloseOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.close() is called.

afterCommitTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.commitTransaction() is called.

afterCreateBatchOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.createBatch() is called.

afterCreateOnConnectionFactory(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after ConnectionFactory.create() is called.

afterCreateSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.createSavepoint(String) is called.

afterCreateStatementOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.createStatement(String) is called.

afterExecuteOnBatch(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Batch.execute() is called.

afterExecuteOnBatch(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Query execution callback that is invoked after Batch.execute() is called.

afterExecuteOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Statement.execute() is called.

afterExecuteOnStatement(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Query execution callback that is invoked after Statement.execute() is called.

afterFetchSizeOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Statement.fetchSize(int) is called.

afterFilterOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Result.filter(Predicate) is called.

afterFlatMapOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Result.flatMap(Function) is called.

afterGetMetadataOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.getMetadata() is called.

afterGetMetadataOnConnectionFactory(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after ConnectionFactory.getMetadata() is called.

afterGetMetadataOnRow(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Row#getMetadata(...) is called.

afterGetOnRow(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Row#get(...) is called.

afterGetRowsUpdatedOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Result.getRowsUpdated() is called.

afterGetTransactionIsolationLevelOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.getTransactionIsolationLevel() is called.

afterIsAutoCommitOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.isAutoCommit() is called.

afterMapOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Result.map(BiFunction) or Result.map(Function) is called.

afterMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener

afterMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

afterMethod(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener

Called after every invocation of methods.

afterMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter

afterQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener

afterQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

afterQuery(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener

Called after executing a query (Batch.execute() or Statement.execute()).

afterQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter

afterQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener

afterReleaseSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.releaseSavepoint(String) is called.

afterReturnGeneratedValuesOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Statement.returnGeneratedValues(String...) is called.

afterRollbackTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.rollbackTransaction() is called.

afterRollbackTransactionToSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.rollbackTransactionToSavepoint(String) is called.

afterSetAutoCommitOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.setAutoCommit(boolean) is called.

afterSetLockWaitTimeoutOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.setLockWaitTimeout(Duration) is called.

afterSetStatementTimeoutOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.setStatementTimeout(Duration) is called.

afterSetTransactionIsolationLevelOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.setTransactionIsolationLevel(IsolationLevel) is called.

afterValidateOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked after Connection.validate(ValidationDepth) is called.

apply(MethodExecutionInfo) - Method in class io.r2dbc.proxy.support.MethodExecutionInfoFormatter

apply(QueryExecutionInfo) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Assert - Class in io.r2dbc.proxy.util

Assertion library for the implementation.

B

BatchCallbackHandler - Class in io.r2dbc.proxy.callback

Proxy callback handler for Batch.

BatchCallbackHandler(Batch, ConnectionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.BatchCallbackHandler

batchSize(int) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

beforeAddOnBatch(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Batch.add(String) is called.

beforeAddOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Statement.add() is called.

beforeBeginTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.beginTransaction() is called.

beforeBindNullOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Statement.bindNull(int, Class) or Statement.bindNull(String, Class) are called.

beforeBindOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Statement.bind(int, Object) or Statement.bind(String, Object) are called.

beforeCloseOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.close() is called.

beforeCommitTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.commitTransaction() is called.

beforeCreateBatchOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.createBatch() is called.

beforeCreateOnConnectionFactory(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before ConnectionFactory.create() is called.

beforeCreateSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.createSavepoint(String) is called.

beforeCreateStatementOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.createStatement(String) is called.

beforeExecuteOnBatch(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Batch.execute() is called.

beforeExecuteOnBatch(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Query execution callback that is invoked before Batch.execute() is called.

beforeExecuteOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Statement.execute() is called.

beforeExecuteOnStatement(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Query execution callback that is invoked before Statement.execute() is called.

beforeFetchSizeOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Statement.fetchSize(int) is called.

beforeFilterOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Result.filter(Predicate) is called.

beforeFlatMapOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Result.flatMap(Function) is called.

beforeGetMetadataOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.getMetadata() is called.

beforeGetMetadataOnConnectionFactory(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before ConnectionFactory.getMetadata() is called.

beforeGetMetadataOnRow(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Row#getMetadata(...) is called.

beforeGetOnRow(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Row#get(...) is called.

beforeGetRowsUpdatedOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Result.getRowsUpdated() is called.

beforeGetTransactionIsolationLevelOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.getTransactionIsolationLevel() is called.

beforeIsAutoCommitOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.isAutoCommit() is called.

beforeMapOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Result.map(BiFunction) or Result.map(Function) is called.

beforeMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener

beforeMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

beforeMethod(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener

Called before every invocation of methods.

beforeMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter

beforeQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener

beforeQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

beforeQuery(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener

Called before executing a query (Batch.execute() or Statement.execute()).

beforeQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter

beforeQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener

beforeReleaseSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.releaseSavepoint(String) is called.

beforeReturnGeneratedValuesOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Statement.returnGeneratedValues(String...) is called.

beforeRollbackTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.rollbackTransaction() is called.

beforeRollbackTransactionToSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.rollbackTransactionToSavepoint(String) is called.

beforeSetAutoCommitOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.setAutoCommit(boolean) is called.

beforeSetLockWaitTimeoutOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.setLockWaitTimeout(Duration) is called.

beforeSetStatementTimeoutOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.setStatementTimeout(Duration) is called.

beforeSetTransactionIsolationLevelOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.setTransactionIsolationLevel(IsolationLevel) is called.

beforeValidateOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener

Callback that is invoked before Connection.validate(ValidationDepth) is called.

BindInfo - Interface in io.r2dbc.proxy.core

Hold contextual information for bind operations(bind and bindNull).

Binding - Interface in io.r2dbc.proxy.core

Represent an operation of Statement.bind(int, java.lang.Object) and Statement.bindNull(int, java.lang.Class<?>).

Bindings - Class in io.r2dbc.proxy.core

Represent set of Binding for each batch.

Bindings() - Constructor for class io.r2dbc.proxy.core.Bindings

Bindings.IndexBinding - Class in io.r2dbc.proxy.core

Represents index binding.

Bindings.NamedBinding - Class in io.r2dbc.proxy.core

Represents named(String) binding.

bindingsSize(int) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

bindParameterConverter(BindParameterConverter) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder

Set BindParameterConverter.

BindParameterConverter - Interface in io.r2dbc.proxy.listener

Callback for Connection.createStatement(String) and bind operations(bind and bindNull).

BindParameterConverter.BindOperation - Interface in io.r2dbc.proxy.listener

Represent bind operation(bind and bindNull).

BoundValue - Interface in io.r2dbc.proxy.core

Represent a value for Statement.bind(int, java.lang.Object) and Statement.bindNull(int, java.lang.Class<?>) operations.

boundValue(BiConsumer<BoundValue, StringBuilder>) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Set a consumer for converting BoundValue.

BoundValue.DefaultBoundValue - Class in io.r2dbc.proxy.core

Default implementation of BoundValue.

build() - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder

Build a ProxyConfig.

build() - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Build a proxy ConnectionFactory.

build() - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder

build() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

build() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

build() - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder

builder() - Static method in class io.r2dbc.proxy.callback.ProxyConfig

Create a new ProxyConfig.Builder.

Builder() - Constructor for class io.r2dbc.proxy.callback.ProxyConfig.Builder

builder(ConnectionFactory) - Static method in class io.r2dbc.proxy.ProxyConnectionFactory

Create a new ProxyConnectionFactory.Builder.

builder(ConnectionFactory, ProxyConfig) - Static method in class io.r2dbc.proxy.ProxyConnectionFactory

Create a new ProxyConnectionFactory.Builder.

builder() - Static method in class io.r2dbc.proxy.test.MockConnectionInfo

Provides a builder for MockConnectionInfo.

builder() - Static method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

Provides a builder for MockMethodExecutionInfo.

builder() - Static method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

Provides a builder for MockQueryExecutionInfo.

Builder() - Constructor for class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

builder() - Static method in class io.r2dbc.proxy.test.MockStatementInfo

Provide a builder for MockStatementInfo.

Builder() - Constructor for class io.r2dbc.proxy.test.MockStatementInfo.Builder

C

CallbackHandler - Interface in io.r2dbc.proxy.callback

Callback logic for proxy invocation.

chompIfEndWith(StringBuilder, char) - Method in class io.r2dbc.proxy.observation.DefaultQueryParametersTagProvider

clock(Clock) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder

Set Clock.

commitCount(int) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder

compareTo(Bindings.IndexBinding) - Method in class io.r2dbc.proxy.core.Bindings.IndexBinding

compareTo(Bindings.NamedBinding) - Method in class io.r2dbc.proxy.core.Bindings.NamedBinding

CompositeProxyExecutionListener - Class in io.r2dbc.proxy.listener

Delegate to multiple of ProxyExecutionListeners.

CompositeProxyExecutionListener(ProxyExecutionListener...) - Constructor for class io.r2dbc.proxy.listener.CompositeProxyExecutionListener

ConnectionCallbackHandler - Class in io.r2dbc.proxy.callback

Proxy callback handler for Connection.

ConnectionCallbackHandler(Connection, ConnectionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.ConnectionCallbackHandler

ConnectionFactoryCallbackHandler - Class in io.r2dbc.proxy.callback

Proxy callback handler for ConnectionFactory.

ConnectionFactoryCallbackHandler(ConnectionFactory, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler

ConnectionHolder - Interface in io.r2dbc.proxy.callback

Provide methods to retrieve original Connection from proxy object.

connectionId(String) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder

ConnectionIdManager - Interface in io.r2dbc.proxy.callback

Connection ID manager interface.

connectionIdManager(ConnectionIdManager) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder

Set ConnectionIdManager.

ConnectionInfo - Interface in io.r2dbc.proxy.core

Hold Connection related information.

connectionInfo(ConnectionInfo) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

connectionInfo(ConnectionInfo) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

connectionInfo(ConnectionInfo) - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder

create() - Static method in interface io.r2dbc.proxy.callback.ConnectionIdManager

Create a default ConnectionIdManager.

create(ProxyConfig) - Method in interface io.r2dbc.proxy.callback.ProxyFactoryFactory

Create ProxyFactory with given ProxyConfig.

create() - Static method in interface io.r2dbc.proxy.core.ValueStore

Create default ValueStore.

create() - Static method in interface io.r2dbc.proxy.listener.BindParameterConverter

Create default BindParameterConverter.

create() - Static method in interface io.r2dbc.proxy.listener.ResultRowConverter

Create a default ResultRowConverter.

create(ConnectionFactoryOptions) - Method in class io.r2dbc.proxy.ProxyConnectionFactoryProvider

Create a new proxy ConnectionFactory from given ConnectionFactoryOptions.

currentMappedResult(Object) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

currentResultCount(int) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

customValue(Object, Object) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

customValue(Object, Object) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

customValues(Map<Object, Object>) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

customValues(Map<Object, Object>) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

D

DefaultBoundValue() - Constructor for class io.r2dbc.proxy.core.BoundValue.DefaultBoundValue

DefaultQueryParametersTagProvider - Class in io.r2dbc.proxy.observation

Default implementation for QueryParametersTagProvider.

DefaultQueryParametersTagProvider() - Constructor for class io.r2dbc.proxy.observation.DefaultQueryParametersTagProvider

DefaultValueStore - Class in io.r2dbc.proxy.core

Default implementation of ValueStore.

DefaultValueStore() - Constructor for class io.r2dbc.proxy.core.DefaultValueStore

DelegatingContextView - Class in io.r2dbc.proxy.callback

ContextView implementation that delegates to the given ContextView in constructor.

DelegatingContextView(ContextView) - Constructor for class io.r2dbc.proxy.callback.DelegatingContextView

delimiter(String) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Set a delimiter between each consumer

E

eachQueryResult(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener

eachQueryResult(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

eachQueryResult(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener

Called on processing each query Result.

eachQueryResult(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter

eachQueryResult(QueryExecutionInfo) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener

empty() - Static method in class io.r2dbc.proxy.test.MockConnectionInfo

Provide an empty MockConnectionInfo.

empty() - Static method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

Provide an empty MockMethodExecutionInfo.

empty() - Static method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

Provide an empty MockMethodExecutionInfo.

empty() - Static method in class io.r2dbc.proxy.test.MockStatementInfo

Provide an empty MockStatementInfo.

executeDuration(Duration) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

executeDuration(Duration) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

ExecutionType - Enum in io.r2dbc.proxy.core

Query execution type.

F

format(MethodExecutionInfo) - Method in class io.r2dbc.proxy.support.MethodExecutionInfoFormatter

Convert the given MethodExecutionInfo to String using registered consumers.

format(QueryExecutionInfo) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Convert the given QueryExecutionInfo to String using registered consumers.

from(MockQueryExecutionInfo) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

G

get(Object) - Method in class io.r2dbc.proxy.callback.DelegatingContextView

get(Object) - Method in class io.r2dbc.proxy.core.DefaultValueStore

get(Object, Class<T>) - Method in class io.r2dbc.proxy.core.DefaultValueStore

get(Object) - Method in interface io.r2dbc.proxy.core.ValueStore

Get the value associated to the key.

get(Object, Class<T>) - Method in interface io.r2dbc.proxy.core.ValueStore

Get the value associated to the key and cast to the type.

getAfterMethodExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

Get the last used MethodExecutionInfo in ProxyExecutionListener.afterMethod(MethodExecutionInfo).

getAfterQueryExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

Get the last used QueryExecutionInfo in ProxyExecutionListener.afterQuery(QueryExecutionInfo).

getBatchSize() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the size of the batch query.

getBatchSize() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getBeforeMethodExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

Get the last used MethodExecutionInfo in ProxyExecutionListener.beforeMethod(MethodExecutionInfo).

getBeforeQueryExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

Get the last used QueryExecutionInfo in ProxyExecutionListener.beforeQuery(QueryExecutionInfo).

getBinding() - Method in interface io.r2dbc.proxy.core.BindInfo

Get invoked bind operation details.

getBindingsList() - Method in class io.r2dbc.proxy.core.QueryInfo

Get the list of Bindings.

getBindingsSize() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the number of the binding.

getBindingsSize() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getBindParameterConverter() - Method in class io.r2dbc.proxy.callback.ProxyConfig

Get BindParameterConverter.

getBoundValue() - Method in interface io.r2dbc.proxy.core.Binding

Get a BoundValue.

getBoundValue() - Method in class io.r2dbc.proxy.core.Bindings.IndexBinding

getBoundValue() - Method in class io.r2dbc.proxy.core.Bindings.NamedBinding

getClock() - Method in class io.r2dbc.proxy.callback.ProxyConfig

Get Clock.

getCommitCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Returns how many times Connection.commitTransaction() method is called.

getCommitCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

getConnectionFactory() - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Return the ConnectionFactory passed at creation.

getConnectionId() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Get ID for the connection.

getConnectionId() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

getConnectionIdManager() - Method in class io.r2dbc.proxy.callback.ProxyConfig

Get ConnectionIdManager.

getConnectionInfo() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the ConnectionInfo.

getConnectionInfo() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the associated ConnectionInfo.

getConnectionInfo() - Method in interface io.r2dbc.proxy.core.StatementInfo

Get ConnectionInfo associated to this Statement.

getConnectionInfo() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getConnectionInfo() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getConnectionInfo() - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder

getConnectionInfo() - Method in class io.r2dbc.proxy.test.MockStatementInfo

getConnectionName() - Method in class io.r2dbc.proxy.observation.QueryContext

getContextualName(QueryContext) - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention

getCurrentMappedResult() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Mapped query result available for each-query-result-callback(ProxyExecutionListener.eachQueryResult(QueryExecutionInfo)).

getCurrentMappedResult() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getCurrentResultCount() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Represent Nth Result.

getCurrentResultCount() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getDelegate() - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter

getDriver() - Method in class io.r2dbc.proxy.ProxyConnectionFactoryProvider

getEachQueryResultExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener

Get the last used QueryExecutionInfo in ProxyExecutionListener.eachQueryResult(QueryExecutionInfo).

getElapsedDuration() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext

Retrieve the elapsed time from the stopwatch that has started by QueriesExecutionContext.startStopwatch().

getExecuteDuration() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the duration of the method invocation.

getExecuteDuration() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the time that took queries to execute.

getExecuteDuration() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getExecuteDuration() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getHighCardinalityKeyValues(QueryContext) - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention

getId(Connection) - Method in interface io.r2dbc.proxy.callback.ConnectionIdManager

Get ID for the input Connection.

getIndexBindings() - Method in class io.r2dbc.proxy.core.Bindings

Get a sorted set of index bindings.

getKey() - Method in interface io.r2dbc.proxy.core.Binding

Get a key which represents index or name of the binding.

getKey() - Method in class io.r2dbc.proxy.core.Bindings.IndexBinding

getKey() - Method in class io.r2dbc.proxy.core.Bindings.NamedBinding

getListeners() - Method in class io.r2dbc.proxy.callback.ProxyConfig

Returns CompositeProxyExecutionListener that contains registered ProxyExecutionListener.

getListeners() - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener

Get registered listeners.

getLowCardinalityKeyValues(QueryContext) - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention

getMethod() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the invoked Method.

getMethod() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the invoked query execution Method.

getMethod() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getMethod() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getMethodArgs() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the arguments of the invocation.

getMethodArgs() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the arguments of the invocation.

getMethodArgs() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getMethodArgs() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getName() - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention

getNamedBindings() - Method in class io.r2dbc.proxy.core.Bindings

Get a sorted set of named bindings.

getNullType() - Method in class io.r2dbc.proxy.core.BoundValue.DefaultBoundValue

getNullType() - Method in interface io.r2dbc.proxy.core.BoundValue

Get the bound null type by Statement.bindNull(int, java.lang.Class<?>).

getOrDefault(Object, T) - Method in class io.r2dbc.proxy.core.DefaultValueStore

getOrDefault(Object, T) - Method in interface io.r2dbc.proxy.core.ValueStore

Get the value associated to the key; otherwise returns specified value.

getOriginalConnection() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Retrieve original Connection.

getOriginalConnection() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

getOriginalQuery() - Method in interface io.r2dbc.proxy.core.StatementInfo

Get the sql statement that has originally specified on Connection.createStatement(String).

getOriginalQuery() - Method in class io.r2dbc.proxy.test.MockStatementInfo

getParams() - Method in class io.r2dbc.proxy.observation.QueryContext

getProxyConfig() - Method in interface io.r2dbc.proxy.callback.ProxyConfigHolder

Retrieve ProxyConfig.

getProxyConfig() - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Return the ProxyConfig.

getProxyEventType() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the proxy event type.

getProxyEventType() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the proxy event type for query execution.

getProxyEventType() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getProxyEventType() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getProxyFactory() - Method in class io.r2dbc.proxy.callback.ProxyConfig

Get ProxyFactory which is generated from the specified ProxyFactoryFactory.

getQueries() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the list of QueryInfo.

getQueries() - Method in class io.r2dbc.proxy.observation.QueryContext

getQueries() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getQuery() - Method in class io.r2dbc.proxy.core.QueryInfo

Get the query.

getResult() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the result of invocation.

getResult() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getResultRowConverter() - Method in class io.r2dbc.proxy.callback.ProxyConfig

Get ResultRowConverter.

getRollbackCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Returns how many times Connection.rollbackTransaction() method is called.

getRollbackCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

getStatementInfo() - Method in interface io.r2dbc.proxy.core.BindInfo

Get StatementInfo where bind operation has happened.

getTagValue(List<Bindings>) - Method in class io.r2dbc.proxy.observation.DefaultQueryParametersTagProvider

getTagValue(List<Bindings>) - Method in interface io.r2dbc.proxy.observation.QueryParametersTagProvider

Provide query parameter values.

getTarget() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the invoked object.

getTarget() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getThreadId() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the thread ID.

getThreadId() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the currently executed thread ID.

getThreadId() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getThreadId() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getThreadName() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the thread name.

getThreadName() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the currently executed thread name.

getThreadName() - Method in class io.r2dbc.proxy.observation.QueryContext

getThreadName() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getThreadName() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getThrowable() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the thrown exception.

getThrowable() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getThrown() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Get the thrown exception.

getThrown() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getTransactionCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Returns how many times Connection.beginTransaction() method is called.

getTransactionCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

getType() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Get the type of query execution.

getType() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getUpdatedQuery() - Method in interface io.r2dbc.proxy.core.StatementInfo

Get the updated sql statement by BindParameterConverter.onCreateStatement(String, StatementInfo).

getUpdatedQuery() - Method in class io.r2dbc.proxy.test.MockStatementInfo

getValue() - Method in class io.r2dbc.proxy.core.BoundValue.DefaultBoundValue

getValue() - Method in interface io.r2dbc.proxy.core.BoundValue

Get the bound value by Statement.bind(int, java.lang.Object).

getValueStore() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Retrieve ValueStore which is associated to the scope of logical connection.

getValueStore() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo

Retrieve ValueStore which is associated to the scope of before/after method execution.

getValueStore() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Retrieve ValueStore which is associated to the scope of before/after method execution.

getValueStore() - Method in interface io.r2dbc.proxy.core.StatementInfo

Retrieve ValueStore which is associated to the scope of logical statement.

getValueStore() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

getValueStore() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo

getValueStore() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

getValueStore() - Method in class io.r2dbc.proxy.test.MockStatementInfo

H

hasKey(Object) - Method in class io.r2dbc.proxy.callback.DelegatingContextView

I

incrementCommitCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Increment commit count.

incrementCommitCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

incrementConsumedCount() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext

Increment the count of consumptions from Result#[map|getRowsUpdated].

incrementProducedCount() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext

Increment the count of produced Result from Statement#execute.

incrementRollbackCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Increment rollback count.

incrementRollbackCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

incrementTransactionCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Increment transaction count.

incrementTransactionCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

indexBinding(int, BoundValue) - Static method in class io.r2dbc.proxy.core.Bindings

Factory method to create Bindings.IndexBinding.

indexBindings(BiConsumer<SortedSet<Binding>, StringBuilder>) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Set a consumer for converting SortedSet of Binding constructed by bind-by-index.

invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.BatchCallbackHandler

invoke(Object, Method, Object[]) - Method in interface io.r2dbc.proxy.callback.CallbackHandler

When proxy is invoked, actual implementation of the proxy handler delegates the invocation to this method.

invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.ConnectionCallbackHandler

invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler

invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.ResultCallbackHandler

invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.RowCallbackHandler

invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler

invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.StatementCallbackHandler

io.r2dbc.proxy - package io.r2dbc.proxy

io.r2dbc.proxy.callback - package io.r2dbc.proxy.callback

Proxy related classes

io.r2dbc.proxy.core - package io.r2dbc.proxy.core

Domain classes

io.r2dbc.proxy.listener - package io.r2dbc.proxy.listener

Listener classes

io.r2dbc.proxy.observation - package io.r2dbc.proxy.observation

io.r2dbc.proxy.support - package io.r2dbc.proxy.support

Misc support classes

io.r2dbc.proxy.test - package io.r2dbc.proxy.test

Utility classes for testing

io.r2dbc.proxy.util - package io.r2dbc.proxy.util

Utility code used throughout the project.

isAllConsumed() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext

Whether currently all produced Results are consumed.

isClosed() - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Returns whether connection is closed or not.

isClosed(boolean) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder

isClosed() - Method in class io.r2dbc.proxy.test.MockConnectionInfo

isNull() - Method in class io.r2dbc.proxy.core.BoundValue.DefaultBoundValue

isNull() - Method in interface io.r2dbc.proxy.core.BoundValue

Distinguish between the bound value is for Statement.bind(int, java.lang.Object) or Statement.bindNull(int, java.lang.Class<?>) operation.

isQueryFinished() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext

Whether the executed queries have finished and results are consumed.

isSuccess() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo

Indicate whether the query execution was successful or not.

isSuccess(boolean) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

isSuccess() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo

L

LastExecutionAwareListener - Class in io.r2dbc.proxy.listener

Keep the last invoked execution.

LastExecutionAwareListener() - Constructor for class io.r2dbc.proxy.listener.LastExecutionAwareListener

listener(ProxyExecutionListener) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder

Add a ProxyExecutionListener.

listener(ProxyExecutionListener) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Register a ProxyExecutionListener.

M

markAllProduced() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext

When QueryInvocationSubscriber produced all Result objects.

method(Method) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

method(Method) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

methodArgs(Object[]) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

methodArgs(Object[]) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

MethodExecutionInfo - Interface in io.r2dbc.proxy.core

Hold method execution related information.

MethodExecutionInfoFormatter - Class in io.r2dbc.proxy.support

Convert MethodExecutionInfo to String.

MethodExecutionInfoFormatter() - Constructor for class io.r2dbc.proxy.support.MethodExecutionInfoFormatter

MockConnectionInfo - Class in io.r2dbc.proxy.test

Mock implementation of ConnectionInfo for testing.

MockConnectionInfo.Builder - Class in io.r2dbc.proxy.test

MockMethodExecutionInfo - Class in io.r2dbc.proxy.test

Mock implementation of MethodExecutionInfo for testing.

MockMethodExecutionInfo.Builder - Class in io.r2dbc.proxy.test

MockQueryExecutionInfo - Class in io.r2dbc.proxy.test

Mock implementation of QueryExecutionInfo for testing.

MockQueryExecutionInfo.Builder - Class in io.r2dbc.proxy.test

MockStatementInfo - Class in io.r2dbc.proxy.test

Mock implementation of StatementInfo.

MockStatementInfo.Builder - Class in io.r2dbc.proxy.test

N

namedBinding(String, BoundValue) - Static method in class io.r2dbc.proxy.core.Bindings

Factory method to create Bindings.NamedBinding.

namedBindings(BiConsumer<SortedSet<Binding>, StringBuilder>) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Set a consumer for converting SortedSet of Binding constructed by bind-by-name.

newLine() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Change the line

nullValue(Class<?>) - Static method in interface io.r2dbc.proxy.core.BoundValue

Create a BoundValue that represents Statement.bindNull(int, java.lang.Class<?>).

O

ObservationProxyExecutionListener - Class in io.r2dbc.proxy.observation

Create Micrometer Observations.

ObservationProxyExecutionListener(ObservationRegistry, ConnectionFactory, String) - Constructor for class io.r2dbc.proxy.observation.ObservationProxyExecutionListener

Constructor that takes a connection url.

ObservationProxyExecutionListener(ObservationRegistry, ConnectionFactory, String, Integer) - Constructor for class io.r2dbc.proxy.observation.ObservationProxyExecutionListener

Constructor that takes host and port.

onAfterMethod(Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Register a callback consumer for after method execution.

onAfterQuery(Consumer<QueryExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Register a callback consumer for after query execution.

onBeforeMethod(Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Register a callback consumer for before method execution

onBeforeQuery(Consumer<QueryExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Register a callback consumer for before query execution.

onBind(BindInfo, Statement, BindParameterConverter.BindOperation) - Method in interface io.r2dbc.proxy.listener.BindParameterConverter

Callback method for bind operations(bind and bindNull) on Statement before actually performing those methods.

onBindings - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Default implementation for formatting bindings.

onBoundValue - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Default implementation for formatting bound value.

onBoundValueParameter - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Default implementation for formatting Parameter value.

onBoundValueRaw - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Default implementation for formatting actual value of bound value.

onCreateStatement(String, StatementInfo) - Method in interface io.r2dbc.proxy.listener.BindParameterConverter

Convert the given query to another one at Connection.createStatement(String).

onEachQueryResult(Consumer<QueryExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Register a callback consumer for processing each query result.

onGet(Row, Method, Object[], ResultRowConverter.GetOperation) - Method in interface io.r2dbc.proxy.listener.ResultRowConverter

Callback method for Row#get(...) before performing the original Row#get(...) method.

onIndexBindings - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Default implementation for formatting bindings by index.

onNamedBindings - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Default implementation for formatting bindings by name.

originalConnection(Connection) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder

originalQuery(String) - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder

P

proceed() - Method in interface io.r2dbc.proxy.listener.BindParameterConverter.BindOperation

Perform the bind operation.

proceed() - Method in interface io.r2dbc.proxy.listener.ResultRowConverter.GetOperation

Perform the original Row#get(...) operation.

PROXY_DRIVER - Static variable in class io.r2dbc.proxy.ProxyConnectionFactoryProvider

Driver option value.

PROXY_LISTENERS - Static variable in class io.r2dbc.proxy.ProxyConnectionFactoryProvider

Proxy listener Option.

ProxyConfig - Class in io.r2dbc.proxy.callback

Central configuration object for proxy.

ProxyConfig() - Constructor for class io.r2dbc.proxy.callback.ProxyConfig

proxyConfig(ProxyConfig) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder

Set a ProxyConfig to use.

ProxyConfig.Builder - Class in io.r2dbc.proxy.callback

Builder to create a ProxyConfig.

ProxyConfigHolder - Interface in io.r2dbc.proxy.callback

Provide a method to retrieve ProxyConfig from proxy object.

ProxyConnectionFactory - Class in io.r2dbc.proxy

Entry point to create a proxy for the given ConnectionFactory.

ProxyConnectionFactory.Builder - Class in io.r2dbc.proxy

Builder to create a proxy ConnectionFactory.

ProxyConnectionFactoryProvider - Class in io.r2dbc.proxy

An implementation of ConnectionFactoryProvider for creating proxy ConnectionFactory.

ProxyConnectionFactoryProvider() - Constructor for class io.r2dbc.proxy.ProxyConnectionFactoryProvider

ProxyEventType - Enum in io.r2dbc.proxy.core

Proxy callback event type.

proxyEventType(ProxyEventType) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

proxyEventType(ProxyEventType) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

ProxyExecutionListener - Interface in io.r2dbc.proxy.listener

Listener interface that is called when proxy is invoked.

ProxyFactory - Interface in io.r2dbc.proxy.callback

Defines factory methods to create proxy of SPI classes.

proxyFactoryFactory(ProxyFactoryFactory) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder

Set ProxyFactoryFactory.

ProxyFactoryFactory - Interface in io.r2dbc.proxy.callback

Factory to create a ProxyFactory.

ProxyMethodExecutionListener - Interface in io.r2dbc.proxy.listener

Listener interface called back when corresponding method on proxy is invoked.

ProxyMethodExecutionListenerAdapter - Class in io.r2dbc.proxy.listener

Adapter to make ProxyMethodExecutionListener work as ProxyExecutionListener.

ProxyMethodExecutionListenerAdapter(ProxyMethodExecutionListener) - Constructor for class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter

ProxyUtils - Class in io.r2dbc.proxy.callback

Utility methods to obtain original Connection from proxy class.

put(Object, Object) - Method in class io.r2dbc.proxy.core.DefaultValueStore

put(Object, Object) - Method in interface io.r2dbc.proxy.core.ValueStore

Store a value associating the provided key.

putAll(Map<Object, Object>) - Method in class io.r2dbc.proxy.core.DefaultValueStore

putAll(Map<Object, Object>) - Method in interface io.r2dbc.proxy.core.ValueStore

Store all key value pairs from provided map.

Q

queries(List<QueryInfo>) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

QueriesExecutionContext - Class in io.r2dbc.proxy.callback

The context of queries execution.

QueriesExecutionContext(Clock) - Constructor for class io.r2dbc.proxy.callback.QueriesExecutionContext

QueryContext - Class in io.r2dbc.proxy.observation

Observation.Context for r2dbc query.

QueryContext() - Constructor for class io.r2dbc.proxy.observation.QueryContext

QueryExecutionInfo - Interface in io.r2dbc.proxy.core

Hold query execution related information.

QueryExecutionInfoFormatter - Class in io.r2dbc.proxy.support

Convert QueryExecutionInfo to String.

QueryExecutionInfoFormatter() - Constructor for class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

QueryInfo - Class in io.r2dbc.proxy.core

Hold each query related info.

QueryInfo(String) - Constructor for class io.r2dbc.proxy.core.QueryInfo

Construct the QueryInfo with query.

queryInfo(QueryInfo) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

QueryObservationConvention - Interface in io.r2dbc.proxy.observation

Default ObservationConvention for R2DBC query execution.

QueryParametersTagProvider - Interface in io.r2dbc.proxy.observation

Construct a tag value for query parameters.

R

R2dbcObservationDocumentation - Enum in io.r2dbc.proxy.observation

ObservationConvention for r2dbc operations.

R2dbcProxyException - Exception in io.r2dbc.proxy.core

Generic r2dbc-proxy exception.

R2dbcProxyException() - Constructor for exception io.r2dbc.proxy.core.R2dbcProxyException

Create a new R2dbcProxyException.

R2dbcProxyException(String) - Constructor for exception io.r2dbc.proxy.core.R2dbcProxyException

Create a new R2dbcProxyException.

R2dbcProxyException(String, Throwable) - Constructor for exception io.r2dbc.proxy.core.R2dbcProxyException

Create a new R2dbcProxyException.

remove(Object) - Method in class io.r2dbc.proxy.core.DefaultValueStore

remove(Object) - Method in interface io.r2dbc.proxy.core.ValueStore

Remove the value associated to the provided key.

requireNonNull(T, String) - Static method in class io.r2dbc.proxy.util.Assert

Checks that a specified object reference is not null and throws a customized IllegalArgumentException if it is.

requireType(Object, Class<T>, String) - Static method in class io.r2dbc.proxy.util.Assert

Checks that the specified value is of a specific type.

result(Object) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

ResultCallbackHandler - Class in io.r2dbc.proxy.callback

Proxy callback handler for Result.

ResultCallbackHandler(Result, QueryExecutionInfo, ProxyConfig, QueriesExecutionContext) - Constructor for class io.r2dbc.proxy.callback.ResultCallbackHandler

Callback handler logic for Result.

resultRowConverter(ResultRowConverter) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder

Set ResultRowConverter.

ResultRowConverter - Interface in io.r2dbc.proxy.listener

Callback for Row#get(...) methods.

ResultRowConverter.GetOperation - Interface in io.r2dbc.proxy.listener

Represent Row#get(...) operation.

rollbackCount(int) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder

RowCallbackHandler - Class in io.r2dbc.proxy.callback

Proxy callback handler for Row.

RowCallbackHandler(Row, QueryExecutionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.RowCallbackHandler

Callback handler logic for Row.

RowSegmentCallbackHandler - Class in io.r2dbc.proxy.callback

Proxy callback handler for Result.RowSegment.

RowSegmentCallbackHandler(Result.RowSegment, QueryExecutionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.RowSegmentCallbackHandler

Callback handler logic for Row.

S

setBindParameterConverter(BindParameterConverter) - Method in class io.r2dbc.proxy.callback.ProxyConfig

Set BindParameterConverter.

setClock(Clock) - Method in class io.r2dbc.proxy.callback.ProxyConfig

Set Clock to use to calculate the elapsed time.

setClosed(boolean) - Method in interface io.r2dbc.proxy.core.ConnectionInfo

Set boolean to indicate whether the connection is closed or not.

setClosed(boolean) - Method in class io.r2dbc.proxy.test.MockConnectionInfo

setConnectionIdManager(ConnectionIdManager) - Method in class io.r2dbc.proxy.callback.ProxyConfig

Set ConnectionIdManager.

setConnectionName(String) - Method in class io.r2dbc.proxy.observation.QueryContext

setIncludeParameterValues(boolean) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener

setParams(List<String>) - Method in class io.r2dbc.proxy.observation.QueryContext

setProxyFactoryFactory(ProxyFactoryFactory) - Method in class io.r2dbc.proxy.callback.ProxyConfig

Set ProxyFactoryFactory.

setQueries(List<String>) - Method in class io.r2dbc.proxy.observation.QueryContext

setQueryObservationConvention(QueryObservationConvention) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener

setQueryParametersTagProvider(QueryParametersTagProvider) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener

setResultRowConverter(ResultRowConverter) - Method in class io.r2dbc.proxy.callback.ProxyConfig

Set ResultRowConverter.

setThreadName(String) - Method in class io.r2dbc.proxy.observation.QueryContext

setThrown(Throwable) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

showAll() - Static method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Create a QueryExecutionInfoFormatter which writes out all attributes on QueryExecutionInfo.

showBatchSize() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show batch size with default format.

showBindings() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show bindings with default format.

showBindingsSize() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show binding size with default format.

showConnection() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show connection information with default format.

showQuery() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show query with default format.

showSuccess() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show query success with default format.

showThread() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show thread information with default format.

showTime() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show query execution duration with default format.

showTransaction() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show transaction information with default format.

showType() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter

Show statement type(batch or statement) with default format.

size() - Method in class io.r2dbc.proxy.callback.DelegatingContextView

startStopwatch() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext

Start the stopwatch.

StatementCallbackHandler - Class in io.r2dbc.proxy.callback

Proxy callback handler for Statement.

StatementCallbackHandler(Statement, StatementInfo, ConnectionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.StatementCallbackHandler

StatementInfo - Interface in io.r2dbc.proxy.core

Hold Statement related information.

stream() - Method in class io.r2dbc.proxy.callback.DelegatingContextView

supports(ConnectionFactoryOptions) - Method in class io.r2dbc.proxy.ProxyConnectionFactoryProvider

supportsContext(Observation.Context) - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention

T

target(Object) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

threadId(long) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

threadId(long) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

threadName(String) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

threadName(String) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

throwable(Throwable) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

toString() - Method in class io.r2dbc.proxy.callback.DelegatingContextView

transactionCount(int) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder

type(ExecutionType) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

U

unwrapConnection() - Method in interface io.r2dbc.proxy.callback.ConnectionHolder

Retrieve original Connection.

unwrapConnection(Connection) - Static method in class io.r2dbc.proxy.callback.ProxyUtils

Get original Connection if given Connection has implemented Wrapped.

unwrapConnection(Batch) - Static method in class io.r2dbc.proxy.callback.ProxyUtils

Get original Connection from proxy Batch.

unwrapConnection(Statement) - Static method in class io.r2dbc.proxy.callback.ProxyUtils

Get original Connection from proxy Statement.

unwrapConnection(Result) - Static method in class io.r2dbc.proxy.callback.ProxyUtils

Get original Connection from proxy Result.

updatedQuery(String) - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder

V

value(Object) - Static method in interface io.r2dbc.proxy.core.BoundValue

Create a BoundValue that represents Statement.bind(int, java.lang.Object).

valueOf(String) - Static method in enum io.r2dbc.proxy.core.ExecutionType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.r2dbc.proxy.core.ProxyEventType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.r2dbc.proxy.observation.R2dbcObservationDocumentation

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.r2dbc.proxy.core.ExecutionType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.r2dbc.proxy.core.ProxyEventType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.r2dbc.proxy.observation.R2dbcObservationDocumentation

Returns an array containing the constants of this enum type, in the order they are declared.

ValueStore - Interface in io.r2dbc.proxy.core

Custom value store.

valueStore(ValueStore) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder

valueStore(ValueStore) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder

valueStore(ValueStore) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder

valueStore(ValueStore) - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder

W

withDefault() - Static method in class io.r2dbc.proxy.support.MethodExecutionInfoFormatter

Create a MethodExecutionInfoFormatter with default consumers that format the MethodExecutionInfo.

wrapBatch(Batch, ConnectionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory

Create a proxy Batch.

wrapConnection(Connection, ConnectionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory

Create a proxy Connection.

wrapConnectionFactory(ConnectionFactory) - Method in interface io.r2dbc.proxy.callback.ProxyFactory

Create a proxy ConnectionFactory.

wrapResult(Result, QueryExecutionInfo, QueriesExecutionContext) - Method in interface io.r2dbc.proxy.callback.ProxyFactory

Create a proxy Result.

wrapRow(Row, QueryExecutionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory

Create a proxy Row.

wrapRowSegment(Result.RowSegment, QueryExecutionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory

Create a proxy Result.RowSegment.

wrapStatement(Statement, StatementInfo, ConnectionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory

Create a proxy Statement.

A B C D E F G H I L M N O P Q R S T U V W