Merge pull request #99 from assimbly/229-sqldouble-insert-of-backslas…

…h-if-option-escape-characters-is-enabled Sql - query was interpolated 2 times
assimbly · Jun 18, 2024 · 6ba3b44 · 6ba3b44
2 parents 8b57e06 + 4325168
commit 6ba3b44
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/sql/src/main/java/org/assimbly/sql/SqlConfiguration.java b/sql/src/main/java/org/assimbly/sql/SqlConfiguration.java
@@ -179,9 +179,8 @@ public String getDatabase(Exchange exchange) {
         return interpolateVar(database, exchange);
     }
 
-    public String getQuery(Exchange exchange) {
-        String query = Base64Helper.unmarshal(this.query, StandardCharsets.UTF_8);
-        return interpolateVar(query, exchange);
+    public String getQuery() {
+        return Base64Helper.unmarshal(this.query, StandardCharsets.UTF_8);
     }
 
     public ConnectionType getConnectionType() {

diff --git a/sql/src/main/java/org/assimbly/sql/SqlProcessor.java b/sql/src/main/java/org/assimbly/sql/SqlProcessor.java
@@ -50,7 +50,7 @@ public void process(Exchange exchange) throws Exception {
         if(connection == null)
             throw new SQLException("Could not connect to the database, check your settings.");
 
-        Document result = executeQuery(exchange, connection, config.getQuery(exchange).trim());
+        Document result = executeQuery(exchange, connection, config.getQuery().trim());
 
         exchange.getIn().setBody(XmlHelper.prettyPrint(result));
     }