Spring IntegrationFlow StoredProcPollingChannelAdapter

Question

我们如何传递 StoredProcPollingChannelAdapter 的更新查询来更新获取的行？

@Bean
public MessageSource<Object> fromDatabase() {

    return new StoredProcPollingChannelAdapter(storedProcExecutor());
}

@Bean
public StoredProcExecutor storedProcExecutor() {

    var storedProcExecutor = new StoredProcExecutor(datasource);
    storedProcExecutor.setStoredProcedureName("proc_name");

    return storedProcExecutor;
}

Answer 1

你自己说的 - 存储过程。没有理由在这个组件上有一个单独的简单操作，因为目标存储过程可以在从数据库返回之前为我们做所有事情。

Spring IntegrationFlow StoredProcPollingChannelAdapter

Spring IntegrationFlow StoredProcPollingChannelAdapter

spring-integration