[jboss-svn-commits] JBL Code SVN: r23522 - in labs/jbossesb/trunk/product/rosetta/src/org/jboss: soa/esb/listeners/gateway and 1 other directory.

[jboss-svn-commits at lists.jboss.org]

Author: mark.little at jboss.com
Date: 2008-10-20 08:42:49 -0400 (Mon, 20 Oct 2008)
New Revision: 23522

Modified:
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/couriers/SqlTableCourier.java
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java
Log:
https://jira.jboss.org/jira/browse/JBESB-2135

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/couriers/SqlTableCourier.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/couriers/SqlTableCourier.java	2008-10-20 12:27:15 UTC (rev 23521)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/couriers/SqlTableCourier.java	2008-10-20 12:42:49 UTC (rev 23522)
@@ -336,7 +336,11 @@
                             break ;
                         case Types.CLOB:
                             final Clob clob = resultSet.getClob(1) ;
-                            value = StreamUtils.readReader(clob.getCharacterStream());
+                            
+                            if (clob != null)
+                                value = StreamUtils.readReader(clob.getCharacterStream());
+                            else
+                                value = "";
                             break ;
                         case Types.CHAR:
                         case Types.VARCHAR:

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java	2008-10-20 12:27:15 UTC (rev 23521)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java	2008-10-20 12:42:49 UTC (rev 23522)
@@ -493,7 +493,7 @@
                             row.put(sCol, ((blob != null) ? StreamUtils.readStreamString(blob.getBinaryStream(), "UTF-8") : null));
                         } else if (type == Types.CLOB) {
                             final Clob clob = RS.getClob(iCurr) ;
-                            row.put(sCol, StreamUtils.readReader(clob.getCharacterStream()));
+                            row.put(sCol, ((clob != null) ? StreamUtils.readReader(clob.getCharacterStream()) : null));
                         } else {
                             row.put(sCol, RS.getObject(iCurr));
                         }