0001471: honor the initial.load.delete.first parameter for table_relo…

…ad_request
JumpMind · Nov 25, 2013 · a641592 · a641592
1 parent 68d9bb4
commit a641592
Showing 1 changed file with 3 additions and 6 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
@@ -123,12 +123,9 @@ public boolean insertReloadEvent(TableReloadRequest request, boolean deleteAtCli
                             try {
                                 transaction = sqlTemplate.startSqlTransaction();
 
-                                String deleteStatement = StringUtils.isNotBlank(request
-                                        .getReloadDeleteStmt()) ? request.getReloadDeleteStmt()
-                                        : triggerRouter.getInitialLoadDeleteStmt();
-                                if (StringUtils.isNotBlank(deleteStatement)) {
-                                    insertPurgeEvent(transaction, targetNode, triggerRouter,
-                                            triggerHistory, false, deleteStatement, -1, null);
+                                if (parameterService.is(ParameterConstants.INITIAL_LOAD_DELETE_BEFORE_RELOAD)) {
+	                                String overrideDeleteStatement = StringUtils.isNotBlank(request.getReloadDeleteStmt()) ? request.getReloadDeleteStmt() : null;
+                                    insertPurgeEvent(transaction, targetNode, triggerRouter, triggerHistory, false, overrideDeleteStatement, -1, null);
                                 }
 
                                 insertReloadEvent(transaction, targetNode, triggerRouter,