Spring Integration 的 JPA(Java 持久性 API)模块提供了使用 JPA 执行各种数据库操作的组件。
您需要将此依赖项包含在项目中:
-
Maven
-
Gradle
<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 框架。
提供以下组件:
这些组件可用于通过向目标数据库发送和接收消息来对目标数据库执行、、 和操作。select
create
update
delete
JPA 入站通道适配器允许您使用 JPA 轮询和检索数据库中的 () 数据,而 JPA 出站通道适配器允许您创建、更新和删除实体。select
您可以使用 JPA 的出站网关将实体持久化到数据库中,从而继续流并在下游执行其他组件。 同样,您可以使用出站网关从数据库中检索实体。
例如,您可以使用出站网关(在其请求通道上接收带有 a 作为有效负载的网关)来查询数据库、检索用户实体并将其传递到下游进行进一步处理。Message
userId
认识到这些语义差异,Spring Integration 提供了两个单独的 JPA 出站网关:
-
检索出站网关
-
更新出站网关