0004798: No data found while correcting foreign key error for reload

batch
JumpMind · Jan 28, 2021 · ebb5865 · ebb5865
1 parent fef36f1
commit ebb5865
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
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
@@ -2537,8 +2537,15 @@ public void reloadMissingForeignKeyRowsForLoad(String sourceNodeId, long batchId
     public void sendMissingForeignKeyRowsForLoad(long batchId, String nodeId, long rowNumber, String rowData) {
         ISqlReadCursor<Data> cursor = null;
         Data data = null;
+        long startBatchId = batchId;
+        if (parameterService.is(ParameterConstants.INITIAL_LOAD_USE_EXTRACT_JOB)) {
+            startBatchId = sqlTemplateDirty.queryForLong(getSql("selectStartBatchExtractRequest"), batchId, nodeId);
+            if (startBatchId == 0) {
+                startBatchId = batchId;
+            }
+        }
         try {
-            cursor = selectDataFor(batchId, nodeId, false);
+            cursor = selectDataFor(startBatchId, nodeId, false);
             data = cursor.next();
         } finally {
             cursor.close();

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataServiceSqlMap.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataServiceSqlMap.java
@@ -154,6 +154,9 @@ public DataServiceSqlMap(IDatabasePlatform platform, Map<String, String> replace
                 + " last_update_time = ? "
                 + " where load_id = ? and completed = 0");
 
+        putSql("selectStartBatchExtractRequest",
+                "select start_batch_id from $(extract_request) where ? between start_batch_id and end_batch_id and node_id = ?");
+
         putSql("updateTableReloadStatusFinalizeCount", "update $(table_reload_status) set "
                 + " finalize_batch_count = ?, last_update_time = ? "
                 + " where load_id = ?");