0004567: Fixed SqlException when using sync.table.prefix

JumpMind · Aug 4, 2022 · 96ce0b5 · 96ce0b5
1 parent ff8d36e
commit 96ce0b5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractSymmetricDialect.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractSymmetricDialect.java
@@ -619,11 +619,11 @@ public long insertWithGeneratedKey(final String sql, final SequenceIdentifier id
     public String getSequenceName(SequenceIdentifier identifier) {
         switch (identifier) {
             case REQUEST:
-                return "sym_extract_r_st_request_id";
+                return parameterService.getTablePrefix() + "_extract_r_st_request_id";
             case DATA:
-                return "sym_data_data_id";
+                return parameterService.getTablePrefix() + "_data_data_id";
             case TRIGGER_HIST:
-                return "sym_trigger_his_ger_hist_id";
+                return parameterService.getTablePrefix() + "_trigger_his_ger_hist_id";
         }
         return null;
     }