stored-procedures - 如何将输入参数值动态更改为存储过程入站 channel 适配器

Question

我需要调用一个在特定窗口期间收集数据的存储过程。例如，我发送一个代表现在的时间戳和一个 15 分钟的窗口，它将返回最近 15 分钟内的所有数据。每次调用此过程时，我都需要更新表示现在的时间戳，以避免使用旧数据。

有什么办法可以实现吗？

我对下面的“now”bean 的尝试失败了，因为即使该 bean 是原型(prototype)，它的值也只会在创建 channel 适配器时检索一次。

我目前配置的匿名 stored-proc-inbound-channel-adapter 如下:

<int-jdbc:stored-proc-inbound-channel-adapter
    channel="storedProcOutboundChannel" stored-procedure-name="dataWindowRetrieval"
    data-source="dataSource" auto-startup="true" id=""
    ignore-column-meta-data="false" is-function="false"
    skip-undeclared-results="true" return-value-required="false">

    <int:poller fixed-rate="60" time-unit="SECONDS"></int:poller>
    <int-jdbc:parameter name="CurrentDateTime" type="java.sql.Timestamp" value="#{now}" />
    <int-jdbc:parameter name="MinuteOffset" type="java.lang.Integer" value="3" />
    <int-jdbc:parameter name="SomeOtherParameter" type="java.lang.Integer" value="4" />
    <int-jdbc:parameter name="YetAnotherParameter" type="java.lang.Integer" value="15" />
    <int-jdbc:returning-resultset name="theResults" row-mapper="org.springframework.jdbc.core.ColumnMapRowMapper" />
</int-jdbc:stored-proc-inbound-channel-adapter>

<bean id="now" scope="prototype" class="java.sql.Timestamp">
    <constructor-arg value="#{ T(java.lang.System).currentTimeMillis()}" />
</bean>

Answer 1

使用 expression="@now" 代替 value。

该值仅在初始化时计算。