| Package | Description |
|---|---|
| io.r2dbc.proxy | |
| io.r2dbc.proxy.callback |
Proxy related classes
|
| io.r2dbc.proxy.listener |
Listener classes
|
| io.r2dbc.proxy.observation | |
| 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.onAfterQuery(Consumer<QueryExecutionInfo> consumer)
Register a callback consumer for after query execution.
|
ProxyConnectionFactory.Builder |
ProxyConnectionFactory.Builder.onBeforeQuery(Consumer<QueryExecutionInfo> consumer)
Register a callback consumer for before query execution.
|
ProxyConnectionFactory.Builder |
ProxyConnectionFactory.Builder.onEachQueryResult(Consumer<QueryExecutionInfo> consumer)
Register a callback consumer for processing each query result.
|
| Modifier and Type | Method and Description |
|---|---|
io.r2dbc.spi.Result |
ProxyFactory.wrapResult(io.r2dbc.spi.Result result,
QueryExecutionInfo executionInfo,
QueriesExecutionContext queriesExecutionContext)
Create a proxy
Result. |
io.r2dbc.spi.Row |
ProxyFactory.wrapRow(io.r2dbc.spi.Row row,
QueryExecutionInfo executionInfo)
Create a proxy
Row. |
io.r2dbc.spi.Result.RowSegment |
ProxyFactory.wrapRowSegment(io.r2dbc.spi.Result.RowSegment rowSegment,
QueryExecutionInfo executionInfo)
Create a proxy
Result.RowSegment. |
| Constructor and Description |
|---|
ResultCallbackHandler(io.r2dbc.spi.Result result,
QueryExecutionInfo queryExecutionInfo,
ProxyConfig proxyConfig,
QueriesExecutionContext queriesExecutionContext)
Callback handler logic for
Result. |
RowCallbackHandler(io.r2dbc.spi.Row row,
QueryExecutionInfo queryExecutionInfo,
ProxyConfig proxyConfig)
Callback handler logic for
Row. |
RowSegmentCallbackHandler(io.r2dbc.spi.Result.RowSegment rowSegment,
QueryExecutionInfo queryExecutionInfo,
ProxyConfig proxyConfig)
Callback handler logic for
Row. |
| Modifier and Type | Method and Description |
|---|---|
QueryExecutionInfo |
LastExecutionAwareListener.getAfterQueryExecutionInfo()
Get the last used
QueryExecutionInfo in ProxyExecutionListener.afterQuery(QueryExecutionInfo). |
QueryExecutionInfo |
LastExecutionAwareListener.getBeforeQueryExecutionInfo()
Get the last used
QueryExecutionInfo in ProxyExecutionListener.beforeQuery(QueryExecutionInfo). |
QueryExecutionInfo |
LastExecutionAwareListener.getEachQueryResultExecutionInfo()
Get the last used
QueryExecutionInfo in ProxyExecutionListener.eachQueryResult(QueryExecutionInfo). |
| Modifier and Type | Method and Description |
|---|---|
default void |
ProxyMethodExecutionListener.afterExecuteOnBatch(QueryExecutionInfo queryExecutionInfo)
Query execution callback that is invoked after
Batch.execute() is called. |
default void |
ProxyMethodExecutionListener.afterExecuteOnStatement(QueryExecutionInfo queryExecutionInfo)
Query execution callback that is invoked after
Statement.execute() is called. |
void |
CompositeProxyExecutionListener.afterQuery(QueryExecutionInfo execInfo) |
void |
LastExecutionAwareListener.afterQuery(QueryExecutionInfo execInfo) |
default void |
ProxyExecutionListener.afterQuery(QueryExecutionInfo execInfo)
Called after executing a query (
Batch.execute() or Statement.execute()). |
void |
ProxyMethodExecutionListenerAdapter.afterQuery(QueryExecutionInfo execInfo) |
default void |
ProxyMethodExecutionListener.beforeExecuteOnBatch(QueryExecutionInfo queryExecutionInfo)
Query execution callback that is invoked before
Batch.execute() is called. |
default void |
ProxyMethodExecutionListener.beforeExecuteOnStatement(QueryExecutionInfo queryExecutionInfo)
Query execution callback that is invoked before
Statement.execute() is called. |
void |
CompositeProxyExecutionListener.beforeQuery(QueryExecutionInfo execInfo) |
void |
LastExecutionAwareListener.beforeQuery(QueryExecutionInfo execInfo) |
default void |
ProxyExecutionListener.beforeQuery(QueryExecutionInfo execInfo)
Called before executing a query (
Batch.execute() or Statement.execute()). |
void |
ProxyMethodExecutionListenerAdapter.beforeQuery(QueryExecutionInfo execInfo) |
void |
CompositeProxyExecutionListener.eachQueryResult(QueryExecutionInfo execInfo) |
void |
LastExecutionAwareListener.eachQueryResult(QueryExecutionInfo execInfo) |
default void |
ProxyExecutionListener.eachQueryResult(QueryExecutionInfo execInfo)
Called on processing each query
Result. |
void |
ProxyMethodExecutionListenerAdapter.eachQueryResult(QueryExecutionInfo execInfo) |
| Modifier and Type | Method and Description |
|---|---|
void |
ObservationProxyExecutionListener.afterQuery(QueryExecutionInfo executionInfo) |
void |
ObservationProxyExecutionListener.beforeQuery(QueryExecutionInfo executionInfo) |
void |
ObservationProxyExecutionListener.eachQueryResult(QueryExecutionInfo executionInfo) |
| Modifier and Type | Field and Description |
|---|---|
BiConsumer<QueryExecutionInfo,StringBuilder> |
QueryExecutionInfoFormatter.onBindings
Default implementation for formatting bindings.
|
| Modifier and Type | Method and Description |
|---|---|
String |
QueryExecutionInfoFormatter.apply(QueryExecutionInfo executionInfo) |
String |
QueryExecutionInfoFormatter.format(QueryExecutionInfo executionInfo)
Convert the given
QueryExecutionInfo to String using registered consumers. |
| Modifier and Type | Method and Description |
|---|---|
QueryExecutionInfoFormatter |
QueryExecutionInfoFormatter.addConsumer(BiConsumer<QueryExecutionInfo,StringBuilder> consumer)
|
| Modifier and Type | Class and Description |
|---|---|
class |
MockQueryExecutionInfo
Mock implementation of
QueryExecutionInfo for testing. |
Copyright © 2025. All rights reserved.