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. |
default void |
ProxyExecutionListener.afterQuery(QueryExecutionInfo execInfo)
Called after executing a query (
Batch.execute() or Statement.execute() ). |
void |
ProxyMethodExecutionListenerAdapter.afterQuery(QueryExecutionInfo execInfo) |
void |
CompositeProxyExecutionListener.afterQuery(QueryExecutionInfo execInfo) |
void |
LastExecutionAwareListener.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. |
default void |
ProxyExecutionListener.beforeQuery(QueryExecutionInfo execInfo)
Called before executing a query (
Batch.execute() or Statement.execute() ). |
void |
ProxyMethodExecutionListenerAdapter.beforeQuery(QueryExecutionInfo execInfo) |
void |
CompositeProxyExecutionListener.beforeQuery(QueryExecutionInfo execInfo) |
void |
LastExecutionAwareListener.beforeQuery(QueryExecutionInfo execInfo) |
default void |
ProxyExecutionListener.eachQueryResult(QueryExecutionInfo execInfo)
Called on processing each query
Result . |
void |
ProxyMethodExecutionListenerAdapter.eachQueryResult(QueryExecutionInfo execInfo) |
void |
CompositeProxyExecutionListener.eachQueryResult(QueryExecutionInfo execInfo) |
void |
LastExecutionAwareListener.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 © 2024. All rights reserved.