如何配置这个JdbcMessageHandler来从消息而不是静态bean中提取参数？

Question

症状：

调用时，此子流的组件（JdbcMessageHandler）不是从消息中提取参数，而是试图从静态bean中提取参数。

异常消息：

org.springframework.dao.InvalidDataAccessApiUsageException：没有为SQL参数ALC_startTime提供值：bean类的无效属性ALC_startTime[org.springframework.integration.jdbc.JdbcMessageHandler1美元]：Bean属性ALC_startTime不可读或getter方法无效：getter的返回类型是否与setter的参数类型匹配？

SQL

Delete from SB_STREAM.TT_9321383 
WHERE (LASTUPDATESTAMP >= to_timestamp (:ALC_startTime, 'YYYY-MM-DD HH24:MI:SS.FF') 
    and LASTUPDATESTAMP <= to_timestamp (:ALC_endTime, 'YYYY-MM-DD HH24:MI:SS.FF')) 
AND ttkey = BIGINT(:ID) 
AND (ttobjectname = :ALC_object AND ttschema = :ALC_schema)

流程：

   return flowDef
        .filter(getFilterExpression(rule)).channel(new DirectChannel())
        .handle(inboundAdapter) // a JdbcOutboundAdapter
        .split(insertDeleteSplitter)
        .publishSubscribeChannel(taskExecutor, c -> 
                c.subscribe(s -> s
                    .filter ("....")
                    .transform(genericTransformer)
                    .handle(insertUpdateMessageHandler(rule))) // a JDBCMessageHandler
                .subscribe(s -> s
                    .filter("....")
                    .transform(genericTransformer)
                    .handle(deleteMessageHandler(rule))) // a JDBCMessageHandler
                .subscribe(sub -> sub
                    .handle(cleanupMessageHandler(rule))) // a JDBCMessageHandler
              .errorHandler(new CustomErrorHandler() // 
        );

清理消息处理程序

private MessageHandler cleanupMessageHandler(RuleMetadata rule) {

<snip ...>
    SQLTextAndParamsList sql = sqlFactory.getCleanupSQL(rule);
    JdbcMessageHandler handler = new JdbcMessageHandler(dbprx.getDatasource(), sql.getSql());

    return handler;
}

编辑：代码更改

生成的SQL已更新为：

Delete from SB_STREAM.TT_9321383 
WHERE (LASTUPDATESTAMP >= to_timestamp (:payload[ALC_startTime], 'YYYY-MM-DD HH24:MI:SS.FF') 
    and LASTUPDATESTAMP <= to_timestamp (:payload[ALC_endTime], 'YYYY-MM-DD HH24:MI:SS.FF')) 
AND ttkey = :payload[ID] 
AND (ttobjectname = :payload[ALC_object] AND ttschema = :payload[ALC_schema])

Answer 1

根据您的第一个屏幕截图，消息的有效负载是一个数组列表，它确实没有ALC\u开始时间、ALC\u结束时间属性。数组列表上没有这些getter！

为了能够读取列表的内容，您需要在您的JdbcMessageHandler上配置ExpressionEvalatingSqlParameterSourceFactory。有关更多信息，请参阅文档：https://docs.spring.io/spring-integration/docs/current/reference/html/jdbc.html#passing-parameters-by-using-spel-expressions.

也许最好以某种方式将列表转换为映射或一些POJO表示。有了这个列表，你很难仅仅通过索引来确定目标值。。。

编辑：这是一个批量更新，因此映射的数组列表是正确的。

SQL参数中的SPEl表达式格式不正确。正确的形式是：有效载荷[ALC\U startTime]。