0003691: initial.load.before.sql and initial.load.after.sql don't work

with a full load anymore
JumpMind · Aug 24, 2018 · 836a35e · 836a35e
1 parent 3a8082d
commit 836a35e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
@@ -678,7 +678,7 @@ private void insertSqlEventsPriorToReload(Node targetNode, String nodeIdRecord,
                     loadId, createBy);
         }
 
-        if (reloadRequests == null || reloadRequests.size() == 0) {
+        if (isFullLoad) {
             String beforeSql = parameterService.getString(reverse ? ParameterConstants.INITIAL_LOAD_REVERSE_BEFORE_SQL
                     : ParameterConstants.INITIAL_LOAD_BEFORE_SQL);
             if (isNotBlank(beforeSql)) {
@@ -697,7 +697,7 @@ private void insertSqlEventsAfterReload(Node targetNode, String nodeIdRecord, lo
             Map<Integer, List<TriggerRouter>> triggerRoutersByHistoryId,
             Map<String, TableReloadRequest> reloadRequests, boolean isFullLoad, String channelId) {
 
-        if (reloadRequests == null || reloadRequests.size() == 0) {
+        if (isFullLoad) {
             String afterSql = parameterService.getString(reverse ? ParameterConstants.INITIAL_LOAD_REVERSE_AFTER_SQL
                             : ParameterConstants.INITIAL_LOAD_AFTER_SQL);
             if (isNotBlank(afterSql)) {