diff --git a/src/java/org/apache/sqoop/mapreduce/OracleUpsertOutputFormat.java b/src/java/org/apache/sqoop/mapreduce/OracleUpsertOutputFormat.java index f79aaa9d..88754e75 100644 --- a/src/java/org/apache/sqoop/mapreduce/OracleUpsertOutputFormat.java +++ b/src/java/org/apache/sqoop/mapreduce/OracleUpsertOutputFormat.java @@ -71,7 +71,7 @@ protected String getUpdateStatement() { // lookup table for update columns Set updateKeyLookup = new LinkedHashSet(); for (String updateKey : updateCols) { - updateKeyLookup.add(updateKey); + updateKeyLookup.add('"' + updateKey + '"'); } StringBuilder sb = new StringBuilder(); @@ -85,7 +85,7 @@ protected String getUpdateStatement() { } else { sb.append(" AND "); } - sb.append(updateCols[i]).append(" = ?"); + sb.append('"' + updateCols[i] + '"').append(" = ?"); } sb.append(" )");