diff --git a/src/java/org/apache/sqoop/manager/SQLServerManager.java b/src/java/org/apache/sqoop/manager/SQLServerManager.java index 024b16ea..7ce1edd6 100644 --- a/src/java/org/apache/sqoop/manager/SQLServerManager.java +++ b/src/java/org/apache/sqoop/manager/SQLServerManager.java @@ -77,5 +77,21 @@ protected String getListDatabasesQuery() { protected String getSchemaQuery() { return "SELECT SCHEMA_NAME()"; } + + @Override + public String escapeColName(String colName) { + if (null == colName) { + return null; + } + return "[" + colName + "]"; + } + + @Override + public String escapeTableName(String tableName) { + if (null == tableName) { + return null; + } + return "[" + tableName + "]"; + } }