0002216: Replication of rows with NULL in large object column on Post…

…greSQL throws exception
JumpMind · Mar 1, 2015 · cd05142 · cd05142
1 parent 19ec527
commit cd05142
Showing 1 changed file with 9 additions and 10 deletions.
diff --git a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/postgresql/PostgresLobHandler.java b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/postgresql/PostgresLobHandler.java
@@ -20,33 +20,32 @@
  */
 package org.jumpmind.db.platform.postgresql;
 
+import java.sql.Blob;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
 import org.jumpmind.db.sql.SymmetricLobHandler;
-import org.springframework.jdbc.support.lob.DefaultLobHandler;
-import org.springframework.jdbc.support.lob.LobHandler;
 
 public class PostgresLobHandler extends SymmetricLobHandler {
 
-    private LobHandler wrappedLobHandler = null;
-
     public PostgresLobHandler() {
         super();
-        DefaultLobHandler wrappedLobHandler = new DefaultLobHandler();
-        wrappedLobHandler.setWrapAsLob(true);
-        this.wrappedLobHandler = wrappedLobHandler;
     }
 
     public boolean needsAutoCommitFalseForBlob(int jdbcTypeCode, String jdbcTypeName) {
         return PostgreSqlDatabasePlatform.isBlobStoredByReference(jdbcTypeName);
     }
 
-    public byte[] getBlobAsBytes(ResultSet rs, int columnIndex, int jdbcTypeCode, String jdbcTypeName)
-            throws SQLException {
+    public byte[] getBlobAsBytes(ResultSet rs, int columnIndex, int jdbcTypeCode,
+            String jdbcTypeName) throws SQLException {
 
         if (PostgreSqlDatabasePlatform.isBlobStoredByReference(jdbcTypeName)) {
-            return wrappedLobHandler.getBlobAsBytes(rs, columnIndex);
+            Blob blob = rs.getBlob(columnIndex);
+            if (blob != null) {
+                return blob.getBytes(1, (int) blob.length());
+            } else {
+                return null;
+            }
         } else {
             return getDefaultHandler().getBlobAsBytes(rs, columnIndex);
         }