Spring 集成:JDBC 入站通道适配器
Spring Integration: JDBC inbound channel adapter
我试图使用 JDBC 入站通道适配器,但遇到了一些困惑。
首先,在查询语句中指定 max-rows-per-poll
还是使用 limit
哪个更有效?
其次,为避免重复读数,在处理每个轮询的最后一条消息后,是否仍然运行 poller 而不是 fixed-rate
?我可以使用 update
但在流中有动态更新查询。
我的集成流程有点像 jdbc:inbound-channel-adapter -> http:outbound-channel-adapter -> jdbc:outbound-channel-adapter
(根据 http:outbound-channel-adapter
的响应更新每一行)。它应该处理大量的行。
LIMIT
效率更高。
- 只要您使用
DirectChannel
s(默认值),并且轮询器上没有任务执行器,下一次轮询不会 运行 直到当前轮询完成,无论触发器如何.
我试图使用 JDBC 入站通道适配器,但遇到了一些困惑。
首先,在查询语句中指定 max-rows-per-poll
还是使用 limit
哪个更有效?
其次,为避免重复读数,在处理每个轮询的最后一条消息后,是否仍然运行 poller 而不是 fixed-rate
?我可以使用 update
但在流中有动态更新查询。
我的集成流程有点像 jdbc:inbound-channel-adapter -> http:outbound-channel-adapter -> jdbc:outbound-channel-adapter
(根据 http:outbound-channel-adapter
的响应更新每一行)。它应该处理大量的行。
LIMIT
效率更高。- 只要您使用
DirectChannel
s(默认值),并且轮询器上没有任务执行器,下一次轮询不会 运行 直到当前轮询完成,无论触发器如何.