Package | Description |
---|---|
io.r2dbc.proxy | |
io.r2dbc.proxy.listener |
Listener classes
|
io.r2dbc.proxy.support |
Misc support classes
|
io.r2dbc.proxy.test |
Utility classes for testing
|
Modifier and Type | Method and Description |
---|---|
ProxyConnectionFactory.Builder |
ProxyConnectionFactory.Builder.onAfterMethod(Consumer<MethodExecutionInfo> consumer)
Register a callback consumer for after method execution.
|
ProxyConnectionFactory.Builder |
ProxyConnectionFactory.Builder.onBeforeMethod(Consumer<MethodExecutionInfo> consumer)
Register a callback consumer for before method execution
|
Modifier and Type | Method and Description |
---|---|
MethodExecutionInfo |
LastExecutionAwareListener.getAfterMethodExecutionInfo()
Get the last used
MethodExecutionInfo in ProxyExecutionListener.afterMethod(MethodExecutionInfo) . |
MethodExecutionInfo |
LastExecutionAwareListener.getBeforeMethodExecutionInfo()
Get the last used
MethodExecutionInfo in ProxyExecutionListener.beforeMethod(MethodExecutionInfo) . |
Modifier and Type | Method and Description |
---|---|
default void |
ProxyMethodExecutionListener.afterAddOnBatch(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Batch.add(String) is called. |
default void |
ProxyMethodExecutionListener.afterAddOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Statement.add() is called. |
default void |
ProxyMethodExecutionListener.afterBeginTransactionOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.beginTransaction() is called. |
default void |
ProxyMethodExecutionListener.afterBindNullOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Statement.bindNull(int, Class) or Statement.bindNull(String, Class) are called. |
default void |
ProxyMethodExecutionListener.afterBindOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Statement.bind(int, Object) or Statement.bind(String, Object) are called. |
default void |
ProxyMethodExecutionListener.afterCloseOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.close() is called. |
default void |
ProxyMethodExecutionListener.afterCommitTransactionOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.commitTransaction() is called. |
default void |
ProxyMethodExecutionListener.afterCreateBatchOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.createBatch() is called. |
default void |
ProxyMethodExecutionListener.afterCreateOnConnectionFactory(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
ConnectionFactory.create() is called. |
default void |
ProxyMethodExecutionListener.afterCreateSavepointOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.createSavepoint(String) is called. |
default void |
ProxyMethodExecutionListener.afterCreateStatementOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.createStatement(String) is called. |
default void |
ProxyMethodExecutionListener.afterExecuteOnBatch(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Batch.execute() is called. |
default void |
ProxyMethodExecutionListener.afterExecuteOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Statement.execute() is called. |
default void |
ProxyMethodExecutionListener.afterFetchSizeOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Statement.fetchSize(int) is called. |
default void |
ProxyMethodExecutionListener.afterFilterOnResult(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Result.filter(Predicate) is called. |
default void |
ProxyMethodExecutionListener.afterFlatMapOnResult(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Result.flatMap(Function) is called. |
default void |
ProxyMethodExecutionListener.afterGetMetadataOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.getMetadata() is called. |
default void |
ProxyMethodExecutionListener.afterGetMetadataOnConnectionFactory(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
ConnectionFactory.getMetadata() is called. |
default void |
ProxyMethodExecutionListener.afterGetMetadataOnRow(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Row#getMetadata(...) is called. |
default void |
ProxyMethodExecutionListener.afterGetOnRow(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Row#get(...) is called. |
default void |
ProxyMethodExecutionListener.afterGetRowsUpdatedOnResult(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Result.getRowsUpdated() is called. |
default void |
ProxyMethodExecutionListener.afterGetTransactionIsolationLevelOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.getTransactionIsolationLevel() is called. |
default void |
ProxyMethodExecutionListener.afterIsAutoCommitOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.isAutoCommit() is called. |
default void |
ProxyMethodExecutionListener.afterMapOnResult(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Result.map(BiFunction) or Result.map(Function) is called. |
default void |
ProxyExecutionListener.afterMethod(MethodExecutionInfo executionInfo)
Called after every invocation of methods.
|
void |
ProxyMethodExecutionListenerAdapter.afterMethod(MethodExecutionInfo executionInfo) |
void |
CompositeProxyExecutionListener.afterMethod(MethodExecutionInfo executionInfo) |
void |
LastExecutionAwareListener.afterMethod(MethodExecutionInfo executionInfo) |
default void |
ProxyMethodExecutionListener.afterReleaseSavepointOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.releaseSavepoint(String) is called. |
default void |
ProxyMethodExecutionListener.afterReturnGeneratedValuesOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Statement.returnGeneratedValues(String...) is called. |
default void |
ProxyMethodExecutionListener.afterRollbackTransactionOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.rollbackTransaction() is called. |
default void |
ProxyMethodExecutionListener.afterRollbackTransactionToSavepointOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.rollbackTransactionToSavepoint(String) is called. |
default void |
ProxyMethodExecutionListener.afterSetAutoCommitOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.setAutoCommit(boolean) is called. |
default void |
ProxyMethodExecutionListener.afterSetLockWaitTimeoutOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.setLockWaitTimeout(Duration) is called. |
default void |
ProxyMethodExecutionListener.afterSetStatementTimeoutOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.setStatementTimeout(Duration) is called. |
default void |
ProxyMethodExecutionListener.afterSetTransactionIsolationLevelOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.setTransactionIsolationLevel(IsolationLevel) is called. |
default void |
ProxyMethodExecutionListener.afterValidateOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked after
Connection.validate(ValidationDepth) is called. |
default void |
ProxyMethodExecutionListener.beforeAddOnBatch(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Batch.add(String) is called. |
default void |
ProxyMethodExecutionListener.beforeAddOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Statement.add() is called. |
default void |
ProxyMethodExecutionListener.beforeBeginTransactionOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.beginTransaction() is called. |
default void |
ProxyMethodExecutionListener.beforeBindNullOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Statement.bindNull(int, Class) or Statement.bindNull(String, Class) are called. |
default void |
ProxyMethodExecutionListener.beforeBindOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Statement.bind(int, Object) or Statement.bind(String, Object) are called. |
default void |
ProxyMethodExecutionListener.beforeCloseOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.close() is called. |
default void |
ProxyMethodExecutionListener.beforeCommitTransactionOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.commitTransaction() is called. |
default void |
ProxyMethodExecutionListener.beforeCreateBatchOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.createBatch() is called. |
default void |
ProxyMethodExecutionListener.beforeCreateOnConnectionFactory(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
ConnectionFactory.create() is called. |
default void |
ProxyMethodExecutionListener.beforeCreateSavepointOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.createSavepoint(String) is called. |
default void |
ProxyMethodExecutionListener.beforeCreateStatementOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.createStatement(String) is called. |
default void |
ProxyMethodExecutionListener.beforeExecuteOnBatch(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Batch.execute() is called. |
default void |
ProxyMethodExecutionListener.beforeExecuteOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Statement.execute() is called. |
default void |
ProxyMethodExecutionListener.beforeFetchSizeOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Statement.fetchSize(int) is called. |
default void |
ProxyMethodExecutionListener.beforeFilterOnResult(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Result.filter(Predicate) is called. |
default void |
ProxyMethodExecutionListener.beforeFlatMapOnResult(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Result.flatMap(Function) is called. |
default void |
ProxyMethodExecutionListener.beforeGetMetadataOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.getMetadata() is called. |
default void |
ProxyMethodExecutionListener.beforeGetMetadataOnConnectionFactory(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
ConnectionFactory.getMetadata() is called. |
default void |
ProxyMethodExecutionListener.beforeGetMetadataOnRow(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Row#getMetadata(...) is called. |
default void |
ProxyMethodExecutionListener.beforeGetOnRow(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Row#get(...) is called. |
default void |
ProxyMethodExecutionListener.beforeGetRowsUpdatedOnResult(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Result.getRowsUpdated() is called. |
default void |
ProxyMethodExecutionListener.beforeGetTransactionIsolationLevelOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.getTransactionIsolationLevel() is called. |
default void |
ProxyMethodExecutionListener.beforeIsAutoCommitOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.isAutoCommit() is called. |
default void |
ProxyMethodExecutionListener.beforeMapOnResult(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Result.map(BiFunction) or Result.map(Function) is called. |
default void |
ProxyExecutionListener.beforeMethod(MethodExecutionInfo executionInfo)
Called before every invocation of methods.
|
void |
ProxyMethodExecutionListenerAdapter.beforeMethod(MethodExecutionInfo executionInfo) |
void |
CompositeProxyExecutionListener.beforeMethod(MethodExecutionInfo executionInfo) |
void |
LastExecutionAwareListener.beforeMethod(MethodExecutionInfo executionInfo) |
default void |
ProxyMethodExecutionListener.beforeReleaseSavepointOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.releaseSavepoint(String) is called. |
default void |
ProxyMethodExecutionListener.beforeReturnGeneratedValuesOnStatement(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Statement.returnGeneratedValues(String...) is called. |
default void |
ProxyMethodExecutionListener.beforeRollbackTransactionOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.rollbackTransaction() is called. |
default void |
ProxyMethodExecutionListener.beforeRollbackTransactionToSavepointOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.rollbackTransactionToSavepoint(String) is called. |
default void |
ProxyMethodExecutionListener.beforeSetAutoCommitOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.setAutoCommit(boolean) is called. |
default void |
ProxyMethodExecutionListener.beforeSetLockWaitTimeoutOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.setLockWaitTimeout(Duration) is called. |
default void |
ProxyMethodExecutionListener.beforeSetStatementTimeoutOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.setStatementTimeout(Duration) is called. |
default void |
ProxyMethodExecutionListener.beforeSetTransactionIsolationLevelOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.setTransactionIsolationLevel(IsolationLevel) is called. |
default void |
ProxyMethodExecutionListener.beforeValidateOnConnection(MethodExecutionInfo methodExecutionInfo)
Callback that is invoked before
Connection.validate(ValidationDepth) is called. |
Modifier and Type | Method and Description |
---|---|
String |
MethodExecutionInfoFormatter.apply(MethodExecutionInfo executionInfo) |
String |
MethodExecutionInfoFormatter.format(MethodExecutionInfo executionInfo)
Convert the given
MethodExecutionInfo to String using registered consumers. |
Modifier and Type | Method and Description |
---|---|
MethodExecutionInfoFormatter |
MethodExecutionInfoFormatter.addConsumer(BiConsumer<MethodExecutionInfo,StringBuilder> consumer)
Register a consumer that converts
MethodExecutionInfo to a String . |
Modifier and Type | Class and Description |
---|---|
class |
MockMethodExecutionInfo
Mock implementation of
MethodExecutionInfo for testing. |
Copyright © 2024. All rights reserved.