apache camel 路由拆分 sql 结果

Question

我想做的是 select 数据库中的所有行，并为每一行更新该行的某些列。下面是我的骆驼路线。

from("direct:insert").
from("sql:select * from my_table").
split(body()).
log("${body[id]}").
end();

我使用下面的代码开始这条路线...

context.createProducerTemplate().sendBody("direct:insert", null);

问题是它发生了多次（即来自 my_table 的所有 id 被打印了大约 18 次！！）。我如何让它只发生一次？

Answer 1

下面的代码对我来说很好..

from("direct:insert").
to("sql:select * from my_table").
split(body()).
log("${body[id]}").
end();

apache camel route to split sql results