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

Question

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

我的要求是，根据应用程序运行的模式需要不同的 SELECT(和 UPDATE)。并且模式会在运行时更改。

是否有一种机制可以让我使用 SI 组件实现此目的？

问候，罗布。

Answer 1

不，目前不支持(您可以使用占位符属性设置初始值，但一旦设置就无法更改)。

您可以使用常规 POJO 入站 channel 适配器和 JdbcTemplate 作为解决方法。

欢迎联系open a new Feature Suggestion .

类似

public JdbcPollingChannelAdapter(JdbcOperations jdbcOperations, Supplier<String> selectQuery) {

应该很容易实现。