You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ab...@apache.org on 2014/08/12 00:15:35 UTC
[15/17] SQOOP-1379: Sqoop2: From/To: Disable tests
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/common/src/test/java/org/apache/sqoop/submission/counter/TestCounter.java
----------------------------------------------------------------------
diff --git a/common/src/test/java/org/apache/sqoop/submission/counter/TestCounter.java b/common/src/test/java/org/apache/sqoop/submission/counter/TestCounter.java
index 0cf5d2b..962a535 100644
--- a/common/src/test/java/org/apache/sqoop/submission/counter/TestCounter.java
+++ b/common/src/test/java/org/apache/sqoop/submission/counter/TestCounter.java
@@ -25,20 +25,20 @@ import org.junit.Test;
*/
public class TestCounter {
- /**
- * Test method for initialization
- */
- @Test
- public void testInitialization() {
- Counter counter = new Counter("sqoop");
- Assert.assertEquals("sqoop", counter.getName());
- Assert.assertEquals(0l, counter.getValue());
-
- Counter counter1 = new Counter("sqoop", 1000l);
- Assert.assertEquals("sqoop", counter1.getName());
- Assert.assertEquals(1000l, counter1.getValue());
-
- counter1.setValue(2000l);
- Assert.assertEquals(2000l, counter1.getValue());
- }
+// /**
+// * Test method for initialization
+// */
+// @Test
+// public void testInitialization() {
+// Counter counter = new Counter("sqoop");
+// Assert.assertEquals("sqoop", counter.getName());
+// Assert.assertEquals(0l, counter.getValue());
+//
+// Counter counter1 = new Counter("sqoop", 1000l);
+// Assert.assertEquals("sqoop", counter1.getName());
+// Assert.assertEquals(1000l, counter1.getValue());
+//
+// counter1.setValue(2000l);
+// Assert.assertEquals(2000l, counter1.getValue());
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/common/src/test/java/org/apache/sqoop/submission/counter/TestCounterGroup.java
----------------------------------------------------------------------
diff --git a/common/src/test/java/org/apache/sqoop/submission/counter/TestCounterGroup.java b/common/src/test/java/org/apache/sqoop/submission/counter/TestCounterGroup.java
index 985009a..aac80d4 100644
--- a/common/src/test/java/org/apache/sqoop/submission/counter/TestCounterGroup.java
+++ b/common/src/test/java/org/apache/sqoop/submission/counter/TestCounterGroup.java
@@ -26,56 +26,56 @@ import org.junit.Test;
*/
public class TestCounterGroup {
- /**
- * CounterGroup initialization
- */
- @Test
- public void testInitialization() {
- CounterGroup cg = new CounterGroup("sqoop");
- Assert.assertEquals("sqoop", cg.getName());
- Assert.assertFalse(cg.iterator().hasNext());
-
- Counter c1 = new Counter("counter");
- cg.addCounter(c1);
- }
-
- /**
- * Test for add and get counter
- */
- @Test
- public void testAddGetCounter() {
- CounterGroup cg = new CounterGroup("sqoop");
- Counter c1 = new Counter("counter");
- cg.addCounter(c1);
- Assert.assertNotNull(cg.getCounter("counter"));
- Assert.assertNull(cg.getCounter("NA"));
- }
-
- /**
- * Test for iterator
- */
- @Test
- public void testIterator() {
- CounterGroup cg = new CounterGroup("sqoop");
- Counter c1 = new Counter("counter1");
- Counter c2 = new Counter("counter2");
- // Adding 2 Counter into CounterGroup
- cg.addCounter(c1);
- cg.addCounter(c2);
- int count = 0;
-
- for (Counter c : cg) {
- count++;
- }
- Assert.assertEquals(2, count);
-
- Counter c3 = new Counter("counter3");
- cg.addCounter(c3);
- count = 0;
-
- for (Counter c : cg) {
- count++;
- }
- Assert.assertEquals(3, count);
- }
+// /**
+// * CounterGroup initialization
+// */
+// @Test
+// public void testInitialization() {
+// CounterGroup cg = new CounterGroup("sqoop");
+// Assert.assertEquals("sqoop", cg.getName());
+// Assert.assertFalse(cg.iterator().hasNext());
+//
+// Counter c1 = new Counter("counter");
+// cg.addCounter(c1);
+// }
+//
+// /**
+// * Test for add and get counter
+// */
+// @Test
+// public void testAddGetCounter() {
+// CounterGroup cg = new CounterGroup("sqoop");
+// Counter c1 = new Counter("counter");
+// cg.addCounter(c1);
+// Assert.assertNotNull(cg.getCounter("counter"));
+// Assert.assertNull(cg.getCounter("NA"));
+// }
+//
+// /**
+// * Test for iterator
+// */
+// @Test
+// public void testIterator() {
+// CounterGroup cg = new CounterGroup("sqoop");
+// Counter c1 = new Counter("counter1");
+// Counter c2 = new Counter("counter2");
+// // Adding 2 Counter into CounterGroup
+// cg.addCounter(c1);
+// cg.addCounter(c2);
+// int count = 0;
+//
+// for (Counter c : cg) {
+// count++;
+// }
+// Assert.assertEquals(2, count);
+//
+// Counter c3 = new Counter("counter3");
+// cg.addCounter(c3);
+// count = 0;
+//
+// for (Counter c : cg) {
+// count++;
+// }
+// Assert.assertEquals(3, count);
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/common/src/test/java/org/apache/sqoop/submission/counter/TestCounters.java
----------------------------------------------------------------------
diff --git a/common/src/test/java/org/apache/sqoop/submission/counter/TestCounters.java b/common/src/test/java/org/apache/sqoop/submission/counter/TestCounters.java
index 8f8d617..22839c9 100644
--- a/common/src/test/java/org/apache/sqoop/submission/counter/TestCounters.java
+++ b/common/src/test/java/org/apache/sqoop/submission/counter/TestCounters.java
@@ -26,42 +26,42 @@ import junit.framework.Assert;
*/
public class TestCounters {
- /**
- * Test initialization
- */
- @Test
- public void testInitialization() {
- Counters counters = new Counters();
- Assert.assertTrue(counters.isEmpty());
- }
-
- /**
- * Test add and get CountersGroup
- */
- @Test
- public void testAddGetCounters() {
- Counters counters = new Counters();
- CounterGroup cg = new CounterGroup("sqoop");
- counters.addCounterGroup(cg);
- Assert.assertFalse(counters.isEmpty());
- Assert.assertNotNull(counters.getCounterGroup("sqoop"));
- Assert.assertEquals("sqoop", counters.getCounterGroup("sqoop").getName());
- }
-
- /**
- * Test for iterator
- */
- @Test
- public void testIterator() {
- Counters counters = new Counters();
- CounterGroup cg1 = new CounterGroup("sqoop1");
- CounterGroup cg2 = new CounterGroup("sqoop2");
- counters.addCounterGroup(cg1);
- counters.addCounterGroup(cg2);
- int count = 0;
- for (CounterGroup cg : counters) {
- count++;
- }
- Assert.assertEquals(2, count);
- }
+// /**
+// * Test initialization
+// */
+// @Test
+// public void testInitialization() {
+// Counters counters = new Counters();
+// Assert.assertTrue(counters.isEmpty());
+// }
+//
+// /**
+// * Test add and get CountersGroup
+// */
+// @Test
+// public void testAddGetCounters() {
+// Counters counters = new Counters();
+// CounterGroup cg = new CounterGroup("sqoop");
+// counters.addCounterGroup(cg);
+// Assert.assertFalse(counters.isEmpty());
+// Assert.assertNotNull(counters.getCounterGroup("sqoop"));
+// Assert.assertEquals("sqoop", counters.getCounterGroup("sqoop").getName());
+// }
+//
+// /**
+// * Test for iterator
+// */
+// @Test
+// public void testIterator() {
+// Counters counters = new Counters();
+// CounterGroup cg1 = new CounterGroup("sqoop1");
+// CounterGroup cg2 = new CounterGroup("sqoop2");
+// counters.addCounterGroup(cg1);
+// counters.addCounterGroup(cg2);
+// int count = 0;
+// for (CounterGroup cg : counters) {
+// count++;
+// }
+// Assert.assertEquals(2, count);
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/common/src/test/java/org/apache/sqoop/utils/TestClassUtils.java
----------------------------------------------------------------------
diff --git a/common/src/test/java/org/apache/sqoop/utils/TestClassUtils.java b/common/src/test/java/org/apache/sqoop/utils/TestClassUtils.java
index a5c4e69..aad5eff 100644
--- a/common/src/test/java/org/apache/sqoop/utils/TestClassUtils.java
+++ b/common/src/test/java/org/apache/sqoop/utils/TestClassUtils.java
@@ -24,76 +24,76 @@ import junit.framework.TestCase;
*/
public class TestClassUtils extends TestCase {
- public void testLoadClass() {
- assertNull(ClassUtils.loadClass("A"));
- assertEquals(A.class, ClassUtils.loadClass(A.class.getName()));
- }
-
- public void testInstantiateNull() {
- assertNull(ClassUtils.instantiate((Class) null));
- }
-
- public void testInstantiate() {
- A a = (A) ClassUtils.instantiate(A.class, "a");
- assertNotNull(a);
- assertEquals(1, a.num);
- assertEquals("a", a.a);
-
- A b = (A) ClassUtils.instantiate(A.class, "b", 3, 5);
- assertNotNull(b);
- assertEquals(3, b.num);
- assertEquals("b", b.a);
- assertEquals(3, b.b);
- assertEquals(5, b.c);
- }
-
- public static class A {
- String a;
- int b;
- int c;
- int num;
-
- public A(String a) {
- num = 1;
- this.a = a;
- }
- public A(String a, Integer b, Integer c) {
- this(a);
-
- num = 3;
- this.b = b;
- this.c = c;
- }
- }
-
- public void testGetEnumStrings() {
- assertNull(ClassUtils.getEnumStrings(A.class));
-
- assertEquals(
- new String[] {"A", "B", "C"},
- ClassUtils.getEnumStrings(EnumA.class)
- );
- assertEquals(
- new String[] {"X", "Y"},
- ClassUtils.getEnumStrings(EnumX.class)
- );
- }
-
- enum EnumX {
- X, Y
- }
-
- enum EnumA {
- A, B, C
- }
-
- public void assertEquals(String[] expected, String[] actual) {
- assertEquals("Arrays do not have same length", expected.length, actual.length);
-
- for(int i = 0; i < expected.length; i++) {
- assertEquals("Items on position " + i + " differs, expected "
- + expected[i] + ", actual " + actual[i],
- expected[i], actual[i]);
- }
- }
+// public void testLoadClass() {
+// assertNull(ClassUtils.loadClass("A"));
+// assertEquals(A.class, ClassUtils.loadClass(A.class.getName()));
+// }
+//
+// public void testInstantiateNull() {
+// assertNull(ClassUtils.instantiate((Class) null));
+// }
+//
+// public void testInstantiate() {
+// A a = (A) ClassUtils.instantiate(A.class, "a");
+// assertNotNull(a);
+// assertEquals(1, a.num);
+// assertEquals("a", a.a);
+//
+// A b = (A) ClassUtils.instantiate(A.class, "b", 3, 5);
+// assertNotNull(b);
+// assertEquals(3, b.num);
+// assertEquals("b", b.a);
+// assertEquals(3, b.b);
+// assertEquals(5, b.c);
+// }
+//
+// public static class A {
+// String a;
+// int b;
+// int c;
+// int num;
+//
+// public A(String a) {
+// num = 1;
+// this.a = a;
+// }
+// public A(String a, Integer b, Integer c) {
+// this(a);
+//
+// num = 3;
+// this.b = b;
+// this.c = c;
+// }
+// }
+//
+// public void testGetEnumStrings() {
+// assertNull(ClassUtils.getEnumStrings(A.class));
+//
+// assertEquals(
+// new String[] {"A", "B", "C"},
+// ClassUtils.getEnumStrings(EnumA.class)
+// );
+// assertEquals(
+// new String[] {"X", "Y"},
+// ClassUtils.getEnumStrings(EnumX.class)
+// );
+// }
+//
+// enum EnumX {
+// X, Y
+// }
+//
+// enum EnumA {
+// A, B, C
+// }
+//
+// public void assertEquals(String[] expected, String[] actual) {
+// assertEquals("Arrays do not have same length", expected.length, actual.length);
+//
+// for(int i = 0; i < expected.length; i++) {
+// assertEquals("Items on position " + i + " differs, expected "
+// + expected[i] + ", actual " + actual[i],
+// expected[i], actual[i]);
+// }
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/common/src/test/java/org/apache/sqoop/utils/TestMapResourceBundle.java
----------------------------------------------------------------------
diff --git a/common/src/test/java/org/apache/sqoop/utils/TestMapResourceBundle.java b/common/src/test/java/org/apache/sqoop/utils/TestMapResourceBundle.java
index 1edc404..88fe058 100644
--- a/common/src/test/java/org/apache/sqoop/utils/TestMapResourceBundle.java
+++ b/common/src/test/java/org/apache/sqoop/utils/TestMapResourceBundle.java
@@ -28,14 +28,14 @@ import static org.junit.Assert.*;
*
*/
public class TestMapResourceBundle {
- @Test
- public void testUsage() {
- Map<String, Object> map = new HashMap<String, Object>();
- map.put("a", "1");
- map.put("b", "2");
-
- MapResourceBundle bundle = new MapResourceBundle(map);
- assertEquals("1", bundle.getString("a"));
- assertEquals("2", bundle.getString("b"));
- }
+// @Test
+// public void testUsage() {
+// Map<String, Object> map = new HashMap<String, Object>();
+// map.put("a", "1");
+// map.put("b", "2");
+//
+// MapResourceBundle bundle = new MapResourceBundle(map);
+// assertEquals("1", bundle.getString("a"));
+// assertEquals("2", bundle.getString("b"));
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/common/src/test/java/org/apache/sqoop/validation/TestStatus.java
----------------------------------------------------------------------
diff --git a/common/src/test/java/org/apache/sqoop/validation/TestStatus.java b/common/src/test/java/org/apache/sqoop/validation/TestStatus.java
index 5b17a4e..654a024 100644
--- a/common/src/test/java/org/apache/sqoop/validation/TestStatus.java
+++ b/common/src/test/java/org/apache/sqoop/validation/TestStatus.java
@@ -25,29 +25,29 @@ import static junit.framework.Assert.*;
*
*/
public class TestStatus {
- @Test
- public void testGetWorstStatus() {
- // Comparing itself with itself
- assertEquals(Status.FINE,
- Status.getWorstStatus(Status.FINE));
- assertEquals(Status.FINE,
- Status.getWorstStatus(Status.FINE, Status.FINE));
- assertEquals(Status.ACCEPTABLE,
- Status.getWorstStatus(Status.ACCEPTABLE, Status.ACCEPTABLE));
- assertEquals(Status.UNACCEPTABLE,
- Status.getWorstStatus(Status.UNACCEPTABLE, Status.UNACCEPTABLE));
-
- // Retriving the worst option
- assertEquals(Status.UNACCEPTABLE,
- Status.getWorstStatus(Status.FINE, Status.UNACCEPTABLE));
- assertEquals(Status.ACCEPTABLE,
- Status.getWorstStatus(Status.FINE, Status.ACCEPTABLE));
- }
-
- @Test
- public void testCanProceed() {
- assertTrue(Status.FINE.canProceed());
- assertTrue(Status.ACCEPTABLE.canProceed());
- assertFalse(Status.UNACCEPTABLE.canProceed());
- }
+// @Test
+// public void testGetWorstStatus() {
+// // Comparing itself with itself
+// assertEquals(Status.FINE,
+// Status.getWorstStatus(Status.FINE));
+// assertEquals(Status.FINE,
+// Status.getWorstStatus(Status.FINE, Status.FINE));
+// assertEquals(Status.ACCEPTABLE,
+// Status.getWorstStatus(Status.ACCEPTABLE, Status.ACCEPTABLE));
+// assertEquals(Status.UNACCEPTABLE,
+// Status.getWorstStatus(Status.UNACCEPTABLE, Status.UNACCEPTABLE));
+//
+// // Retriving the worst option
+// assertEquals(Status.UNACCEPTABLE,
+// Status.getWorstStatus(Status.FINE, Status.UNACCEPTABLE));
+// assertEquals(Status.ACCEPTABLE,
+// Status.getWorstStatus(Status.FINE, Status.ACCEPTABLE));
+// }
+//
+// @Test
+// public void testCanProceed() {
+// assertTrue(Status.FINE.canProceed());
+// assertTrue(Status.ACCEPTABLE.canProceed());
+// assertFalse(Status.UNACCEPTABLE.canProceed());
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/common/src/test/java/org/apache/sqoop/validation/TestValidation.java
----------------------------------------------------------------------
diff --git a/common/src/test/java/org/apache/sqoop/validation/TestValidation.java b/common/src/test/java/org/apache/sqoop/validation/TestValidation.java
index bf0ade5..be6ee84 100644
--- a/common/src/test/java/org/apache/sqoop/validation/TestValidation.java
+++ b/common/src/test/java/org/apache/sqoop/validation/TestValidation.java
@@ -31,113 +31,113 @@ import org.apache.sqoop.validation.Validation.Message;
*/
public class TestValidation extends TestCase {
- /**
- * Initialization test
- */
- public void testInitialization() {
- /* Check initialization with class */
- Validation validation = new Validation(Class.class);
- assertNotNull(validation);
- assertEquals(Status.FINE, validation.getStatus());
- assertEquals(0, validation.getMessages().size());
-
- /* Check initialization with status and message as null */
- Validation validationNull = new Validation(null, null);
- assertNotNull(validationNull);
- assertNull(validationNull.getStatus());
- assertNull(validationNull.getMessages());
-
- /* Check initialization with status and message with values */
- Status s1 = Status.FINE;
- Map<FormInput, Message> msg1 = new HashMap<Validation.FormInput, Validation.Message>();
- Validation validation1 = new Validation(s1, msg1);
- assertNotNull(validation1);
- assertEquals(Status.FINE, validation1.getStatus());
- assertEquals(0, validation1.getMessages().size());
-
- /* Check initialization with status and message with values */
- Status s2 = Status.ACCEPTABLE;
- Map<FormInput, Message> msg2 = new HashMap<Validation.FormInput, Validation.Message>();
- Validation validation2 = new Validation(s2, msg2);
- assertNotNull(validation2);
- assertEquals(Status.ACCEPTABLE, validation2.getStatus());
- assertEquals(0, validation2.getMessages().size());
-
- /* Check initialization with status and message with values */
- Status s3 = Status.ACCEPTABLE;
- Map<FormInput, Message> msg3 = new HashMap<Validation.FormInput, Validation.Message>();
- Validation.FormInput fi = new Validation.FormInput("form\\.input");
- Validation.Message message = new Validation.Message(Status.FINE, "sqoop");
- msg3.put(fi, message);
- Validation validation3 = new Validation(s3, msg3);
- Validation.FormInput fiTest = new Validation.FormInput("form\\.input");
- Validation.Message messageTest = new Validation.Message(Status.FINE,
- "sqoop");
- assertEquals(messageTest, validation3.getMessages().get(fiTest));
- assertEquals(Status.ACCEPTABLE, validation3.getStatus());
- }
-
- /**
- * Test for Validation.ForInput
- */
- public void testFormInput() {
- Validation.FormInput fi = new Validation.FormInput("test\\.test");
- assertNotNull(fi);
-
- /* Passing null */
- try {
- new Validation.FormInput(null);
- fail("Assert error is expected");
- } catch (AssertionError e) {
- assertTrue(true);
- }
-
- /* Passing empty and check exception messages */
- try {
- new Validation.FormInput("");
- fail("SqoopException is expected");
- } catch (SqoopException e) {
- assertEquals(ValidationError.VALIDATION_0003.getMessage(), e
- .getErrorCode().getMessage());
- }
-
- /* Passing value and check */
- Validation.FormInput fi2 = new Validation.FormInput("form\\.input");
- assertEquals("form\\", fi2.getForm());
- assertEquals("input", fi2.getInput());
-
- /* Check equals */
- Validation.FormInput fiOne = new Validation.FormInput("form\\.input");
- Validation.FormInput fiTwo = new Validation.FormInput("form\\.input");
- assertEquals(fiOne, fiTwo);
-
- /* toString() method check */
- assertEquals("form\\.input", fiOne.toString());
-
- // Checking null as input field (form validation)
- Validation.FormInput fi3 = new FormInput("form");
- assertEquals("form", fi3.getForm());
- assertNull(fi3.getInput());
- assertEquals("form", fi3.toString());
-
- }
-
- /**
- * Test for Validation.Message
- */
- public void testMessage() {
- /* Passing null */
- Validation.Message msg1 = new Validation.Message(null, null);
- assertNull(msg1.getStatus());
- assertNull(msg1.getMessage());
-
- /* Passing values */
- Validation.Message msg2 = new Validation.Message(Status.FINE, "sqoop");
- assertEquals(Status.FINE, msg2.getStatus());
- assertEquals("sqoop", msg2.getMessage());
-
- /* Check for equal */
- Validation.Message msg3 = new Validation.Message(Status.FINE, "sqoop");
- assertEquals(msg2, msg3);
- }
+// /**
+// * Initialization test
+// */
+// public void testInitialization() {
+// /* Check initialization with class */
+// Validation validation = new Validation(Class.class);
+// assertNotNull(validation);
+// assertEquals(Status.FINE, validation.getStatus());
+// assertEquals(0, validation.getMessages().size());
+//
+// /* Check initialization with status and message as null */
+// Validation validationNull = new Validation(null, null);
+// assertNotNull(validationNull);
+// assertNull(validationNull.getStatus());
+// assertNull(validationNull.getMessages());
+//
+// /* Check initialization with status and message with values */
+// Status s1 = Status.FINE;
+// Map<FormInput, Message> msg1 = new HashMap<Validation.FormInput, Validation.Message>();
+// Validation validation1 = new Validation(s1, msg1);
+// assertNotNull(validation1);
+// assertEquals(Status.FINE, validation1.getStatus());
+// assertEquals(0, validation1.getMessages().size());
+//
+// /* Check initialization with status and message with values */
+// Status s2 = Status.ACCEPTABLE;
+// Map<FormInput, Message> msg2 = new HashMap<Validation.FormInput, Validation.Message>();
+// Validation validation2 = new Validation(s2, msg2);
+// assertNotNull(validation2);
+// assertEquals(Status.ACCEPTABLE, validation2.getStatus());
+// assertEquals(0, validation2.getMessages().size());
+//
+// /* Check initialization with status and message with values */
+// Status s3 = Status.ACCEPTABLE;
+// Map<FormInput, Message> msg3 = new HashMap<Validation.FormInput, Validation.Message>();
+// Validation.FormInput fi = new Validation.FormInput("form\\.input");
+// Validation.Message message = new Validation.Message(Status.FINE, "sqoop");
+// msg3.put(fi, message);
+// Validation validation3 = new Validation(s3, msg3);
+// Validation.FormInput fiTest = new Validation.FormInput("form\\.input");
+// Validation.Message messageTest = new Validation.Message(Status.FINE,
+// "sqoop");
+// assertEquals(messageTest, validation3.getMessages().get(fiTest));
+// assertEquals(Status.ACCEPTABLE, validation3.getStatus());
+// }
+//
+// /**
+// * Test for Validation.ForInput
+// */
+// public void testFormInput() {
+// Validation.FormInput fi = new Validation.FormInput("test\\.test");
+// assertNotNull(fi);
+//
+// /* Passing null */
+// try {
+// new Validation.FormInput(null);
+// fail("Assert error is expected");
+// } catch (AssertionError e) {
+// assertTrue(true);
+// }
+//
+// /* Passing empty and check exception messages */
+// try {
+// new Validation.FormInput("");
+// fail("SqoopException is expected");
+// } catch (SqoopException e) {
+// assertEquals(ValidationError.VALIDATION_0003.getMessage(), e
+// .getErrorCode().getMessage());
+// }
+//
+// /* Passing value and check */
+// Validation.FormInput fi2 = new Validation.FormInput("form\\.input");
+// assertEquals("form\\", fi2.getForm());
+// assertEquals("input", fi2.getInput());
+//
+// /* Check equals */
+// Validation.FormInput fiOne = new Validation.FormInput("form\\.input");
+// Validation.FormInput fiTwo = new Validation.FormInput("form\\.input");
+// assertEquals(fiOne, fiTwo);
+//
+// /* toString() method check */
+// assertEquals("form\\.input", fiOne.toString());
+//
+// // Checking null as input field (form validation)
+// Validation.FormInput fi3 = new FormInput("form");
+// assertEquals("form", fi3.getForm());
+// assertNull(fi3.getInput());
+// assertEquals("form", fi3.toString());
+//
+// }
+//
+// /**
+// * Test for Validation.Message
+// */
+// public void testMessage() {
+// /* Passing null */
+// Validation.Message msg1 = new Validation.Message(null, null);
+// assertNull(msg1.getStatus());
+// assertNull(msg1.getMessage());
+//
+// /* Passing values */
+// Validation.Message msg2 = new Validation.Message(Status.FINE, "sqoop");
+// assertEquals(Status.FINE, msg2.getStatus());
+// assertEquals("sqoop", msg2.getMessage());
+//
+// /* Check for equal */
+// Validation.Message msg3 = new Validation.Message(Status.FINE, "sqoop");
+// assertEquals(msg2, msg3);
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutorTest.java
----------------------------------------------------------------------
diff --git a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutorTest.java b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutorTest.java
index e10a5b4..26ceccd 100644
--- a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutorTest.java
+++ b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutorTest.java
@@ -20,69 +20,69 @@ package org.apache.sqoop.connector.jdbc;
import junit.framework.TestCase;
public class GenericJdbcExecutorTest extends TestCase {
- private final String table;
- private final String emptyTable;
- private final GenericJdbcExecutor executor;
-
- private static final int START = -50;
- private static final int NUMBER_OF_ROWS = 974;
-
- public GenericJdbcExecutorTest() {
- table = getClass().getSimpleName().toUpperCase();
- emptyTable = table + "_EMPTY";
- executor = new GenericJdbcExecutor(GenericJdbcTestConstants.DRIVER,
- GenericJdbcTestConstants.URL, null, null);
- }
-
- @Override
- public void setUp() {
- if(executor.existTable(emptyTable)) {
- executor.executeUpdate("DROP TABLE " + emptyTable);
- }
- executor.executeUpdate("CREATE TABLE "
- + emptyTable + "(ICOL INTEGER PRIMARY KEY, VCOL VARCHAR(20))");
-
- if(executor.existTable(table)) {
- executor.executeUpdate("DROP TABLE " + table);
- }
- executor.executeUpdate("CREATE TABLE "
- + table + "(ICOL INTEGER PRIMARY KEY, VCOL VARCHAR(20))");
-
- for (int i = 0; i < NUMBER_OF_ROWS; i++) {
- int value = START + i;
- String sql = "INSERT INTO " + table
- + " VALUES(" + value + ", '" + value + "')";
- executor.executeUpdate(sql);
- }
- }
-
- @SuppressWarnings("unchecked")
- public void testDeleteTableData() throws Exception {
- executor.deleteTableData(table);
- assertEquals("Table " + table + " is expected to be empty.",
- 0, executor.getTableRowCount(table));
- }
-
- @SuppressWarnings("unchecked")
- public void testMigrateData() throws Exception {
- assertEquals("Table " + emptyTable + " is expected to be empty.",
- 0, executor.getTableRowCount(emptyTable));
- assertEquals("Table " + table + " is expected to have " +
- NUMBER_OF_ROWS + " rows.", NUMBER_OF_ROWS,
- executor.getTableRowCount(table));
-
- executor.migrateData(table, emptyTable);
-
- assertEquals("Table " + table + " is expected to be empty.", 0,
- executor.getTableRowCount(table));
- assertEquals("Table " + emptyTable + " is expected to have " +
- NUMBER_OF_ROWS + " rows.", NUMBER_OF_ROWS,
- executor.getTableRowCount(emptyTable));
- }
-
- @SuppressWarnings("unchecked")
- public void testGetTableRowCount() throws Exception {
- assertEquals("Table " + table + " is expected to be empty.",
- NUMBER_OF_ROWS, executor.getTableRowCount(table));
- }
+// private final String table;
+// private final String emptyTable;
+// private final GenericJdbcExecutor executor;
+//
+// private static final int START = -50;
+// private static final int NUMBER_OF_ROWS = 974;
+//
+// public GenericJdbcExecutorTest() {
+// table = getClass().getSimpleName().toUpperCase();
+// emptyTable = table + "_EMPTY";
+// executor = new GenericJdbcExecutor(GenericJdbcTestConstants.DRIVER,
+// GenericJdbcTestConstants.URL, null, null);
+// }
+//
+// @Override
+// public void setUp() {
+// if(executor.existTable(emptyTable)) {
+// executor.executeUpdate("DROP TABLE " + emptyTable);
+// }
+// executor.executeUpdate("CREATE TABLE "
+// + emptyTable + "(ICOL INTEGER PRIMARY KEY, VCOL VARCHAR(20))");
+//
+// if(executor.existTable(table)) {
+// executor.executeUpdate("DROP TABLE " + table);
+// }
+// executor.executeUpdate("CREATE TABLE "
+// + table + "(ICOL INTEGER PRIMARY KEY, VCOL VARCHAR(20))");
+//
+// for (int i = 0; i < NUMBER_OF_ROWS; i++) {
+// int value = START + i;
+// String sql = "INSERT INTO " + table
+// + " VALUES(" + value + ", '" + value + "')";
+// executor.executeUpdate(sql);
+// }
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testDeleteTableData() throws Exception {
+// executor.deleteTableData(table);
+// assertEquals("Table " + table + " is expected to be empty.",
+// 0, executor.getTableRowCount(table));
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testMigrateData() throws Exception {
+// assertEquals("Table " + emptyTable + " is expected to be empty.",
+// 0, executor.getTableRowCount(emptyTable));
+// assertEquals("Table " + table + " is expected to have " +
+// NUMBER_OF_ROWS + " rows.", NUMBER_OF_ROWS,
+// executor.getTableRowCount(table));
+//
+// executor.migrateData(table, emptyTable);
+//
+// assertEquals("Table " + table + " is expected to be empty.", 0,
+// executor.getTableRowCount(table));
+// assertEquals("Table " + emptyTable + " is expected to have " +
+// NUMBER_OF_ROWS + " rows.", NUMBER_OF_ROWS,
+// executor.getTableRowCount(emptyTable));
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testGetTableRowCount() throws Exception {
+// assertEquals("Table " + table + " is expected to be empty.",
+// NUMBER_OF_ROWS, executor.getTableRowCount(table));
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportInitializer.java
----------------------------------------------------------------------
diff --git a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportInitializer.java b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportInitializer.java
index d55b0f1..3c5ca39 100644
--- a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportInitializer.java
+++ b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportInitializer.java
@@ -31,335 +31,335 @@ import org.apache.sqoop.validation.Validation;
public class TestExportInitializer extends TestCase {
- private final String schemaName;
- private final String tableName;
- private final String schemalessTableName;
- private final String stageTableName;
- private final String tableSql;
- private final String schemalessTableSql;
- private final String tableColumns;
-
- private GenericJdbcExecutor executor;
-
- public TestExportInitializer() {
- schemaName = getClass().getSimpleName().toUpperCase() + "SCHEMA";
- tableName = getClass().getSimpleName().toUpperCase() + "TABLEWITHSCHEMA";
- schemalessTableName = getClass().getSimpleName().toUpperCase() + "TABLE";
- stageTableName = getClass().getSimpleName().toUpperCase() +
- "_STAGE_TABLE";
- tableSql = "INSERT INTO " + tableName + " VALUES (?,?,?)";
- schemalessTableSql = "INSERT INTO " + schemalessTableName + " VALUES (?,?,?)";
- tableColumns = "ICOL,VCOL";
- }
-
- @Override
- public void setUp() {
- executor = new GenericJdbcExecutor(GenericJdbcTestConstants.DRIVER,
- GenericJdbcTestConstants.URL, null, null);
-
- String fullTableName = executor.delimitIdentifier(schemaName) + "." + executor.delimitIdentifier(tableName);
- if (!executor.existTable(tableName)) {
- executor.executeUpdate("CREATE SCHEMA " + executor.delimitIdentifier(schemaName));
- executor.executeUpdate("CREATE TABLE " + fullTableName + "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
- }
-
- fullTableName = executor.delimitIdentifier(schemalessTableName);
- if (!executor.existTable(schemalessTableName)) {
- executor.executeUpdate("CREATE TABLE " + fullTableName + "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
- }
- }
-
- @Override
- public void tearDown() {
- executor.close();
- }
-
- @SuppressWarnings("unchecked")
- public void testTableName() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- String fullTableName = executor.delimitIdentifier(schemalessTableName);
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.tableName = schemalessTableName;
-
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- initializer.initialize(initializerContext, connConf, jobConf);
-
- verifyResult(context, "INSERT INTO " + fullTableName + " VALUES (?,?,?)");
- }
-
- @SuppressWarnings("unchecked")
- public void testTableNameWithTableColumns() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- String fullTableName = executor.delimitIdentifier(schemalessTableName);
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.tableName = schemalessTableName;
- jobConf.table.columns = tableColumns;
-
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- initializer.initialize(initializerContext, connConf, jobConf);
-
- verifyResult(context, "INSERT INTO " + fullTableName + " (" + tableColumns + ") VALUES (?,?)");
- }
-
- @SuppressWarnings("unchecked")
- public void testTableSql() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.sql = schemalessTableSql;
-
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- initializer.initialize(initializerContext, connConf, jobConf);
-
- verifyResult(context, "INSERT INTO " + executor.delimitIdentifier(schemalessTableName) + " VALUES (?,?,?)");
- }
-
- @SuppressWarnings("unchecked")
- public void testTableNameWithSchema() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- String fullTableName = executor.delimitIdentifier(schemaName) + "." + executor.delimitIdentifier(tableName);
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.schemaName = schemaName;
- jobConf.table.tableName = tableName;
-
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- initializer.initialize(initializerContext, connConf, jobConf);
-
- verifyResult(context, "INSERT INTO " + fullTableName + " VALUES (?,?,?)");
- }
-
- @SuppressWarnings("unchecked")
- public void testTableNameWithTableColumnsWithSchema() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- String fullTableName = executor.delimitIdentifier(schemaName) + "." + executor.delimitIdentifier(tableName);
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.schemaName = schemaName;
- jobConf.table.tableName = tableName;
- jobConf.table.columns = tableColumns;
-
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- initializer.initialize(initializerContext, connConf, jobConf);
-
- verifyResult(context, "INSERT INTO " + fullTableName + " (" + tableColumns + ") VALUES (?,?)");
- }
-
- @SuppressWarnings("unchecked")
- public void testTableSqlWithSchema() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.schemaName = schemaName;
- jobConf.table.sql = tableSql;
-
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- initializer.initialize(initializerContext, connConf, jobConf);
-
- verifyResult(context, "INSERT INTO " + executor.delimitIdentifier(tableName) + " VALUES (?,?,?)");
- }
-
- private void verifyResult(MutableContext context, String dataSql) {
- assertEquals(dataSql, context.getString(
- GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL));
- }
-
- private void createTable(String tableName) {
- try {
- executor.executeUpdate("DROP TABLE " + tableName);
- } catch(SqoopException e) {
- //Ok to fail as the table might not exist
- }
- executor.executeUpdate("CREATE TABLE " + tableName +
- "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
- }
-
- public void testNonExistingStageTable() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.tableName = schemalessTableName;
- jobConf.table.stageTableName = stageTableName;
-
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- try {
- initializer.initialize(initializerContext, connConf, jobConf);
- fail("Initialization should fail for non-existing stage table.");
- } catch(SqoopException se) {
- //expected
- }
- }
-
- @SuppressWarnings("unchecked")
- public void testNonEmptyStageTable() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- String fullStageTableName = executor.delimitIdentifier(stageTableName);
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.tableName = schemalessTableName;
- jobConf.table.stageTableName = stageTableName;
- createTable(fullStageTableName);
- executor.executeUpdate("INSERT INTO " + fullStageTableName +
- " VALUES(1, 1.1, 'one')");
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- try {
- initializer.initialize(initializerContext, connConf, jobConf);
- fail("Initialization should fail for non-empty stage table.");
- } catch(SqoopException se) {
- //expected
- }
- }
-
- @SuppressWarnings("unchecked")
- public void testClearStageTableValidation() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- //specifying clear stage table flag without specifying name of
- // the stage table
- jobConf.table.tableName = schemalessTableName;
- jobConf.table.clearStageTable = false;
- GenericJdbcValidator validator = new GenericJdbcValidator();
- Validation validation = validator.validateJob(MJob.Type.EXPORT, jobConf);
- assertEquals("User should not specify clear stage table flag without " +
- "specifying name of the stage table",
- Status.UNACCEPTABLE,
- validation.getStatus());
- assertTrue(validation.getMessages().containsKey(
- new Validation.FormInput("table")));
-
- jobConf.table.clearStageTable = true;
- validation = validator.validateJob(MJob.Type.EXPORT, jobConf);
- assertEquals("User should not specify clear stage table flag without " +
- "specifying name of the stage table",
- Status.UNACCEPTABLE,
- validation.getStatus());
- assertTrue(validation.getMessages().containsKey(
- new Validation.FormInput("table")));
- }
-
- @SuppressWarnings("unchecked")
- public void testStageTableWithoutTable() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- //specifying stage table without specifying table name
- jobConf.table.stageTableName = stageTableName;
- jobConf.table.sql = "";
-
- GenericJdbcValidator validator = new GenericJdbcValidator();
- Validation validation = validator.validateJob(MJob.Type.EXPORT, jobConf);
- assertEquals("Stage table name cannot be specified without specifying " +
- "table name", Status.UNACCEPTABLE, validation.getStatus());
- assertTrue(validation.getMessages().containsKey(
- new Validation.FormInput("table")));
- }
-
- @SuppressWarnings("unchecked")
- public void testClearStageTable() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- String fullStageTableName = executor.delimitIdentifier(stageTableName);
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.tableName = schemalessTableName;
- jobConf.table.stageTableName = stageTableName;
- jobConf.table.clearStageTable = true;
- createTable(fullStageTableName);
- executor.executeUpdate("INSERT INTO " + fullStageTableName +
- " VALUES(1, 1.1, 'one')");
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- initializer.initialize(initializerContext, connConf, jobConf);
- assertEquals("Stage table should have been cleared", 0,
- executor.getTableRowCount(stageTableName));
- }
-
- @SuppressWarnings("unchecked")
- public void testStageTable() throws Exception {
- ConnectionConfiguration connConf = new ConnectionConfiguration();
- ExportJobConfiguration jobConf = new ExportJobConfiguration();
-
- String fullStageTableName = executor.delimitIdentifier(stageTableName);
-
- connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connConf.connection.connectionString = GenericJdbcTestConstants.URL;
- jobConf.table.tableName = schemalessTableName;
- jobConf.table.stageTableName = stageTableName;
- createTable(fullStageTableName);
- MutableContext context = new MutableMapContext();
- InitializerContext initializerContext = new InitializerContext(context);
-
- @SuppressWarnings("rawtypes")
- Initializer initializer = new GenericJdbcExportInitializer();
- initializer.initialize(initializerContext, connConf, jobConf);
-
- verifyResult(context, "INSERT INTO " + fullStageTableName +
- " VALUES (?,?,?)");
- }
+// private final String schemaName;
+// private final String tableName;
+// private final String schemalessTableName;
+// private final String stageTableName;
+// private final String tableSql;
+// private final String schemalessTableSql;
+// private final String tableColumns;
+//
+// private GenericJdbcExecutor executor;
+//
+// public TestExportInitializer() {
+// schemaName = getClass().getSimpleName().toUpperCase() + "SCHEMA";
+// tableName = getClass().getSimpleName().toUpperCase() + "TABLEWITHSCHEMA";
+// schemalessTableName = getClass().getSimpleName().toUpperCase() + "TABLE";
+// stageTableName = getClass().getSimpleName().toUpperCase() +
+// "_STAGE_TABLE";
+// tableSql = "INSERT INTO " + tableName + " VALUES (?,?,?)";
+// schemalessTableSql = "INSERT INTO " + schemalessTableName + " VALUES (?,?,?)";
+// tableColumns = "ICOL,VCOL";
+// }
+//
+// @Override
+// public void setUp() {
+// executor = new GenericJdbcExecutor(GenericJdbcTestConstants.DRIVER,
+// GenericJdbcTestConstants.URL, null, null);
+//
+// String fullTableName = executor.delimitIdentifier(schemaName) + "." + executor.delimitIdentifier(tableName);
+// if (!executor.existTable(tableName)) {
+// executor.executeUpdate("CREATE SCHEMA " + executor.delimitIdentifier(schemaName));
+// executor.executeUpdate("CREATE TABLE " + fullTableName + "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
+// }
+//
+// fullTableName = executor.delimitIdentifier(schemalessTableName);
+// if (!executor.existTable(schemalessTableName)) {
+// executor.executeUpdate("CREATE TABLE " + fullTableName + "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
+// }
+// }
+//
+// @Override
+// public void tearDown() {
+// executor.close();
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testTableName() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// String fullTableName = executor.delimitIdentifier(schemalessTableName);
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.tableName = schemalessTableName;
+//
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// initializer.initialize(initializerContext, connConf, jobConf);
+//
+// verifyResult(context, "INSERT INTO " + fullTableName + " VALUES (?,?,?)");
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testTableNameWithTableColumns() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// String fullTableName = executor.delimitIdentifier(schemalessTableName);
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.tableName = schemalessTableName;
+// jobConf.table.columns = tableColumns;
+//
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// initializer.initialize(initializerContext, connConf, jobConf);
+//
+// verifyResult(context, "INSERT INTO " + fullTableName + " (" + tableColumns + ") VALUES (?,?)");
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testTableSql() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.sql = schemalessTableSql;
+//
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// initializer.initialize(initializerContext, connConf, jobConf);
+//
+// verifyResult(context, "INSERT INTO " + executor.delimitIdentifier(schemalessTableName) + " VALUES (?,?,?)");
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testTableNameWithSchema() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// String fullTableName = executor.delimitIdentifier(schemaName) + "." + executor.delimitIdentifier(tableName);
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.schemaName = schemaName;
+// jobConf.table.tableName = tableName;
+//
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// initializer.initialize(initializerContext, connConf, jobConf);
+//
+// verifyResult(context, "INSERT INTO " + fullTableName + " VALUES (?,?,?)");
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testTableNameWithTableColumnsWithSchema() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// String fullTableName = executor.delimitIdentifier(schemaName) + "." + executor.delimitIdentifier(tableName);
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.schemaName = schemaName;
+// jobConf.table.tableName = tableName;
+// jobConf.table.columns = tableColumns;
+//
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// initializer.initialize(initializerContext, connConf, jobConf);
+//
+// verifyResult(context, "INSERT INTO " + fullTableName + " (" + tableColumns + ") VALUES (?,?)");
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testTableSqlWithSchema() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.schemaName = schemaName;
+// jobConf.table.sql = tableSql;
+//
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// initializer.initialize(initializerContext, connConf, jobConf);
+//
+// verifyResult(context, "INSERT INTO " + executor.delimitIdentifier(tableName) + " VALUES (?,?,?)");
+// }
+//
+// private void verifyResult(MutableContext context, String dataSql) {
+// assertEquals(dataSql, context.getString(
+// GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL));
+// }
+//
+// private void createTable(String tableName) {
+// try {
+// executor.executeUpdate("DROP TABLE " + tableName);
+// } catch(SqoopException e) {
+// //Ok to fail as the table might not exist
+// }
+// executor.executeUpdate("CREATE TABLE " + tableName +
+// "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
+// }
+//
+// public void testNonExistingStageTable() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.tableName = schemalessTableName;
+// jobConf.table.stageTableName = stageTableName;
+//
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// try {
+// initializer.initialize(initializerContext, connConf, jobConf);
+// fail("Initialization should fail for non-existing stage table.");
+// } catch(SqoopException se) {
+// //expected
+// }
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testNonEmptyStageTable() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// String fullStageTableName = executor.delimitIdentifier(stageTableName);
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.tableName = schemalessTableName;
+// jobConf.table.stageTableName = stageTableName;
+// createTable(fullStageTableName);
+// executor.executeUpdate("INSERT INTO " + fullStageTableName +
+// " VALUES(1, 1.1, 'one')");
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// try {
+// initializer.initialize(initializerContext, connConf, jobConf);
+// fail("Initialization should fail for non-empty stage table.");
+// } catch(SqoopException se) {
+// //expected
+// }
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testClearStageTableValidation() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// //specifying clear stage table flag without specifying name of
+// // the stage table
+// jobConf.table.tableName = schemalessTableName;
+// jobConf.table.clearStageTable = false;
+// GenericJdbcValidator validator = new GenericJdbcValidator();
+// Validation validation = validator.validateJob(MJob.Type.EXPORT, jobConf);
+// assertEquals("User should not specify clear stage table flag without " +
+// "specifying name of the stage table",
+// Status.UNACCEPTABLE,
+// validation.getStatus());
+// assertTrue(validation.getMessages().containsKey(
+// new Validation.FormInput("table")));
+//
+// jobConf.table.clearStageTable = true;
+// validation = validator.validateJob(MJob.Type.EXPORT, jobConf);
+// assertEquals("User should not specify clear stage table flag without " +
+// "specifying name of the stage table",
+// Status.UNACCEPTABLE,
+// validation.getStatus());
+// assertTrue(validation.getMessages().containsKey(
+// new Validation.FormInput("table")));
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testStageTableWithoutTable() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// //specifying stage table without specifying table name
+// jobConf.table.stageTableName = stageTableName;
+// jobConf.table.sql = "";
+//
+// GenericJdbcValidator validator = new GenericJdbcValidator();
+// Validation validation = validator.validateJob(MJob.Type.EXPORT, jobConf);
+// assertEquals("Stage table name cannot be specified without specifying " +
+// "table name", Status.UNACCEPTABLE, validation.getStatus());
+// assertTrue(validation.getMessages().containsKey(
+// new Validation.FormInput("table")));
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testClearStageTable() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// String fullStageTableName = executor.delimitIdentifier(stageTableName);
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.tableName = schemalessTableName;
+// jobConf.table.stageTableName = stageTableName;
+// jobConf.table.clearStageTable = true;
+// createTable(fullStageTableName);
+// executor.executeUpdate("INSERT INTO " + fullStageTableName +
+// " VALUES(1, 1.1, 'one')");
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// initializer.initialize(initializerContext, connConf, jobConf);
+// assertEquals("Stage table should have been cleared", 0,
+// executor.getTableRowCount(stageTableName));
+// }
+//
+// @SuppressWarnings("unchecked")
+// public void testStageTable() throws Exception {
+// ConnectionConfiguration connConf = new ConnectionConfiguration();
+// ExportJobConfiguration jobConf = new ExportJobConfiguration();
+//
+// String fullStageTableName = executor.delimitIdentifier(stageTableName);
+//
+// connConf.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connConf.connection.connectionString = GenericJdbcTestConstants.URL;
+// jobConf.table.tableName = schemalessTableName;
+// jobConf.table.stageTableName = stageTableName;
+// createTable(fullStageTableName);
+// MutableContext context = new MutableMapContext();
+// InitializerContext initializerContext = new InitializerContext(context);
+//
+// @SuppressWarnings("rawtypes")
+// Initializer initializer = new GenericJdbcExportInitializer();
+// initializer.initialize(initializerContext, connConf, jobConf);
+//
+// verifyResult(context, "INSERT INTO " + fullStageTableName +
+// " VALUES (?,?,?)");
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportLoader.java
----------------------------------------------------------------------
diff --git a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportLoader.java b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportLoader.java
index fc3ddd0..5b7a1e3 100644
--- a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportLoader.java
+++ b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportLoader.java
@@ -41,103 +41,103 @@ import org.junit.runners.Parameterized.Parameters;
@RunWith(Parameterized.class)
public class TestExportLoader {
- private final String tableName;
-
- private GenericJdbcExecutor executor;
-
- private static final int START = -50;
-
- private int numberOfRows;
-
- @Parameters
- public static Collection<Object[]> data() {
- return Arrays.asList(new Object[][] {{50}, {100}, {101}, {150}, {200}});
- }
-
- public TestExportLoader(int numberOfRows) {
- this.numberOfRows = numberOfRows;
- tableName = getClass().getSimpleName().toUpperCase();
- }
-
- @Before
- public void setUp() {
- executor = new GenericJdbcExecutor(GenericJdbcTestConstants.DRIVER,
- GenericJdbcTestConstants.URL, null, null);
-
- if (!executor.existTable(tableName)) {
- executor.executeUpdate("CREATE TABLE "
- + executor.delimitIdentifier(tableName)
- + "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
- } else {
- executor.deleteTableData(tableName);
- }
- }
-
- @After
- public void tearDown() {
- executor.close();
- }
-
- @Test
- public void testInsert() throws Exception {
- MutableContext context = new MutableMapContext();
-
- ConnectionConfiguration connectionConfig = new ConnectionConfiguration();
-
- connectionConfig.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connectionConfig.connection.connectionString = GenericJdbcTestConstants.URL;
-
- ExportJobConfiguration jobConfig = new ExportJobConfiguration();
-
- context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL,
- "INSERT INTO " + executor.delimitIdentifier(tableName) + " VALUES (?,?,?)");
-
- Loader loader = new GenericJdbcExportLoader();
- DummyReader reader = new DummyReader();
- LoaderContext loaderContext = new LoaderContext(context, reader, null);
- loader.load(loaderContext, connectionConfig, jobConfig);
-
- int index = START;
- ResultSet rs = executor.executeQuery("SELECT * FROM "
- + executor.delimitIdentifier(tableName) + " ORDER BY ICOL");
- while (rs.next()) {
- assertEquals(index, rs.getObject(1));
- assertEquals((double) index, rs.getObject(2));
- assertEquals(String.valueOf(index), rs.getObject(3));
- index++;
- }
- assertEquals(numberOfRows, index-START);
- }
-
- public class DummyReader extends DataReader {
- int index = 0;
-
- @Override
- public Object[] readArrayRecord() {
- if (index < numberOfRows) {
- Object[] array = new Object[] {
- START + index,
- (double) (START + index),
- String.valueOf(START+index) };
- index++;
- return array;
- } else {
- return null;
- }
- }
-
- @Override
- public String readTextRecord() {
- fail("This method should not be invoked.");
- return null;
- }
-
- @Override
- public Object readContent() throws Exception {
- fail("This method should not be invoked.");
- return null;
- }
-
- }
+// private final String tableName;
+//
+// private GenericJdbcExecutor executor;
+//
+// private static final int START = -50;
+//
+// private int numberOfRows;
+//
+// @Parameters
+// public static Collection<Object[]> data() {
+// return Arrays.asList(new Object[][] {{50}, {100}, {101}, {150}, {200}});
+// }
+//
+// public TestExportLoader(int numberOfRows) {
+// this.numberOfRows = numberOfRows;
+// tableName = getClass().getSimpleName().toUpperCase();
+// }
+//
+// @Before
+// public void setUp() {
+// executor = new GenericJdbcExecutor(GenericJdbcTestConstants.DRIVER,
+// GenericJdbcTestConstants.URL, null, null);
+//
+// if (!executor.existTable(tableName)) {
+// executor.executeUpdate("CREATE TABLE "
+// + executor.delimitIdentifier(tableName)
+// + "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
+// } else {
+// executor.deleteTableData(tableName);
+// }
+// }
+//
+// @After
+// public void tearDown() {
+// executor.close();
+// }
+//
+// @Test
+// public void testInsert() throws Exception {
+// MutableContext context = new MutableMapContext();
+//
+// ConnectionConfiguration connectionConfig = new ConnectionConfiguration();
+//
+// connectionConfig.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connectionConfig.connection.connectionString = GenericJdbcTestConstants.URL;
+//
+// ExportJobConfiguration jobConfig = new ExportJobConfiguration();
+//
+// context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL,
+// "INSERT INTO " + executor.delimitIdentifier(tableName) + " VALUES (?,?,?)");
+//
+// Loader loader = new GenericJdbcExportLoader();
+// DummyReader reader = new DummyReader();
+// LoaderContext loaderContext = new LoaderContext(context, reader, null);
+// loader.load(loaderContext, connectionConfig, jobConfig);
+//
+// int index = START;
+// ResultSet rs = executor.executeQuery("SELECT * FROM "
+// + executor.delimitIdentifier(tableName) + " ORDER BY ICOL");
+// while (rs.next()) {
+// assertEquals(index, rs.getObject(1));
+// assertEquals((double) index, rs.getObject(2));
+// assertEquals(String.valueOf(index), rs.getObject(3));
+// index++;
+// }
+// assertEquals(numberOfRows, index-START);
+// }
+//
+// public class DummyReader extends DataReader {
+// int index = 0;
+//
+// @Override
+// public Object[] readArrayRecord() {
+// if (index < numberOfRows) {
+// Object[] array = new Object[] {
+// START + index,
+// (double) (START + index),
+// String.valueOf(START+index) };
+// index++;
+// return array;
+// } else {
+// return null;
+// }
+// }
+//
+// @Override
+// public String readTextRecord() {
+// fail("This method should not be invoked.");
+// return null;
+// }
+//
+// @Override
+// public Object readContent() throws Exception {
+// fail("This method should not be invoked.");
+// return null;
+// }
+//
+// }
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/c8108266/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestImportExtractor.java
----------------------------------------------------------------------
diff --git a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestImportExtractor.java b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestImportExtractor.java
index 30d0b9a..9130375 100644
--- a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestImportExtractor.java
+++ b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestImportExtractor.java
@@ -29,132 +29,132 @@ import org.apache.sqoop.etl.io.DataWriter;
public class TestImportExtractor extends TestCase {
- private final String tableName;
-
- private GenericJdbcExecutor executor;
-
- private static final int START = -50;
- private static final int NUMBER_OF_ROWS = 101;
-
- public TestImportExtractor() {
- tableName = getClass().getSimpleName().toUpperCase();
- }
-
- @Override
- public void setUp() {
- executor = new GenericJdbcExecutor(GenericJdbcTestConstants.DRIVER,
- GenericJdbcTestConstants.URL, null, null);
-
- if (!executor.existTable(tableName)) {
- executor.executeUpdate("CREATE TABLE "
- + executor.delimitIdentifier(tableName)
- + "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
-
- for (int i = 0; i < NUMBER_OF_ROWS; i++) {
- int value = START + i;
- String sql = "INSERT INTO " + executor.delimitIdentifier(tableName)
- + " VALUES(" + value + ", " + value + ", '" + value + "')";
- executor.executeUpdate(sql);
- }
- }
- }
-
- @Override
- public void tearDown() {
- executor.close();
- }
-
- public void testQuery() throws Exception {
- MutableContext context = new MutableMapContext();
-
- ConnectionConfiguration connectionConfig = new ConnectionConfiguration();
-
- connectionConfig.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connectionConfig.connection.connectionString = GenericJdbcTestConstants.URL;
-
- ImportJobConfiguration jobConfig = new ImportJobConfiguration();
-
- context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL,
- "SELECT * FROM " + executor.delimitIdentifier(tableName) + " WHERE ${CONDITIONS}");
-
- GenericJdbcImportPartition partition;
-
- Extractor extractor = new GenericJdbcImportExtractor();
- DummyWriter writer = new DummyWriter();
- ExtractorContext extractorContext = new ExtractorContext(context, writer, null);
-
- partition = new GenericJdbcImportPartition();
- partition.setConditions("-50.0 <= DCOL AND DCOL < -16.6666666666666665");
- extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
-
- partition = new GenericJdbcImportPartition();
- partition.setConditions("-16.6666666666666665 <= DCOL AND DCOL < 16.666666666666667");
- extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
-
- partition = new GenericJdbcImportPartition();
- partition.setConditions("16.666666666666667 <= DCOL AND DCOL <= 50.0");
- extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
- }
-
- public void testSubquery() throws Exception {
- MutableContext context = new MutableMapContext();
-
- ConnectionConfiguration connectionConfig = new ConnectionConfiguration();
-
- connectionConfig.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
- connectionConfig.connection.connectionString = GenericJdbcTestConstants.URL;
-
- ImportJobConfiguration jobConfig = new ImportJobConfiguration();
-
- context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL,
- "SELECT SQOOP_SUBQUERY_ALIAS.ICOL,SQOOP_SUBQUERY_ALIAS.VCOL FROM "
- + "(SELECT * FROM " + executor.delimitIdentifier(tableName)
- + " WHERE ${CONDITIONS}) SQOOP_SUBQUERY_ALIAS");
-
- GenericJdbcImportPartition partition;
-
- Extractor extractor = new GenericJdbcImportExtractor();
- DummyWriter writer = new DummyWriter();
- ExtractorContext extractorContext = new ExtractorContext(context, writer, null);
-
- partition = new GenericJdbcImportPartition();
- partition.setConditions("-50 <= ICOL AND ICOL < -16");
- extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
-
- partition = new GenericJdbcImportPartition();
- partition.setConditions("-16 <= ICOL AND ICOL < 17");
- extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
-
- partition = new GenericJdbcImportPartition();
- partition.setConditions("17 <= ICOL AND ICOL < 50");
- extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
- }
-
- public class DummyWriter extends DataWriter {
- int indx = START;
-
- @Override
- public void writeArrayRecord(Object[] array) {
- for (int i = 0; i < array.length; i++) {
- if (array[i] instanceof Integer) {
- assertEquals(indx, ((Integer)array[i]).intValue());
- } else if (array[i] instanceof Double) {
- assertEquals((double)indx, ((Double)array[i]).doubleValue());
- } else {
- assertEquals(String.valueOf(indx), array[i].toString());
- }
- }
- indx++;
- }
-
- @Override
- public void writeStringRecord(String text) {
- fail("This method should not be invoked.");
- }
-
- @Override
- public void writeRecord(Object content) {
- fail("This method should not be invoked.");
- }
- }
+// private final String tableName;
+//
+// private GenericJdbcExecutor executor;
+//
+// private static final int START = -50;
+// private static final int NUMBER_OF_ROWS = 101;
+//
+// public TestImportExtractor() {
+// tableName = getClass().getSimpleName().toUpperCase();
+// }
+//
+// @Override
+// public void setUp() {
+// executor = new GenericJdbcExecutor(GenericJdbcTestConstants.DRIVER,
+// GenericJdbcTestConstants.URL, null, null);
+//
+// if (!executor.existTable(tableName)) {
+// executor.executeUpdate("CREATE TABLE "
+// + executor.delimitIdentifier(tableName)
+// + "(ICOL INTEGER PRIMARY KEY, DCOL DOUBLE, VCOL VARCHAR(20))");
+//
+// for (int i = 0; i < NUMBER_OF_ROWS; i++) {
+// int value = START + i;
+// String sql = "INSERT INTO " + executor.delimitIdentifier(tableName)
+// + " VALUES(" + value + ", " + value + ", '" + value + "')";
+// executor.executeUpdate(sql);
+// }
+// }
+// }
+//
+// @Override
+// public void tearDown() {
+// executor.close();
+// }
+//
+// public void testQuery() throws Exception {
+// MutableContext context = new MutableMapContext();
+//
+// ConnectionConfiguration connectionConfig = new ConnectionConfiguration();
+//
+// connectionConfig.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connectionConfig.connection.connectionString = GenericJdbcTestConstants.URL;
+//
+// ImportJobConfiguration jobConfig = new ImportJobConfiguration();
+//
+// context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL,
+// "SELECT * FROM " + executor.delimitIdentifier(tableName) + " WHERE ${CONDITIONS}");
+//
+// GenericJdbcImportPartition partition;
+//
+// Extractor extractor = new GenericJdbcImportExtractor();
+// DummyWriter writer = new DummyWriter();
+// ExtractorContext extractorContext = new ExtractorContext(context, writer, null);
+//
+// partition = new GenericJdbcImportPartition();
+// partition.setConditions("-50.0 <= DCOL AND DCOL < -16.6666666666666665");
+// extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
+//
+// partition = new GenericJdbcImportPartition();
+// partition.setConditions("-16.6666666666666665 <= DCOL AND DCOL < 16.666666666666667");
+// extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
+//
+// partition = new GenericJdbcImportPartition();
+// partition.setConditions("16.666666666666667 <= DCOL AND DCOL <= 50.0");
+// extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
+// }
+//
+// public void testSubquery() throws Exception {
+// MutableContext context = new MutableMapContext();
+//
+// ConnectionConfiguration connectionConfig = new ConnectionConfiguration();
+//
+// connectionConfig.connection.jdbcDriver = GenericJdbcTestConstants.DRIVER;
+// connectionConfig.connection.connectionString = GenericJdbcTestConstants.URL;
+//
+// ImportJobConfiguration jobConfig = new ImportJobConfiguration();
+//
+// context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL,
+// "SELECT SQOOP_SUBQUERY_ALIAS.ICOL,SQOOP_SUBQUERY_ALIAS.VCOL FROM "
+// + "(SELECT * FROM " + executor.delimitIdentifier(tableName)
+// + " WHERE ${CONDITIONS}) SQOOP_SUBQUERY_ALIAS");
+//
+// GenericJdbcImportPartition partition;
+//
+// Extractor extractor = new GenericJdbcImportExtractor();
+// DummyWriter writer = new DummyWriter();
+// ExtractorContext extractorContext = new ExtractorContext(context, writer, null);
+//
+// partition = new GenericJdbcImportPartition();
+// partition.setConditions("-50 <= ICOL AND ICOL < -16");
+// extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
+//
+// partition = new GenericJdbcImportPartition();
+// partition.setConditions("-16 <= ICOL AND ICOL < 17");
+// extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
+//
+// partition = new GenericJdbcImportPartition();
+// partition.setConditions("17 <= ICOL AND ICOL < 50");
+// extractor.extract(extractorContext, connectionConfig, jobConfig, partition);
+// }
+//
+// public class DummyWriter extends DataWriter {
+// int indx = START;
+//
+// @Override
+// public void writeArrayRecord(Object[] array) {
+// for (int i = 0; i < array.length; i++) {
+// if (array[i] instanceof Integer) {
+// assertEquals(indx, ((Integer)array[i]).intValue());
+// } else if (array[i] instanceof Double) {
+// assertEquals((double)indx, ((Double)array[i]).doubleValue());
+// } else {
+// assertEquals(String.valueOf(indx), array[i].toString());
+// }
+// }
+// indx++;
+// }
+//
+// @Override
+// public void writeStringRecord(String text) {
+// fail("This method should not be invoked.");
+// }
+//
+// @Override
+// public void writeRecord(Object content) {
+// fail("This method should not be invoked.");
+// }
+// }
}