如何让JdbcPollingChannelAdapter执行的更新查询具备事务性？

你不需要依赖Poller构建器，直接通过@Poller注解的advice属性就能给轮询过程加上事务，具体实现步骤如下：

1. 配置事务管理器 #

先确保Spring上下文里存在DataSourceTransactionManager Bean，用来管理数据库事务：

@Bean
public DataSourceTransactionManager transactionManager(DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
}

2. 创建事务通知 #

定义TransactionInterceptor，指定事务的传播规则，保证轮询时的查询和更新操作在同一个事务中执行：

@Bean
public TransactionInterceptor transactionAdvice(DataSourceTransactionManager transactionManager) {
    RuleBasedTransactionAttribute transactionAttribute = new RuleBasedTransactionAttribute();
    // 设置事务传播行为为默认的REQUIRED
    transactionAttribute.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

    NameMatchTransactionAttributeSource attributeSource = new NameMatchTransactionAttributeSource();
    // 匹配所有方法应用该事务规则
    attributeSource.addTransactionalMethod("*", transactionAttribute);

    TransactionInterceptor interceptor = new TransactionInterceptor();
    interceptor.setTransactionManager(transactionManager);
    interceptor.setTransactionAttributeSource(attributeSource);
    return interceptor;
}

3. 给Poller绑定事务通知 #

修改@InboundChannelAdapter上的@Poller注解，通过advice属性引用事务通知Bean，让整个轮询流程（包括查询、更新SQL）被事务包裹：

@Bean
@InboundChannelAdapter(value = "inChannel", poller = @Poller(fixedDelay = "2000", advice = "transactionAdvice"))
public MessageSource<?> pollDbForQuery(DataSource dataSource) {
    JdbcPollingChannelAdapter myAdapter = new JdbcPollingChannelAdapter(dataSource, SQL); 
    myAdapter.setRowMapper(new BeanPropertyRowMapper<>(MyEntity.class)); // 补全行映射逻辑
    myAdapter.setUpdateSql("update your_table set status = 'processed' where id = ?"); // 替换为你的更新SQL
    return myAdapter; // 注意返回实例要和变量名一致
}

关键说明 #

• JdbcPollingChannelAdapter的查询和更新操作都在Poller线程中执行，给Poller添加事务通知后，这两个操作会处于同一个事务上下文，保证原子性——任意一步失败，事务都会回滚。
• 如果需要更细粒度的事务控制，可以调整TransactionAttribute的属性，比如设置只读、指定异常回滚规则等。

另外注意你原代码里的小问题：splitter方法缺少实现逻辑，return adapter应改为return myAdapter，myEnity建议首字母大写为MyEntity，这些细节需要修正。

内容的提问来源于stack exchange，提问作者Gestalt