SQOOP-3350: Fix tests which use warehouse-dir as target-dir
(Szabolcs Vasas via Boglarka Egyed)
diff --git a/src/test/org/apache/sqoop/TestFreeFormQueryImport.java b/src/test/org/apache/sqoop/TestFreeFormQueryImport.java
index 2df4352..d39faee 100644
--- a/src/test/org/apache/sqoop/TestFreeFormQueryImport.java
+++ b/src/test/org/apache/sqoop/TestFreeFormQueryImport.java
@@ -90,7 +90,7 @@
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 @@
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;
diff --git a/src/test/org/apache/sqoop/manager/mysql/MySqlColumnEscapeImportTest.java b/src/test/org/apache/sqoop/manager/mysql/MySqlColumnEscapeImportTest.java
index 734499e..eaab8c5 100644
--- a/src/test/org/apache/sqoop/manager/mysql/MySqlColumnEscapeImportTest.java
+++ b/src/test/org/apache/sqoop/manager/mysql/MySqlColumnEscapeImportTest.java
@@ -87,7 +87,7 @@
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 @@
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());
diff --git a/src/test/org/apache/sqoop/manager/oracle/OracleColumnEscapeImportTest.java b/src/test/org/apache/sqoop/manager/oracle/OracleColumnEscapeImportTest.java
index d4146dc..684586c 100644
--- a/src/test/org/apache/sqoop/manager/oracle/OracleColumnEscapeImportTest.java
+++ b/src/test/org/apache/sqoop/manager/oracle/OracleColumnEscapeImportTest.java
@@ -87,7 +87,7 @@
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 @@
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());
diff --git a/src/test/org/apache/sqoop/manager/oracle/OracleIncrementalImportTest.java b/src/test/org/apache/sqoop/manager/oracle/OracleIncrementalImportTest.java
index 4dde3d6..8e6ccc9 100644
--- a/src/test/org/apache/sqoop/manager/oracle/OracleIncrementalImportTest.java
+++ b/src/test/org/apache/sqoop/manager/oracle/OracleIncrementalImportTest.java
@@ -109,7 +109,7 @@
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 @@
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 @@
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",
diff --git a/src/test/org/apache/sqoop/manager/oracle/OracleSpecialCharacterTableImportTest.java b/src/test/org/apache/sqoop/manager/oracle/OracleSpecialCharacterTableImportTest.java
index 453ad82..6539e5a 100644
--- a/src/test/org/apache/sqoop/manager/oracle/OracleSpecialCharacterTableImportTest.java
+++ b/src/test/org/apache/sqoop/manager/oracle/OracleSpecialCharacterTableImportTest.java
@@ -98,7 +98,7 @@
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 @@
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());
diff --git a/src/test/org/apache/sqoop/manager/oracle/OracleSplitterTest.java b/src/test/org/apache/sqoop/manager/oracle/OracleSplitterTest.java
index 33b7d74..c2f9532 100644
--- a/src/test/org/apache/sqoop/manager/oracle/OracleSplitterTest.java
+++ b/src/test/org/apache/sqoop/manager/oracle/OracleSplitterTest.java
@@ -91,7 +91,7 @@
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 @@
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));