You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ma...@apache.org on 2016/11/29 18:08:03 UTC

sqoop git commit: SQOOP-3057: Fixing 3rd party Oracle tests failing due to invalid case of column names

Repository: sqoop
Updated Branches:
  refs/heads/trunk f9d76fd4a -> 916cae19f


SQOOP-3057: Fixing 3rd party Oracle tests failing
due to invalid case of column names

(Anna Szonyi via Attila Szabo)


Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/916cae19
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/916cae19
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/916cae19

Branch: refs/heads/trunk
Commit: 916cae19f8851f72e425f7d7bbdbdd92f5fe1bc5
Parents: f9d76fd
Author: Attila Szabo <ma...@apache.org>
Authored: Tue Nov 29 19:06:19 2016 +0100
Committer: Attila Szabo <ma...@apache.org>
Committed: Tue Nov 29 19:06:19 2016 +0100

----------------------------------------------------------------------
 .../com/cloudera/sqoop/manager/MySQLTestUtils.java    |  4 ++--
 .../com/cloudera/sqoop/manager/OracleExportTest.java  |  4 ++--
 .../sqoop/manager/oracle/OracleCallExportTest.java    | 14 +++++++-------
 3 files changed, 11 insertions(+), 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/sqoop/blob/916cae19/src/test/com/cloudera/sqoop/manager/MySQLTestUtils.java
----------------------------------------------------------------------
diff --git a/src/test/com/cloudera/sqoop/manager/MySQLTestUtils.java b/src/test/com/cloudera/sqoop/manager/MySQLTestUtils.java
index 2e2448a..77aefde 100644
--- a/src/test/com/cloudera/sqoop/manager/MySQLTestUtils.java
+++ b/src/test/com/cloudera/sqoop/manager/MySQLTestUtils.java
@@ -19,7 +19,7 @@
 package com.cloudera.sqoop.manager;
 
 import com.cloudera.sqoop.SqoopOptions;
-import jodd.util.StringUtil;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -149,7 +149,7 @@ public final class MySQLTestUtils {
   }
 
   private boolean isSet(String userPass) {
-    return !StringUtil.isBlank(userPass);
+    return !StringUtils.isBlank(userPass);
   }
 
   public void addPasswordIfIsSet(SqoopOptions opts) {

http://git-wip-us.apache.org/repos/asf/sqoop/blob/916cae19/src/test/com/cloudera/sqoop/manager/OracleExportTest.java
----------------------------------------------------------------------
diff --git a/src/test/com/cloudera/sqoop/manager/OracleExportTest.java b/src/test/com/cloudera/sqoop/manager/OracleExportTest.java
index e716510..7ee3d94 100644
--- a/src/test/com/cloudera/sqoop/manager/OracleExportTest.java
+++ b/src/test/com/cloudera/sqoop/manager/OracleExportTest.java
@@ -271,10 +271,10 @@ public class OracleExportTest extends TestExport {
     createTable();
     // first time will be insert.
     runExport(getArgv(true, 10, 10, newStrArray(null,
-        "--update-key", "id", "--update-mode", "allowinsert")));
+        "--update-key", "ID", "--update-mode", "allowinsert")));
     // second time will be update.
     runExport(getArgv(true, 10, 10, newStrArray(null,
-        "--update-key", "id", "--update-mode", "allowinsert")));
+        "--update-key", "ID", "--update-mode", "allowinsert")));
     verifyExport(TOTAL_RECORDS);
   }
 }

http://git-wip-us.apache.org/repos/asf/sqoop/blob/916cae19/src/test/org/apache/sqoop/manager/oracle/OracleCallExportTest.java
----------------------------------------------------------------------
diff --git a/src/test/org/apache/sqoop/manager/oracle/OracleCallExportTest.java b/src/test/org/apache/sqoop/manager/oracle/OracleCallExportTest.java
index 431df0f..1d3417a 100644
--- a/src/test/org/apache/sqoop/manager/oracle/OracleCallExportTest.java
+++ b/src/test/org/apache/sqoop/manager/oracle/OracleCallExportTest.java
@@ -90,23 +90,23 @@ public class OracleCallExportTest extends ExportJobTestCase {
   private void createObjects() {
 
     String createTableSql = "CREATE TABLE " + tableName + " ( "
-      + "\"id\"  INT NOT NULL PRIMARY KEY, "
-      + "\"msg\" VARCHAR(24) NOT NULL, "
+      + "\"ID\"  INT NOT NULL PRIMARY KEY, "
+      + "\"MSG\" VARCHAR(24) NOT NULL, "
       + "\"d\" DATE, "
       + "\"f\" FLOAT, "
       + "\"vc\" VARCHAR(32))";
 
     String createProcSql = "CREATE PROCEDURE " + procName + " ( "
-      + "\"id\" IN INT,"
-      + "\"msg\" IN VARCHAR,"
+      + "\"ID\" IN INT,"
+      + "\"MSG\" IN VARCHAR,"
       + "\"d\" IN DATE,"
       + "\"f\" IN FLOAT) IS BEGIN "
       + "INSERT INTO " + tableName + " "
-      + "VALUES(\"id\","
-      + "\"msg\","
+      + "VALUES(\"ID\","
+      + "\"MSG\","
       + "\"d\","
       + "\"f\","
-      + "\"msg\" || '_2'); END;";
+      + "\"MSG\" || '_2'); END;";
 
     try {
       dropTableIfExists(tableName);