Author: ningjiang Date: Thu Aug 30 07:08:46 2012 New Revision: 1378825 URL: http://svn.apache.org/viewvc?rev=1378825&view=rev Log: CAMEL-5551 fix the issue that String types not converted from CLOB
Modified: camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java Modified: camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java?rev=1378825&r1=1378824&r2=1378825&view=diff ============================================================================== --- camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java (original) +++ camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java Thu Aug 30 07:08:46 2012 @@ -21,6 +21,7 @@ import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; +import java.sql.Types; import java.util.ArrayList; import java.util.LinkedHashMap; import java.util.List; @@ -257,8 +258,14 @@ public class JdbcProducer extends Defaul columnName = meta.getColumnName(columnNumber); } } - // use index based which should be faster - row.put(columnName, rs.getObject(columnNumber)); + // use index based which should be faster + int columnType = meta.getColumnType( columnNumber ); + if (columnType == Types.CLOB || columnType == Types.BLOB) { + row.put(columnName, rs.getString( columnNumber)); + } + else { + row.put(columnName, rs.getObject(columnNumber)); + } } data.add(row); rowNumber++;