0005413: Bulk loaded flag is not being read from database for incoming

and outgoing services
JumpMind · Aug 17, 2022 · c070bbc · c070bbc
1 parent 841be6b
commit c070bbc
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 2 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
@@ -572,6 +572,7 @@ public IncomingBatch mapRow(Row rs) {
             batch.setLoadId(rs.getLong("load_id"));
             batch.setCommonFlag(rs.getBoolean("common_flag"));
             batch.setFailedDataId(rs.getLong("failed_data_id"));
+            batch.setBulkLoadFlag(rs.getBoolean("bulk_loader_flag"));
             return batch;
         }
     }

diff --git a/...ic-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchServiceSqlMap.java b/...ic-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchServiceSqlMap.java
@@ -42,7 +42,7 @@ public IncomingBatchServiceSqlMap(IDatabasePlatform platform, Map<String, String
                     + "  data_row_count, extract_insert_row_count, extract_update_row_count, "
                     + "  extract_delete_row_count, extract_row_count, reload_row_count, other_row_count, "
                     + "  load_flag, extract_count, load_count, router_millis, extract_millis, sent_count, "
-                    + "  transform_extract_millis, transform_load_millis, load_id, common_flag, failed_data_id from "
+                    + "  transform_extract_millis, transform_load_millis, load_id, common_flag, failed_data_id, bulk_loader_flag from "
                     + "  $(incoming_batch)                                          " );
 
         putSql("selectCreateTimePrefixSql" ,"" + 

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java
@@ -876,6 +876,7 @@ public OutgoingBatch mapRow(Row rs) {
                     batch.setIgnoreRowCount(rs.getLong("ignore_row_count"));
                     batch.setMissingDeleteCount(rs.getLong("missing_delete_count"));
                     batch.setSkipCount(rs.getLong("skip_count"));
+                    batch.setBulkLoadFlag(rs.getBoolean("bulk_loader_flag"));
                 }
                 return batch;
             } else {

diff --git a/...ic-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java b/...ic-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java
@@ -97,7 +97,7 @@ public OutgoingBatchServiceSqlMap(IDatabasePlatform platform,
                         + "  b.transform_extract_millis, b.transform_load_millis, b.fallback_insert_count, b.fallback_update_count, "
                         + "  b.conflict_win_count, b.conflict_lose_count, b.ignore_row_count, b.missing_delete_count, b.skip_count, "
                         + "  b.failed_data_id, b.failed_line_number, b.last_update_hostname, b.last_update_time, b.create_time, b.batch_id, "
-                        + "  b.extract_job_flag, b.load_flag, b.error_flag, b.common_flag, b.load_id, b.create_by, b.summary from "
+                        + "  b.extract_job_flag, b.load_flag, b.error_flag, b.common_flag, b.load_id, b.create_by, b.summary, b.bulk_loader_flag from "
                         + "  $(outgoing_batch) b ");
         putSql("selectOutgoingBatchErrorsSql", " where error_flag=1 order by batch_id   ");
         putSql("countOutgoingBatchesErrorsOnChannelSql",