0002062: Slow SYM_DATA reads on Firebird

JumpMind · Nov 10, 2014 · 491bcb3 · 491bcb3
1 parent 7304687
commit 491bcb3
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/...ric-client/src/main/java/org/jumpmind/symmetric/db/firebird/FirebirdSymmetricDialect.java b/...ric-client/src/main/java/org/jumpmind/symmetric/db/firebird/FirebirdSymmetricDialect.java
@@ -29,6 +29,7 @@
 import org.jumpmind.db.util.BinaryEncoding;
 import org.jumpmind.symmetric.db.AbstractSymmetricDialect;
 import org.jumpmind.symmetric.db.ISymmetricDialect;
+import org.jumpmind.symmetric.model.Channel;
 import org.jumpmind.symmetric.model.Trigger;
 import org.jumpmind.symmetric.service.IParameterService;
 import org.springframework.jdbc.UncategorizedSQLException;
@@ -164,4 +165,14 @@ public void cleanupTriggers() {
             log.info("Remove {} triggers", count);
         }
     }
+
+    @Override
+    public String massageDataExtractionSql(String sql, Channel channel) {
+        if (channel != null && !channel.isContainsBigLob()) {
+            sql = StringUtils.replace(sql, "d.row_data", "cast(d.row_data as varchar(10000))");
+            sql = StringUtils.replace(sql, "d.old_data", "cast(d.old_data as varchar(10000))");
+            sql = StringUtils.replace(sql, "d.pk_data", "cast(d.pk_data as varchar(500))");
+        }
+        return sql;
+    }
 }