パッケージ org.springframework.integration.r2dbc.outbound

クラス R2dbcMessageHandler

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractReactiveMessageHandler
org.springframework.integration.r2dbc.outbound.R2dbcMessageHandler
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Ordered、ExpressionCapable、Orderable、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、ReactiveMessageHandler
public class R2dbcMessageHandler extends AbstractReactiveMessageHandler
リアクティブ r2dbc サポートを使用して、メッセージペイロードをリレーショナルデータベースに書き込む ReactiveMessageHandler の実装。
導入:
5.4
作成者:
Rohan Mukesh, Artem Bilan

  • コンストラクターの詳細

    • R2dbcMessageHandler

      public R2dbcMessageHandler(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)
      提供された R2dbcEntityOperations の完全に作成および初期化されたインスタンスを使用して、このインスタンスを構築します。
      パラメーター:
      r2dbcEntityOperations - R2dbcEntityOperations 実装。

  • メソッドの詳細

    • setQueryType

      public void setQueryType(R2dbcMessageHandler.Type type)
      クエリを実行するための R2dbcMessageHandler.Type を設定します。
      パラメーター:
      type - 使用する R2dbcMessageHandler.Type。

    • setQueryTypeExpression

      public void setQueryTypeExpression(Expression queryTypeExpression)
      SpEL 式を設定して、クエリを実行するための R2dbcMessageHandler.Type を評価します。
      パラメーター:
      queryTypeExpression - 使用する式。

    • setTableName

      public void setTableName(StringSE tableName)
      クエリを実行するターゲットデータベースのテーブルを指定します。
      パラメーター:
      tableName - 使用するテーブルの名前。

    • setTableNameExpression

      public void setTableNameExpression(Expression tableNameExpression)
      SpEL 式を設定して、実行時にリクエストメッセージに対してテーブル名を評価します。
      パラメーター:
      tableNameExpression - 使用する式。

    • setValuesExpression

      public void setValuesExpression(Expression valuesExpression)
      SpEL 式を設定して、名前と値のペアの MapSE を評価し、パラメーターとしてクエリにバインドします。
      パラメーター:
      valuesExpression - 使用する式。

    • setCriteriaExpression

      public void setCriteriaExpression(Expression criteriaExpression)
      SpEL 式を設定して、クエリを実行するための Criteria を評価します。
      パラメーター:
      criteriaExpression - 使用する式。

    • getComponentType

      public StringSE getComponentType()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
      次で指定:
      インターフェース NamedComponent の getComponentType 
      オーバーライド:
      クラス MessageHandlerSupport の getComponentType 

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス IntegrationObjectSupport の onInit 

    • handleMessageInternal

      protected reactor.core.publisher.Mono<VoidSE> handleMessageInternal(Message<?> message)
      次で指定:
      クラス AbstractReactiveMessageHandler の handleMessageInternal