svn commit: r1378825 - /camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java

[ningjiang]

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++;