动态查询作为 MULE 的入站连接
我正在尝试创建一个到 Mule 服务器的 SQL 查询入站连接,但我希望查询本身是动态的(这意味着我想添加一个值,例如:SELECT * FROM SOME_TABLE WHERE TimeStamp > SomeDynamicVariable
)。
考虑到我想经常轮询数据库,我将如何创建这样的入站连接?
I am trying to create an SQL query inbound connection to my Mule server but I want the query itself to be dynamic (meaning I want to add a value such as: SELECT * FROM SOME_TABLE WHERE TimeStamp > SomeDynamicVariable
).
How would I go about creating such an inbound connection, considering that I want to poll the database every so often?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
在 Mule 中,您想要实现的目标称为“请求”(即使用自定义表达式使用端点),并且不使用入站端点进行处理。
为了实现您的目标,您需要:
使用 Mule 表达式作为时间戳值的全局 JDBC 端点,例如如下所示:
A Quartz 入站端点生成事件,负载中包含要在查询中使用的时间戳,
D .
In Mule, what you want to achieve is called "requesting" (ie. consuming an endpoint with a custom expression) and is not handled with inbound endpoints.
To achieve your goal you need:
A global JDBC endpoint using a Mule expression for the timestamp value, for example like this:
A Quartz inbound endpoint to generate an event containing in the payload the timestamp to be used in query,
D.