有没有办法使用 Spring Integration 的 jdbc:oubound-channel-adapter 编写 BLOB？

Question

我收到带有字符串有效负载的传入消息，但数据库（我无法控制）将此数据记录为 BLOB。有没有办法让 Spring Integration 将字符串按摩到 CLOB 或 BLOB 中？

我有一个出站通道适配器进行数据库插入，它（简化）看起来像：

<int-jdbc:outbound-channel-adapter channel="inboundTraffic"
                                   datasource="localDataSource"
                                   query="insert into MESSAGES (DATA, SAVE_DATE)
                                          values (:payload, :saveDate)"
                                   sql-parameter-source-factory="spelSource" />

<bean id="spelSource" class="o.s.i.j.ExpressionEvaluatingSqlParameterSourceFactory">
    <property name="parameterExpressions">
         <map>
              <entry key="payload" value="payload" />
              <entry key="saveDate" value="new java.util.Date()" />
         </map>
    </property>
</bean>

但是我在负载上得到了 SQLException：

ORA-01461 只能绑定 LONG 值，以便插入到 LONG 列中。

频道。文档的 18 有一个 blob 示例，将整个内容重写为服务激活器而不是 oubound-channel-adapter，并从文件流式传输......这似乎有点过头了，但 BLOB 和 CLOBS 应该是这样的在框架内完成？

感谢您的帮助！

Answer 1

这个怎么样：

<entry key="payload" value="new org.springframework.jdbc.core.support.SqlLobValue(payload)" />

?

查看它的 JavaDoc：

 * Object to represent an SQL BLOB/CLOB value parameter. BLOBs can either be an
 * InputStream or a byte array. CLOBs can be in the form of a Reader, InputStream
 * or String. Each CLOB/BLOB value will be stored together with its length.
 * The type is based on which constructor is used. Objects of this class are
 * immutable except for the LobCreator reference. Use them and discard them.

更新

“SqlLobValue 只支持 SQL 类型 BLOB 和 CLOB”，源于 SqlLobValue.setTypeValue(...) 方法。

看起来SqlLobValue 没有默认的sqlType，所以我们应该在SqlParameterSource 级别手动执行一些操作，因为它提供了getSqlType() 合约。

我们可以简单地使用ExpressionEvaluatingSqlParameterSourceFactory 扩展来做到这一点：

public class MyExpressionEvaluatingSqlParameterSourceFactory extends ExpressionEvaluatingSqlParameterSourceFactory {
    @Override
    public SqlParameterSource createParameterSource(Object input) {
        AbstractSqlParameterSource parameterSource =
                (AbstractSqlParameterSource) super.createParameterSource(input);
        parameterSource.registerSqlType("payload", Types.BLOB);
        return parameterSource;
    }
}

随时提出JIRA 以向ExpressionEvaluatingSqlParameterSourceFactory 添加setSqlTypes() 支持。