github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-18 18:00:50 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-2754: Sqoop2: Fix bug in integration test for Mysql and Postgresql

Browse Source 
(Colin Ma via Jarek Jarcec Cecho)
This commit is contained in:
Jarek Jarcec Cecho 2015-12-24 09:21:48 +01:00
parent 889fde9a1a
commit bf5cc533b3
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
repository/repository-mysql/src/test/java/org/apache/sqoop/integration/repository/mysql/TestJobHandling.java
View File

@ -17,6 +17,7 @@
*/ */
package org.apache.sqoop.integration.repository.mysql; package org.apache.sqoop.integration.repository.mysql;
import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -145,9 +146,13 @@ public void testFindJobsByConnector() throws Exception {
.findJobsForConnectorUpgrade( .findJobsForConnectorUpgrade(
handler.findConnector("A", provider.getConnection()) handler.findConnector("A", provider.getConnection())
.getPersistenceId(), provider.getConnection()); .getPersistenceId(), provider.getConnection());
List<String> jobNames = new ArrayList<String>();
for (MJob job : list) {
jobNames.add(job.getName());
}
assertEquals(2, list.size()); assertEquals(2, list.size());
assertEquals(JOB_A_NAME, list.get(0).getName()); assertTrue(jobNames.contains(JOB_A_NAME));
assertEquals(JOB_B_NAME, list.get(1).getName()); assertTrue(jobNames.contains(JOB_B_NAME));
} }
@Test @Test

3
repository/repository-postgresql/src/test/java/org/apache/sqoop/integration/repository/postgresql/PostgresqlTestCase.java
View File

@ -62,7 +62,8 @@ public void setUpClass() {
@BeforeMethod(alwaysRun = true) @BeforeMethod(alwaysRun = true)
public void setUp() throws Exception { public void setUp() throws Exception {
provider.start(); provider.start();
// clear the data for sqoop
provider.dropSchema("SQOOP");
handler = new PostgresqlRepositoryHandler(); handler = new PostgresqlRepositoryHandler();
handler.createOrUpgradeRepository(provider.getConnection()); handler.createOrUpgradeRepository(provider.getConnection());
} }