mysql - apache camel 路由拆分 sql 结果

Question

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

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();