动态查询作为 MULE 的入站连接

发布于 2024-12-11 12:12:22 字数 184 浏览 0 评论 0原文

我正在尝试创建一个到 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 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

燕归巢 2024-12-18 12:12:22

在 Mule 中,您想要实现的目标称为“请求”(即使用自定义表达式使用端点),并且不使用入站端点进行处理。

为了实现您的目标,您需要:

  • 使用 Mule 表达式作为时间戳值的全局 JDBC 端点,例如如下所示:

    
    
  • A Quartz 入站端点生成事件,负载中包含要在查询中使用的时间戳,

  • A 消息丰富器从端点请求并在当前负载中设置结果值(target = #[payload])。

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:

    <jdbc:query key="myQuery" value="SELECT * FROM SOME_TABLE WHERE TimeStamp > #[payload]"/>
    
  • A Quartz inbound endpoint to generate an event containing in the payload the timestamp to be used in query,

  • A message enricher to request from the endpoint and set the resulting value in the current payload (target = #[payload]).

D.

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文