Spring Integration-JDBC Inbound Channel-一次性处理一组相互关联的行



在我们的应用程序中,我们必须采用Spring Integration JDBC Inbound Channel来轮询包含客户订单的DB表。我们需要一次性处理单个客户的所有订单。

因此,我们有一个包含order_number、customer_number和一些附加数据的表。我们想要获得一个行集合,其中customer_number与入站通道适配器调用的方法的参数相同。

下面的数据库是Oracle19c。知道如何做到这一点吗?

听起来更像是JdbcOutboundGateway-根据消息负载中提供的参数调用SELECT

查看文档中的更多信息:https://docs.spring.io/spring-integration/docs/current/reference/html/jdbc.html#jdbc-出站网关。

如何启动流已经无关紧要了,但JDBC Inbound Channel Adapter肯定不适合您,因为没有类似于基于请求的选择的东西。您可以通过ExpressionEvaluatingSqlParameterSourceFactory找到一些东西,但它听起来确实像是通过JdbcOutboundGateway的事件驱动方法。

最新更新