From eb1fefa4e4a2d85ac5f9e23ff695facfe1f6cc22 Mon Sep 17 00:00:00 2001 From: elong Date: Thu, 20 Dec 2018 10:27:01 -0500 Subject: [PATCH] 0003802: Faster two-pass initial load for tables with LOB on Oracle --- .../jumpmind/symmetric/service/impl/DataExtractorService.java | 4 ++-- 1 file changed, 2 insertions(+), 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 index c8fd1928a0..818cce4d30 100644 --- 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);