0003802: Faster two-pass initial load for tables with LOB on Oracle

JumpMind · Dec 20, 2018 · eb1fefa · eb1fefa
1 parent b3b0533
commit eb1fefa
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -2671,7 +2671,7 @@ protected CsvData selectNext() {
                         }
                     }
 
-                    if (symmetricDialect.isInitialLoadTwoPassLob(this.sourceTable)) {
+                    if (this.routingContext.getChannel().isReloadFlag() && symmetricDialect.isInitialLoadTwoPassLob(this.sourceTable)) {
                         this.isLobFirstPass = true;
                     }
 
@@ -2741,7 +2741,7 @@ protected void startNewCursor(final TriggerHistory triggerHistory,
 
             Channel channel = configurationService.getChannel(triggerRouter.getTrigger().getChannelId());
 
-            if (symmetricDialect.isInitialLoadTwoPassLob(this.sourceTable)) {
+            if (channel.isReloadFlag() && symmetricDialect.isInitialLoadTwoPassLob(this.sourceTable)) {
                 channel = new Channel();
                 channel.setContainsBigLob(!this.isLobFirstPass);
                 selectSql = symmetricDialect.getInitialLoadTwoPassLobSql(selectSql, this.sourceTable, this.isLobFirstPass);