0003905: table sym_extract_request not found, missing table prefix

JumpMind · Apr 9, 2019 · 580bf32 · 580bf32
1 parent 900ac13
commit 580bf32
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ic-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorServiceSqlMap.java b/...ic-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorServiceSqlMap.java
@@ -44,11 +44,11 @@ public DataExtractorServiceSqlMap(IDatabasePlatform platform,
 
         putSql("countExtractChildRequestMissed",
                 "select count(*) from $(extract_request) where status = ? and parent_request_id > 0 " 
-                + "and parent_request_id in (select request_id from sym_extract_request where parent_request_id = 0 and status = ?)");
+                + "and parent_request_id in (select request_id from $(extract_request) where parent_request_id = 0 and status = ?)");
 
         putSql("releaseExtractChildRequestMissed",
-                "update sym_extract_request set parent_request_id = 0 where status = ? and parent_request_id > 0 " 
-                + "and parent_request_id in (select request_id from sym_extract_request where parent_request_id = 0 and status = ?)");
+                "update $(extract_request) set parent_request_id = 0 where status = ? and parent_request_id > 0 " 
+                + "and parent_request_id in (select request_id from $(extract_request) where parent_request_id = 0 and status = ?)");
 
         putSql("insertExtractRequestSql", "insert into $(extract_request) (request_id, node_id, queue, status, start_batch_id, end_batch_id, trigger_id, router_id, load_id, table_name, total_rows, parent_request_id, last_update_time, create_time) "
                 + " values(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, current_timestamp, current_timestamp)");