From 7d6667ddb65ff1e5c5ff2c4b764a8b3996016bf1 Mon Sep 17 00:00:00 2001 From: Venkat Ranganathan Date: Fri, 11 Nov 2016 14:06:21 -0800 Subject: [PATCH] SQOOP-2990: Sqoop(oracle) export [updateTableToOracle] with "--update-mode allowinsert" : app fails with java.sql.SQLException: Missing IN or OUT parameter at index (Sowmya Ramesh via Venkat Ranganathan) --- .../org/apache/sqoop/mapreduce/OracleUpsertOutputFormat.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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(" )");