JPA 支持
Spring Integration 的 JPA (Java Persistence API) 模块提供了用于使用 JPA 执行各种数据库操作的组件。
您需要在项目中包含此依赖
-
Maven
-
Gradle
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-jpa</artifactId>
<version>6.4.4</version>
</dependency>
compile "org.springframework.integration:spring-integration-jpa:6.4.4"
JPA API 必须通过一些特定于供应商的实现来包含,例如 Hibernate ORM 框架。
提供了以下组件
这些组件可以通过向目标数据库发送和接收消息来执行 select
、create
、update
和 delete
操作。
JPA 入站通道适配器允许您使用 JPA 从数据库中轮询和检索 (select
) 数据,而 JPA 出站通道适配器允许您创建、更新和删除实体。
您可以使用 JPA 出站网关将实体持久化到数据库,从而允许您继续流程并执行下游的其他组件。类似地,您可以使用出站网关从数据库中检索实体。
例如,您可以使用出站网关(在其请求通道上接收带有 userId
作为 payload 的 Message
),查询数据库,检索用户实体,并将其向下游传递以进行进一步处理。
认识到这些语义差异,Spring Integration 提供了两个独立的 JPA 出站网关
-
检索出站网关
-
更新出站网关