org.springframework.integration.r2dbc.dsl

Class R2dbc

java.lang.Object

org.springframework.integration.r2dbc.dsl.R2dbc

public final class R2dbc
extends Object

Java DSL Factory class for R2DBC components.

Since:

5.4

Author:

Artem Bilan

Method Summary

Modifier and Type	Method and Description
static R2dbcMessageSourceSpec	inboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, Expression queryExpression) Create an instance of R2dbcMessageSourceSpec for the provided R2dbcEntityOperations and SpEL expression for query.
static R2dbcMessageSourceSpec	inboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, java.util.function.Function<R2dbcMessageSource.SelectCreator,org.springframework.data.r2dbc.core.StatementMapper.SelectSpec> selectFunction) Create an instance of R2dbcMessageSourceSpec for the provided R2dbcEntityOperations and function to create a StatementMapper.SelectSpec instance.
static R2dbcMessageSourceSpec	inboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, String query) Create an instance of R2dbcMessageSourceSpec for the provided R2dbcEntityOperations and query string.
static R2dbcMessageHandlerSpec	outboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations) Create an instance of R2dbcMessageHandlerSpec for the provided R2dbcEntityOperations.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

inboundChannelAdapter

public static R2dbcMessageSourceSpec inboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations,
                                                           String query)

Create an instance of R2dbcMessageSourceSpec for the provided R2dbcEntityOperations and query string.

Parameters:

r2dbcEntityOperations - the R2dbcEntityOperations to use.

query - the query to execute.

Returns:

the spec.

inboundChannelAdapter

public static R2dbcMessageSourceSpec inboundChannelAdapter(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations,
                                                           java.util.function.Function<R2dbcMessageSource.SelectCreator,org.springframework.data.r2dbc.core.StatementMapper.SelectSpec> selectFunction)

Create an instance of R2dbcMessageSourceSpec for the provided R2dbcEntityOperations and function to create a StatementMapper.SelectSpec instance.

Parameters:

r2dbcEntityOperations - the R2dbcEntityOperations 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 of R2dbcMessageSourceSpec for the provided R2dbcEntityOperations and SpEL expression for query.

Parameters:

r2dbcEntityOperations - the R2dbcEntityOperations 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 of R2dbcMessageHandlerSpec for the provided R2dbcEntityOperations.

Parameters:

r2dbcEntityOperations - the R2dbcEntityOperations to use.

Returns:

the spec.