Spring 集成 JdbcPollingChannelAdapter 与可配置的选择和更新 SQL

Question

Spring Integration JdbcPollingChannelAdapter jdbc:inbound-channel-adapter 允许您使用 SqlParameterSource 更改 selectQuery WHERE 子句中的值。但是没有任何机制可以更改实际的 SQL。适配器的构造函数采用无法覆盖或更新的 selectQuery:String。

我的要求是，根据应用程序运行的模式需要不同的 SELECT（和 UPDATE）。并且模式将在运行时改变。

是否有一种机制可以让我通过 SI 组件实现这一目标？

问候，罗布。

Answer 1

不，目前不支持（您可以使用占位符属性设置初始值，但一旦设置就无法更改）。您可以使用常规 POJO 入站通道适配器作为JdbcTemplate解决方法。就像是public JdbcPollingChannelAdapter(JdbcOperations jdbcOperations, Supplier<String> selectQuery) {应该很容易实施。