0002077: Sql Server and MySQL bulk database writer should use quoted …

…identifiers around table names
JumpMind · Nov 19, 2014 · 43db5eb · 43db5eb
1 parent 6dd1cb9
commit 43db5eb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/io/MySqlBulkDatabaseWriter.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/io/MySqlBulkDatabaseWriter.java
@@ -183,7 +183,7 @@ protected void flush() {
 	            String sql = String.format("LOAD DATA " + (isLocal ? "LOCAL " : "") + 
 	            		"INFILE '" + stagedInputFile.getFile().getAbsolutePath()).replace('\\', '/') + "' " + 
 	            		(isReplace ? "REPLACE " : "IGNORE ") + "INTO TABLE " +
-	            		this.getTargetTable().getFullyQualifiedTableName() +
+	            		this.getTargetTable().getFullyQualifiedTableName(platform.getDatabaseInfo().getDelimiterToken()) +
                                 " FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '\"' ESCAPED BY '\\\\' LINES TERMINATED BY '\\n' STARTING BY ''" +
                                 " (" + Table.getCommaDeliminatedColumns(table.getColumns()) + ")";
 	            Statement stmt = c.createStatement();

diff --git a/...ic-mssql/src/main/java/org/jumpmind/symmetric/io/data/writer/MsSqlBulkDatabaseWriter.java b/...ic-mssql/src/main/java/org/jumpmind/symmetric/io/data/writer/MsSqlBulkDatabaseWriter.java
@@ -190,7 +190,7 @@ protected void flush() {
 	            JdbcSqlTransaction jdbcTransaction = (JdbcSqlTransaction) transaction;
 	            Connection c = jdbcTransaction.getConnection();
 	            String sql = String.format("BULK INSERT " + 
-	            		this.getTargetTable().getFullyQualifiedTableName() + 
+	            		this.getTargetTable().getFullyQualifiedTableName(platform.getDatabaseInfo().getDelimiterToken()) + 
 	            		" FROM '" + filename) + "'" +
 	            		" WITH ( FIELDTERMINATOR='||', KEEPIDENTITY " + (fireTriggers ? ", FIRE_TRIGGERS" : "") + ");";
 	            Statement stmt = c.createStatement();