This is an automated email from the ASF dual-hosted git repository.

hansva pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-hop.git


The following commit(s) were added to refs/heads/master by this push:
     new 4760e45  HOP-2671: add parameter resolve
     new b32bda3  Merge pull request #797 from hansva/master
4760e45 is described below

commit 4760e45561a5de2e4f1c4b88f73ba2e11e8863da
Author: Hans Van Akelyen <[email protected]>
AuthorDate: Fri May 7 23:40:22 2021 +0200

    HOP-2671: add parameter resolve
---
 .../transforms/monetdbbulkloader/MonetDbBulkLoader.java     | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git 
a/plugins/transforms/monetdbbulkloader/src/main/java/org/apache/hop/pipeline/transforms/monetdbbulkloader/MonetDbBulkLoader.java
 
b/plugins/transforms/monetdbbulkloader/src/main/java/org/apache/hop/pipeline/transforms/monetdbbulkloader/MonetDbBulkLoader.java
index 240c301..953d39a 100644
--- 
a/plugins/transforms/monetdbbulkloader/src/main/java/org/apache/hop/pipeline/transforms/monetdbbulkloader/MonetDbBulkLoader.java
+++ 
b/plugins/transforms/monetdbbulkloader/src/main/java/org/apache/hop/pipeline/transforms/monetdbbulkloader/MonetDbBulkLoader.java
@@ -436,12 +436,9 @@ public class MonetDbBulkLoader extends 
BaseTransform<MonetDbBulkLoaderMeta, Mone
           .append(data.quote)
           .append("' NULL AS '" + nullRep + "';");
       String cmd = cmdBuff.toString();
-      if (log.isDetailed()) {
-        logDetailed(cmd);
-      }
 
       // See if we need to execute extra SQL statements...
-      //
+
       String sql = dm.getConnectSql();
 
       // only execute if the SQL is not empty, null and is not just a bunch of
@@ -450,7 +447,10 @@ public class MonetDbBulkLoader extends 
BaseTransform<MonetDbBulkLoaderMeta, Mone
         String[] sqlStatements = sql.split(";");
         for (String statement : sqlStatements) {
           data.out.write('s');
-          data.out.write(statement);
+          data.out.write(resolve(statement));
+          if (log.isDetailed()) {
+            logDetailed(resolve(statement));
+          }
           data.out.write(';');
           data.out.newLine();
         }
@@ -458,6 +458,9 @@ public class MonetDbBulkLoader extends 
BaseTransform<MonetDbBulkLoaderMeta, Mone
         data.out.write('s');
       }
 
+      if (log.isDetailed()) {
+        logDetailed(cmd);
+      }
       data.out.write(cmdBuff.toString());
       data.out.newLine();
 

Reply via email to