sql syntax fixes

JumpMind · Jul 28, 2017 · f5f9e86 · f5f9e86
1 parent 4d65f09
commit f5f9e86
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
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
@@ -108,7 +108,7 @@ public OutgoingBatchServiceSqlMap(IDatabasePlatform platform,
                         + "  b.ignore_row_count, b.missing_delete_count, b.skip_count, "
                         + "  b.failed_data_id, 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      "
-                        + "  $(schemaName)$(outgoing_batch)                                                                                        ");
+                        + "  $(schemaName)$(outgoing_batch) b                                                                                       ");
 
         putSql("selectOutgoingBatchErrorsSql", " where error_flag=1 order by batch_id   ");
 

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterServiceSqlMap.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterServiceSqlMap.java
@@ -29,13 +29,13 @@ public class RouterServiceSqlMap extends AbstractSqlMap {
     public RouterServiceSqlMap(IDatabasePlatform platform, Map<String, String> replacementTokens) {
         super(platform, replacementTokens);
 
-        putSql("selectChannelsUsingGapsSql", "select distinct channel_id from $(schemaName)$(data) where $(schemaName)$(dataRange)");
+        putSql("selectChannelsUsingGapsSql", "select distinct channel_id from $(schemaName)$(data) where $(dataRange)");
 
         putSql("selectChannelsUsingStartDataId", "select distinct channel_id from $(schemaName)$(data) where data_id >= ?");
 
         putSql("selectDataUsingGapsSql",
                 ""
-                        + "select $(schemaName)$(selectDataUsingGapsSqlHint) d.data_id, d.table_name, d.event_type, d.row_data as row_data, d.pk_data as pk_data, d.old_data as old_data,                        "
+                        + "select $(selectDataUsingGapsSqlHint) d.data_id, d.table_name, d.event_type, d.row_data as row_data, d.pk_data as pk_data, d.old_data as old_data,                        "
                         + "  d.create_time, d.trigger_hist_id, d.channel_id, d.transaction_id, d.source_node_id, d.external_data, d.node_list   "
                         + "  from $(schemaName)$(data) d where d.channel_id=? $(dataRange)                                                ");