JPA サポート

Spring Integration の JPA(Java Persistence API)モジュールは、JPA を使用してさまざまなデータベース操作を実行するためのコンポーネントを提供します。

この依存関係をプロジェクトに含める必要があります。

<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-jpa</artifactId>
    <version>6.3.1</version>
</dependency>
compile "org.springframework.integration:spring-integration-jpa:6.3.1"

JPA API は、ベンダー固有の実装を介して含める必要があります。Hibernate ORM フレームワーク。

次のコンポーネントが提供されます。

これらのコンポーネントを使用して、ターゲットデータベースとメッセージを送受信することにより、ターゲットデータベースで selectcreateupdatedelete 操作を実行できます。

JPA 受信チャネルアダプターでは、JPA を使用してデータベースからデータをポーリングおよび取得(select)できますが、JPA 送信チャネルアダプターではエンティティを作成、更新、削除できます。

JPA の送信ゲートウェイを使用して、エンティティをデータベースに保持し、フローを継続し、ダウンストリームでさらにコンポーネントを実行できます。同様に、送信ゲートウェイを使用して、データベースからエンティティを取得できます。

例: 送信ゲートウェイを使用して、userId を含む Message をリクエストチャネルでペイロードとして受信し、データベースを照会してユーザーエンティティを取得し、さらに処理するためにダウンストリームに渡すことができます。

これらのセマンティックの違いを認識して、Spring Integration は 2 つの別個の JPA 送信ゲートウェイを提供します。

  • 送信ゲートウェイの取得

  • 送信ゲートウェイの更新