From 8ec661518ed7c3ae780e0dacd5a04e9a02910ab9 Mon Sep 17 00:00:00 2001
From: Eric Long <elong@jumpmind.com>
Date: Fri, 7 Aug 2020 10:28:57 -0400
Subject: [PATCH] 0004493: better debug logging

---
 .../jumpmind/symmetric/io/MsSqlBulkDatabaseWriter.java    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/io/MsSqlBulkDatabaseWriter.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/io/MsSqlBulkDatabaseWriter.java
index fa5b918152..47e6da579c 100644
--- a/symmetric-client/src/main/java/org/jumpmind/symmetric/io/MsSqlBulkDatabaseWriter.java
+++ b/symmetric-client/src/main/java/org/jumpmind/symmetric/io/MsSqlBulkDatabaseWriter.java
@@ -75,6 +75,8 @@ public MsSqlBulkDatabaseWriter(IDatabasePlatform symmetricPlatform,
            this.rowTerminator = rowTerminator;
         }
         this.uncPath = uncPath;
+        log.debug("Initialized with maxRowsBeforeFlush={}, fireTriggers={}, fieldTerminator={}, rowTerminator={}, uncPath={}",
+                maxRowsBeforeFlush, fireTriggers, fieldTerminator, rowTerminator, uncPath);
     }
 
     public boolean start(Table table) {
@@ -204,7 +206,7 @@ protected void bulkWrite(CsvData data) {
     
     protected void flush() {
         if (loadedRows > 0) {
-                this.stagedInputFile.close();
+            this.stagedInputFile.close();
                 
             statistics.get(batch).startTimer(DataWriterStatisticConstants.LOADMILLIS);
             String filename;
@@ -236,7 +238,8 @@ protected void flush() {
                         " WITH (DATAFILETYPE='widechar', FIELDTERMINATOR='"+StringEscapeUtils.escapeJava(fieldTerminator)+"', KEEPIDENTITY" + 
                         (fireTriggers ? ", FIRE_TRIGGERS" : "") + rowTerminatorString +");";
                 Statement stmt = c.createStatement();
-    
+                log.debug("Running {}", sql);
+
                 //TODO:  clean this up, deal with errors, etc.?
                 stmt.execute(sql);
                 stmt.close();
@@ -255,5 +258,6 @@ protected void createStagingFile() {
         //      but we don't want to depend on symmetric core.
         this.stagedInputFile = stagingManager.create("bulkloaddir",
                 table.getName() + this.getBatch().getBatchId() + ".csv");
+        log.debug("Using staging file {}", stagedInputFile.getFile().getPath());
     }
 }
\ No newline at end of file