如何解决Spring Integration JDBC入站通道适配器的ORA-01795错误

问题根源 #

你遇到的ORA-01795错误是因为Oracle限制IN子句中的表达式最多1000个，而你的JDBC入站适配器默认会把一次轮询查到的所有ID全部放到IN (:id)里，当记录数超过1000时就触发了这个限制。

常用解决方案 #

1. 限制每次轮询的记录数（最简单有效）

Spring Integration的JDBC入站适配器提供了max-rows-per-poll属性，直接设置这个值为1000（或更小），适配器会自动限制每次查询的行数，这样更新时IN列表的元素数就不会超过Oracle的限制。

修改后的配置示例：

<int-jdbc:inbound-channel-adapter query="select id, type, status, location from products where type='ABC' and status != 'P'"
    channel="target" data-source="dataSource"
    update="update item set status='P' where id in (:id)"
    max-rows-per-poll="1000">
   <int-poller fixed-delay="60" time-unit="SECONDS"/>
</int-jdbc:inbound-channel-adapter>

额外建议：在查询语句中加上status != 'P'的条件，避免重复查询已经处理过的记录，提升效率。

2. 用子查询替代IN子句

如果业务需要一次处理超过1000条记录，可以修改更新语句，用子查询关联的方式替代直接的IN列表，这样就不会触发1000个元素的限制。

比如把更新语句改成：

update item set status='P' 
where id in (select id from products where type='ABC' and status != 'P')

但要注意这种方式需要确保查询语句和更新语句的条件完全匹配，否则可能出现重复处理或漏处理的情况。同时，这种方式会把所有符合条件的记录一次性更新，适合不需要把查询结果发送到通道做后续处理的场景。

3. 自定义参数源处理分段批量更新

如果需要更灵活的分段逻辑，可以自定义SqlParameterSourceFactory，把ID列表分成多个1000以内的批次，生成多个更新语句执行。不过这种方式需要编写自定义代码，复杂度较高，适合特殊业务场景。

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