1

我正在尝试使用骆驼 SQL 组件（http://camel.apache.org/sql-component.html）插入输入流。

我在 Oracle 数据库中有下表：

table EMPLOYEE(NAME varchar(32) ,SURNAME varchar(32)  , PIC BLOB );

和以下路线：

 <route>
   <from uri="direct:startOracle" />
    <to uri="sql:INSERT INTO EMPLOYEE (Name, surname, pics) VALUES (# , # , #)?dataSource=#oracle" />
</route>

当我尝试运行以下代码时：

Resource r = contex.getResource("classpath:file/ciao.jpg");
InputStream inputStream = r.getInputStream();   
aProducerTemplate.sendBody(new Object[] {"mario", "ross", inputStream});

我总是得到一种不兼容的第三个参数（输入流）。

相同的代码在 MySQL 数据库上运行没有错误，但在 Oracle 上运行不佳。

我看到组件骆驼 SQL 使用以下代码作为使用准备好的语句的策略：

// use argument setter as it deals with various JDBC drivers setObject vs setLong/setInteger/setString etc.
ArgumentPreparedStatementSetter setter = new ArgumentPreparedStatementSetter(args);
setter.setValues(ps);

但这种策略似乎没有使用如下准备语句：

ps.setBinaryStream(3,inputStream,length);

而是调用以下代码

ps.setObject(paramIndex, inputStream);

它似乎在 oracle db 上效果不佳。

所以问题是：我会改变 SQL 骆驼组件使用的默认 SQL 准备语句策略吗？或者还有其他方法吗？

4

1 回答 1

1

非常感谢您的评论。

我刚刚找到了一个解决方案：

Resource r = contex.getResource("classpath:file/ciao.jpg");
InputStream inputStream = r.getInputStream();
SqlLobValue blobVal = new SqlLobValue(inputStream, (int) r.getFile().length() );
SqlParameterValue blob = new SqlParameterValue(Types.BLOB,"BLOB", blobVal );
aProducerTemplate.sendBody(new Object[] {"Mario", "Rossi",blob} );
于 2016-01-05T17:02:45.303 回答