Class R2dbc
java.lang.Object
org.springframework.integration.r2dbc.dsl.R2dbc
Java DSL Factory class for R2DBC components.
- Since:
- 5.4
- Author:
- Artem Bilan
-
Method Summary
Modifier and TypeMethodDescriptionstatic R2dbcMessageSourceSpec
inboundChannelAdapter
(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, String query) Create an instance ofR2dbcMessageSourceSpec
for the providedR2dbcEntityOperations
and query string.static R2dbcMessageSourceSpec
inboundChannelAdapter
(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, Function<R2dbcMessageSource.SelectCreator, org.springframework.data.r2dbc.core.StatementMapper.SelectSpec> selectFunction) Create an instance ofR2dbcMessageSourceSpec
for the providedR2dbcEntityOperations
and function to create aStatementMapper.SelectSpec
instance.static R2dbcMessageSourceSpec
inboundChannelAdapter
(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, Expression queryExpression) Create an instance ofR2dbcMessageSourceSpec
for the providedR2dbcEntityOperations
and SpEL expression for query.static R2dbcMessageHandlerSpec
outboundChannelAdapter
(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations) Create an instance ofR2dbcMessageHandlerSpec
for the providedR2dbcEntityOperations
.
-
Method Details
-
inboundChannelAdapter
public static R2dbcMessageSourceSpec inboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, String query) Create an instance ofR2dbcMessageSourceSpec
for the providedR2dbcEntityOperations
and query string.- Parameters:
r2dbcEntityOperations
- theR2dbcEntityOperations
to use.query
- the query to execute.- Returns:
- the spec.
-
inboundChannelAdapter
public static R2dbcMessageSourceSpec inboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, Function<R2dbcMessageSource.SelectCreator, org.springframework.data.r2dbc.core.StatementMapper.SelectSpec> selectFunction) Create an instance ofR2dbcMessageSourceSpec
for the providedR2dbcEntityOperations
and function to create aStatementMapper.SelectSpec
instance.- Parameters:
r2dbcEntityOperations
- theR2dbcEntityOperations
to use.selectFunction
- the expression to evaluate a query for execution.- Returns:
- the spec.
-
inboundChannelAdapter
public static R2dbcMessageSourceSpec inboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, Expression queryExpression) Create an instance ofR2dbcMessageSourceSpec
for the providedR2dbcEntityOperations
and SpEL expression for query.- Parameters:
r2dbcEntityOperations
- theR2dbcEntityOperations
to use.queryExpression
- the expression to evaluate a query for execution.- Returns:
- the spec.
-
outboundChannelAdapter
public static R2dbcMessageHandlerSpec outboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations) Create an instance ofR2dbcMessageHandlerSpec
for the providedR2dbcEntityOperations
.- Parameters:
r2dbcEntityOperations
- theR2dbcEntityOperations
to use.- Returns:
- the spec.
-