Spring集成：使用adice-chain时Jdbc-inbound-adapter是事务性的

Question

我的 jdbc-inbound-adapter 有以下配置：

    <si-jdbc:inbound-channel-adapter id="jdbcInboundAdapter"
    channel="queueChannel" data-source="myDataSource"
    auto-startup="true"
    query="SELECT * FROM STAGE_TABLE WHERE STATUS='WAITING'  FOR UPDATE SKIP LOCKED"
    update="UPDATE STAGE_TABLE SET STATUS='IN_PROGRESS' WHERE ID IN (:Id)"
    max-rows-per-poll="100" row-mapper="rowMapper"
    update-per-row="true">

    <si:poller fixed-rate="5000">
        <si:advice-chain> 
            <ref bean="txAdvice"/> 
            <ref bean="inboundAdapterConfiguration"/> 
        </si:advice-chain>
    </si:poller>
</si-jdbc:inbound-channel-adapter>
    <tx:advice id="txAdvice">
        <tx:attributes>
            <tx:method name="get*" read-only="false"/>
            <tx:method name="*"/>
        </tx:attributes>
    </tx:advice>

我的问题是 select 和 update 语句是否会在同一个事务中执行。

在 spring-integration 文档中，它没有明确指定使用建议链时的交易。 （我使用的是spring-integration-jdbc-2.2.0.RC2.jar） 请参阅第 18.1.1 节轮询事务支持： http://docs.spring.io/spring-integration/docs/2.0.0.RC1/reference/html/transactions.html

Answer 1

您正在使用一个非常旧的版本（当时只是一个候选版本，而不是 GA 版本。当前版本是 3.0.2.RELEASE，最新的 2.2.x 是 2.2.6.RELEASE。请升级到其中一个。

http://projects.spring.io/spring-integration/

是的，这一切都在同一个事务中完成。

你指的是旧文档吗？ current documentation 说

“用于 JDBC 的轮询器的一个非常重要的特性是将轮询操作包装在事务中的选项，..”。

事务启动，消息源被调用（获取结果），下游流程全部发生在事务中（除非你切换到另一个线程，在这种情况下事务将在那个时候提交）。

实际上，更新是在选择之后（并且在发送消息之前）完成的，但是直到下游流程完成后才会发生提交。

您的频道名为queueChannel；如果它真的是一个队列通道，这意味着一旦消息存储在队列中，事务就会提交。

如果您认为需要改进文档，请打开JIRA Issue。