| 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.