[jboss-svn-commits] JBL Code SVN: r23439 - 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-13 08:58:35 -0400 (Mon, 13 Oct 2008)
New Revision: 23439

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-2116

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-13 12:27:03 UTC (rev 23438)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/couriers/SqlTableCourier.java	2008-10-13 12:58:35 UTC (rev 23439)
@@ -321,8 +321,12 @@
                         {
                         case Types.BLOB:
                             final Blob blob = resultSet.getBlob(1) ;
-                            final byte[] blobData = StreamUtils.readStream(blob.getBinaryStream()) ;
-                            value = new String(blobData) ;
+                            final byte[] blobData = ((blob != null) ? StreamUtils.readStream(blob.getBinaryStream()) : null);
+                            
+                            if (blobData != null)
+                                value = new String(blobData) ;
+                            else
+                                value = "";
                             break ;
                         case Types.BINARY:
                         case Types.VARBINARY:

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-13 12:27:03 UTC (rev 23438)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java	2008-10-13 12:58:35 UTC (rev 23439)
@@ -490,7 +490,7 @@
                         final int type = meta.getColumnType(iCurr) ;
                         if (type == Types.BLOB) {
                             final Blob blob = RS.getBlob(iCurr) ;
-                            row.put(sCol, StreamUtils.readStreamString(blob.getBinaryStream(), "UTF-8"));
+                            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()));