SQOOP-3350: Fix tests which use warehouse-dir as target-dir
authorBoglarka Egyed <bogi@apache.org>
Fri, 27 Jul 2018 09:27:18 +0000 (11:27 +0200)
committerBoglarka Egyed <bogi@apache.org>
Fri, 27 Jul 2018 09:27:18 +0000 (11:27 +0200)
(Szabolcs Vasas via Boglarka Egyed)

src/test/org/apache/sqoop/TestFreeFormQueryImport.java
src/test/org/apache/sqoop/manager/mysql/MySqlColumnEscapeImportTest.java
src/test/org/apache/sqoop/manager/oracle/OracleColumnEscapeImportTest.java
src/test/org/apache/sqoop/manager/oracle/OracleIncrementalImportTest.java
src/test/org/apache/sqoop/manager/oracle/OracleSpecialCharacterTableImportTest.java
src/test/org/apache/sqoop/manager/oracle/OracleSplitterTest.java

index 2df4352..d39faee 100644 (file)
@@ -90,7 +90,7 @@ public class TestFreeFormQueryImport extends ImportJobTestCase {
     args.add("--connect");
     args.add(getConnectString());
     args.add("--target-dir");
-    args.add(getWarehouseDir());
+    args.add(getTablePath().toString());
     args.add("--split-by");
     args.add(splitByCol);
     args.add("--num-mappers");
@@ -134,8 +134,7 @@ public class TestFreeFormQueryImport extends ImportJobTestCase {
 
     runImport(getArgv(tableName1 + "." + getColName(0), query));
 
-    Path warehousePath = new Path(this.getWarehouseDir());
-    Path filePath = new Path(warehousePath, "part-m-00000");
+    Path filePath = new Path(getTablePath(), "part-m-00000");
     String expectedVal = "1,foo";
 
     BufferedReader reader = null;
index 734499e..eaab8c5 100644 (file)
@@ -87,7 +87,7 @@ public class MySqlColumnEscapeImportTest extends ImportJobTestCase {
     args.add(mySQLTestUtils.getUserName());
     mySQLTestUtils.addPasswordIfIsSet(args);
     args.add("--target-dir");
-    args.add(getWarehouseDir());
+    args.add(getTablePath().toString());
     args.add("--num-mappers");
     args.add("1");
     args.add("--table");
@@ -105,8 +105,7 @@ public class MySqlColumnEscapeImportTest extends ImportJobTestCase {
     String[] args = getArgv();
     runImport(args);
 
-    Path warehousePath = new Path(this.getWarehouseDir());
-    Path filePath = new Path(warehousePath, "part-m-00000");
+    Path filePath = new Path(getTablePath(), "part-m-00000");
     String output = Files.toString(new File(filePath.toString()), Charsets.UTF_8);
 
     assertEquals("hello, world", output.trim());
index d4146dc..684586c 100644 (file)
@@ -87,7 +87,7 @@ public class OracleColumnEscapeImportTest extends ImportJobTestCase {
     args.add("--password");
     args.add(OracleUtils.ORACLE_USER_PASS);
     args.add("--target-dir");
-    args.add(getWarehouseDir());
+    args.add(getTablePath().toString());
     args.add("--num-mappers");
     args.add("1");
     args.add("--query");
@@ -104,8 +104,7 @@ public class OracleColumnEscapeImportTest extends ImportJobTestCase {
     String[] args = getArgv();
     runImport(args);
 
-    Path warehousePath = new Path(this.getWarehouseDir());
-    Path filePath = new Path(warehousePath, "part-m-00000");
+    Path filePath = new Path(getTablePath(), "part-m-00000");
     String output = Files.toString(new File(filePath.toString()), Charsets.UTF_8);
 
     assertEquals("hello, world!", output.trim());
index 4dde3d6..8e6ccc9 100644 (file)
@@ -109,7 +109,7 @@ public class OracleIncrementalImportTest extends ImportJobTestCase {
     args.add("--connect");
     args.add(getConnectString());
     args.add("--target-dir");
-    args.add(getWarehouseDir());
+    args.add(getTablePath().toString());
     args.add("--num-mappers");
     args.add("1");
     args.add("--split-by");
@@ -153,8 +153,7 @@ public class OracleIncrementalImportTest extends ImportJobTestCase {
     String[] args = getArgv(tableName, connPropsFileName, getColName(2));
     runImport(args);
 
-    Path warehousePath = new Path(this.getWarehouseDir());
-    Path filePath = new Path(warehousePath, "part-m-00000");
+    Path filePath = new Path(getTablePath().toString(), "part-m-00000");
     String output = readLineFromPath(filePath);
     String expectedVal = "2,new_data,2000-11-11";
     assertEquals("Incremental import result expected a different string",
@@ -181,8 +180,7 @@ public class OracleIncrementalImportTest extends ImportJobTestCase {
     String[] args = getArgv(tableName, connPropsFileName, getColName(2));
     runImport(args);
 
-    Path warehousePath = new Path(this.getWarehouseDir());
-    Path filePath = new Path(warehousePath, "part-m-00000");
+    Path filePath = new Path(getTablePath(), "part-m-00000");
     String output = readLineFromPath(filePath);
     String expectedVal = "2,new_data,2000-11-11 23:23:23.0";
     assertEquals("Incremental import result expected a different string",
index 453ad82..6539e5a 100644 (file)
@@ -98,7 +98,7 @@ public class OracleSpecialCharacterTableImportTest extends ImportJobTestCase {
     args.add("--password");
     args.add(OracleUtils.ORACLE_USER_PASS);
     args.add("--target-dir");
-    args.add(getWarehouseDir());
+    args.add(getTablePath().toString());
     args.add("--num-mappers");
     args.add("1");
     args.add("--table");
@@ -120,8 +120,7 @@ public class OracleSpecialCharacterTableImportTest extends ImportJobTestCase {
     String[] args = getArgv();
     runImport(args);
 
-    Path warehousePath = new Path(this.getWarehouseDir());
-    Path filePath = new Path(warehousePath, "part-m-00000");
+    Path filePath = new Path(getTablePath(), "part-m-00000");
     String output = Files.toString(new File(filePath.toString()), Charsets.UTF_8);
 
     assertEquals("hello, world!", output.trim());
index 33b7d74..c2f9532 100644 (file)
@@ -91,7 +91,7 @@ public class OracleSplitterTest extends ImportJobTestCase {
     args.add("--connect");
     args.add(getConnectString());
     args.add("--target-dir");
-    args.add(getWarehouseDir());
+    args.add(getTablePath().toString());
     args.add("--num-mappers");
     args.add("2");
     args.add("--split-by");
@@ -127,13 +127,13 @@ public class OracleSplitterTest extends ImportJobTestCase {
     List<String> lines;
 
     // First row should be in the first file
-    file = new File(this.getWarehouseDir(), "part-m-00000");
+    file = new File(getTablePath().toString(), "part-m-00000");
     lines = FileUtils.readLines(file, "UTF-8");
     assertEquals(1, lines.size());
     assertEquals("1,old_data,1999-01-01 11:11:11.0", lines.get(0));
 
     // With second line in the second file
-    file = new File(this.getWarehouseDir(), "part-m-00001");
+    file = new File(getTablePath().toString(), "part-m-00001");
     lines = FileUtils.readLines(file, "UTF-8");
     assertEquals(1, lines.size());
     assertEquals("2,new_data,2000-11-11 23:23:23.0", lines.get(0));