Spring Integration：如何将数组作为单个有效负载发送到 jdbc：出站网关

Question

如何将数组作为单个有效负载发送到 jdbc：Spring Integration 的出站网关？ 我正在构造一个字符串数组并将其发送到接口方法。然而，SQL 接受一个参数 ":payload"，但它会因 UncategorizedSQLException 而失败。

出站网关的Sql查询如下

<int-jdbc:outbound-gateway data-source="dataSource"   request-channel="requestChannel" 
                           query="select XMLMSG from Table where SEQ_ID in (:payload)"                                
                           reply-channel="replyChannel" > 

</int-jdbc:outbound-gateway>

serviceinterface.findBySequenceIds(sequenceIdStringArray);

Answer 1

实际上对于substituteNamedParameters，对于IN 子句，参数必须是Collection 而不是array。 NamedParameterJdbcTemplate.substituteNamedParameters的源码：

if (value instanceof Collection) {
    Iterator<?> entryIter = ((Collection<?>) value).iterator();
    int k = 0;
        while (entryIter.hasNext()) {
    if (k > 0) {
        actualSql.append(", ");
        }

......
      actualSql.append("?");

所以，只需从您的字符串构造List，而不是array：

Arrays.asList("foo", "bar", "baz");

而你真正的查询将是：

select XMLMSG from Table where SEQ_ID in (?, ?, ?)

JdbcTemplate 将为您完成的其他工作。

更新

注意，默认情况下<int-jdbc:outbound-gateway/> 只选择一条记录。要摆脱此限制，请指定 max-rows-per-poll="0"。