0003621: use table variable to support changing sym prefix

JumpMind · Jul 9, 2018 · c016009 · c016009
1 parent 81e71b9
commit c016009
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -44,7 +44,7 @@ public OutgoingBatchServiceSqlMap(IDatabasePlatform platform,
                 "update $(outgoing_batch) set ignore_count=1, status='OK', error_flag=0, last_update_time=current_timestamp where load_id=?");
 
         putSql("cancelChannelBatchesSelectSql",
-                "select node_id, batch_id from sym_outgoing_batch where channel_id = ? and status <> ? and summary=? and sent_count=0");
+                "select node_id, batch_id from $(outgoing_batch) where channel_id = ? and status <> ? and summary=? and sent_count=0");
 
         putSql("cancelChannelBatchSql",
                 "update $(outgoing_batch) set ignore_count=1, status='OK', error_flag=0, last_update_time=current_timestamp where node_id = ? and batch_id = ?");