diff --git a/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java b/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java index e584a19f..514b5ac2 100644 --- a/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java +++ b/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java @@ -439,13 +439,13 @@ public void createOrUpgradeRepository(Connection conn) { // Change direction from VARCHAR to BIGINT + foreign key. updateDirections(conn, insertDirections(conn)); renameConnectorToConfigurable(conn); - } - // Add unique constraints on job and links for version 4 onwards - if (repositoryVersion > 3) { + + // Add unique constraints on job and links for version 4 onwards runQuery(QUERY_UPGRADE_TABLE_SQ_JOB_ADD_UNIQUE_CONSTRAINT_NAME, conn); runQuery(QUERY_UPGRADE_TABLE_SQ_LINK_ADD_UNIQUE_CONSTRAINT_NAME, conn); runQuery(QUERY_UPGRADE_TABLE_SQ_CONFIGURABLE_ADD_UNIQUE_CONSTRAINT_NAME, conn); } + // last step upgrade the repository version to the latest value in the code upgradeRepositoryVersion(conn); } diff --git a/repository/repository-derby/src/test/java/org/apache/sqoop/repository/derby/DerbyTestCase.java b/repository/repository-derby/src/test/java/org/apache/sqoop/repository/derby/DerbyTestCase.java index edcef70f..3398c914 100644 --- a/repository/repository-derby/src/test/java/org/apache/sqoop/repository/derby/DerbyTestCase.java +++ b/repository/repository-derby/src/test/java/org/apache/sqoop/repository/derby/DerbyTestCase.java @@ -580,7 +580,7 @@ public void loadJobs(int version) throws Exception { for(String type : new String[] {"IMPORT", "EXPORT"}) { for(String name : new String[] {"JA", "JB"} ) { runQuery("INSERT INTO SQOOP.SQ_JOB(SQB_NAME, SQB_CONNECTION, SQB_TYPE)" - + " VALUES('" + name + "', 1, '" + type + "')"); + + " VALUES('" + type + "_" + name + "', 1, '" + type + "')"); } }