【发布时间】:2023-11-05 15:01:01
【问题描述】:
我正在尝试创建到我的 Mule 服务器的 SQL 查询入站连接,但我希望查询本身是动态的(这意味着我想添加一个值,例如:SELECT * FROM SOME_TABLE WHERE TimeStamp > SomeDynamicVariable)。
考虑到我想经常轮询数据库,我将如何创建这样的入站连接?
【问题讨论】:
我正在尝试创建到我的 Mule 服务器的 SQL 查询入站连接,但我希望查询本身是动态的(这意味着我想添加一个值,例如:SELECT * FROM SOME_TABLE WHERE TimeStamp > SomeDynamicVariable)。
考虑到我想经常轮询数据库,我将如何创建这样的入站连接?
【问题讨论】:
在 Mule 中,您想要实现的称为“请求”(即使用自定义表达式使用端点),并且不使用入站端点处理。
要实现您的目标,您需要:
使用 Mule 表达式作为时间戳值的全局 JDBC 端点,例如:
<jdbc:query key="myQuery" value="SELECT * FROM SOME_TABLE WHERE TimeStamp > #[payload]"/>
一个Quartz inbound endpoint to generate an event在有效载荷中包含要在查询中使用的时间戳,
D.
【讨论】: