Spring Integration：如何在集成流中正确开启数据库事务？

你遇到的核心问题有两个：一是调用sinkSql后没有生成预期的事务日志，说明事务并未实际触发；二是直接使用e.transactional(true)会因为系统中存在多个事务管理器（源数据库+Sybase）而报错，因为Spring无法自动确定使用哪个默认事务管理器。

解决方案步骤 #

1. 确保JdbcTemplate与事务管理器绑定同一数据源 #

这是最容易被忽略的关键点：如果sinkSql中使用的JdbcTemplate不是绑定到SYBASE_DS的实例，那么即使事务管理器配置正确，事务也不会生效（因为数据源不匹配，事务无法覆盖到数据库操作）。

添加针对Sybase的专属JdbcTemplate配置：

@Bean(name = "sybaseJdbcTemplate")
public JdbcTemplate sybaseJdbcTemplate(@Qualifier(SYBASE_DS) DataSource sybaseDataSource) {
    return new JdbcTemplate(sybaseDataSource);
}

然后在你的业务类中注入这个特定的JdbcTemplate，替代默认的实例：

@Autowired
@Qualifier("sybaseJdbcTemplate")
private JdbcTemplate sybaseJdbcTemplate;

public void sinkSql(final Message<?> message) {
    // 这里使用sybaseJdbcTemplate执行DML逻辑
    sybaseJdbcTemplate.update("INSERT INTO your_table (...) VALUES (...)", ...);
}

2. 简化事务配置（两种可选方式） #

方式一：直接在Integration流中指定事务管理器名称

不需要手动创建TransactionInterceptor，可以直接在handle的配置中指定事务管理器的bean名称，Spring Integration会自动创建符合要求的事务拦截器，这种方式更简洁不易出错：

@Bean
public IntegrationFlow sinkSqlFlow() {
    return IntegrationFlows.from(SYBASE_SINK_SQL)
            .enrichHeaders(h -> h.header(MessageHeaders.ERROR_CHANNEL, SYBASE_ERROR))
            .handle(this::sinkSql, e -> e.transactional(SYBASE_TRAN_MANAGER)
                    .isolation(Isolation.READ_COMMITTED)
                    .propagation(Propagation.REQUIRES_NEW)
                    .readOnly(false))
            .get();
}

方式二：修复自定义TransactionInterceptor的应用（如果坚持使用自定义拦截器）

如果你希望保留自定义的TransactionInterceptor，需要确保它被正确注入并应用：

• 确认sybaseTransactionInterceptor bean已经被正确注入到sinkSqlFlow方法中
• 检查拦截器的传播行为、隔离级别配置是否符合预期（你当前配置的REQUIRES_NEW是合理的，会为每个消息处理创建独立事务，避免和上游事务耦合）

3. 验证日志配置生效 #

确保你的日志配置（比如application.properties）已经正确加载，没有被其他配置覆盖：

logging.level.org.springframework.transaction.interceptor=TRACE
logging.level.org.springframework.transaction.support=DEBUG

4. 测试事务触发 #

完成上述配置后，触发消息进入SYBASE_SINK_SQL通道，执行sinkSql方法时，你应该能看到类似以下的事务日志：

TRACE o.s.t.i.TransactionInterceptor - Getting transaction for [your.package.YourClass.sinkSql]
DEBUG o.s.t.s.AbstractPlatformTransactionManager - Creating new transaction with name [your.package.YourClass.sinkSql]: PROPAGATION_REQUIRES_NEW, ISOLATION_READ_COMMITTED
...
DEBUG o.s.t.s.AbstractPlatformTransactionManager - Initiating transaction commit
TRACE o.s.t.i.TransactionInterceptor - Completing transaction for [your.package.YourClass.sinkSql]

关键注意事项 #

• 事务管理器和JdbcTemplate必须使用同一个数据源，否则事务无法生效
• 当系统中存在多个事务管理器时，必须明确指定要使用的那个（不能依赖默认的@Transactional或transactional(true)）
• REQUIRES_NEW传播行为会为每个消息处理创建独立事务，适合Sink这种需要独立提交的场景，避免和上游事务产生耦合

内容的提问来源于stack exchange，提问作者Thiago Sayão