Apache Camel 2.18中IN子句执行SQL删除语句遇问题求助

我之前也遇到过类似的问题，在Camel 2.x版本里处理SQL IN子句的集合参数确实有一些需要注意的地方，尤其是你用的2.18这个稍旧的版本。让我帮你梳理一下问题和解决方案：

问题分析 #

你当前SQL语句里的:#in:idSet语法是错误的——Camel SQL组件并没有in:这个前缀的参数引用规则。在2.18版本中，要绑定集合类型参数到IN子句，直接引用参数名即可，组件会自动识别集合并将其展开为对应的占位符。

解决方案 #

1. 修正SQL参数引用方式 #

把你的路由代码里的SQL语句改成下面这样，去掉多余的in:前缀：

from("direct:deleteRoute")
    .setBody(simple("DELETE FROM TABLE_NAME WHERE ID IN (:#idSet)"))
    .to(Constants.JDBC_DATA_SOURCE)
.end();

这里的:#idSet会直接引用Exchange头中键为idSet的集合对象（Set/List类型都支持），Camel SQL组件会自动把集合展开成多个?占位符。比如你的idSet包含1、2、3，最终生成的SQL会是DELETE FROM TABLE_NAME WHERE ID IN (?, ?, ?)，同时自动绑定对应的参数值，完全避免SQL注入风险。

2. 确保参数类型正确 #

一定要保证你传入的idSet是Java集合类型（比如java.util.HashSet或ArrayList），而不是逗号分隔的字符串。如果你的原始数据是字符串格式，需要先转换成集合，示例代码如下：

// 假设上游传入的是逗号分隔的ID字符串，先转成Set再传入删除路由
from("your-input-route")
    .setHeader("idSet", exchange -> {
        String idsStr = exchange.getIn().getHeader("idStr", String.class);
        return new HashSet<>(Arrays.asList(idsStr.split(",")));
    })
    .to("direct:deleteRoute");

3. 更简洁的SQL DSL写法 #

你也可以直接使用Camel的sql组件端点，省去setBody的步骤，代码会更简洁直观：

from("direct:deleteRoute")
    .to("sql:DELETE FROM TABLE_NAME WHERE ID IN (:#idSet)?dataSource=#" + Constants.JDBC_DATA_SOURCE)
.end();

这里的dataSource=#xxx是引用注册在Camel上下文里的数据源Bean，和你之前的Constants.JDBC_DATA_SOURCE对应即可。

调试建议 #

如果还是遇到问题，可以开启Camel的DEBUG日志，查看org.apache.camel.component.sql.SqlProducer的日志输出——它会打印出生成的SQL语句和绑定的参数值，帮你快速定位问题所在。

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