我想做的是从数据库中选择所有行,并为每一行更新该行的某些列。下面是我的 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 次!!)。我如何让它只发生一次?
最佳答案
下面的代码对我来说很好..
from("direct:insert").
to("sql:select * from my_table").
split(body()).
log("${body[id]}").
end();
关于mysql - apache camel 路由拆分 sql 结果,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30571571/