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 Details

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