0003716: MSSQL bulk loader fails when truncate table is used as part of

the load with a different target database and schema
JumpMind · Sep 11, 2018 · 549b92e · 549b92e
1 parent a000d14
commit 549b92e
Showing 1 changed file with 12 additions and 9 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
@@ -85,7 +85,8 @@ public boolean start(Table table) {
                 String qualifiedName = sourceTable.getFullyQualifiedTableName();
                 if (writerSettings.isIgnoreMissingTables()) {                    
                     if (!missingTables.contains(qualifiedName)) {
-                        log.warn("Did not find the {} table in the target database", qualifiedName);
+                        log.info("Did not find the {} table in the target database. This might have been part of a sql "
+                                + "command (truncate) but will work if the fully qualified name was in the sql provided", qualifiedName);
                         missingTables.add(qualifiedName);
                     }
                 } else {
@@ -94,7 +95,7 @@ public boolean start(Table table) {
             }
 
             needsBinaryConversion = false;
-            if (! batch.getBinaryEncoding().equals(BinaryEncoding.HEX)) {
+            if (! batch.getBinaryEncoding().equals(BinaryEncoding.HEX) && targetTable != null) {
                 for (Column column : targetTable.getColumns()) {
                     if (column.isOfBinaryType()) {
                         needsBinaryConversion = true;
@@ -104,13 +105,15 @@ public boolean start(Table table) {
             }
             databaseTable = getPlatform(table).getTableFromCache(sourceTable.getCatalog(), sourceTable.getSchema(),
                     sourceTable.getName(), false);
-            String[] csvNames = targetTable.getColumnNames();
-            String[] columnNames = databaseTable.getColumnNames();
-            needsColumnsReordered = false;
-            for (int i = 0; i < csvNames.length; i++) {
-                if (! csvNames[i].equals(columnNames[i])) {
-                    needsColumnsReordered = true;
-                    break;
+            if (targetTable != null) {
+                String[] csvNames = targetTable.getColumnNames();
+                String[] columnNames = databaseTable.getColumnNames();
+                needsColumnsReordered = false;
+                for (int i = 0; i < csvNames.length; i++) {
+                    if (! csvNames[i].equals(columnNames[i])) {
+                        needsColumnsReordered = true;
+                        break;
+                    }
                 }
             }
         	//TODO: Did this because start is getting called multiple times