sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject [5/5] sqoop git commit: SQOOP-1589: Sqoop2: Create common constants, error codes, and queries
Date Tue, 11 Nov 2014 00:37:26 GMT
SQOOP-1589: Sqoop2: Create common constants, error codes, and queries

(Abraham Elmahrek via Jarek Jarcec Cecho)


Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/5de4b437
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/5de4b437
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/5de4b437

Branch: refs/heads/sqoop2
Commit: 5de4b437826c6dde7f9b880ad24b453d7fcc8ef5
Parents: 4640d81
Author: Jarek Jarcec Cecho <jarcec@apache.org>
Authored: Mon Nov 10 16:37:00 2014 -0800
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
Committed: Mon Nov 10 16:37:00 2014 -0800

----------------------------------------------------------------------
 pom.xml                                         |    5 +
 repository/pom.xml                              |    1 +
 repository/repository-common/pom.xml            |   60 +
 .../repository/common/CommonRepoConstants.java  |   24 +
 .../common/CommonRepositoryError.java           |  201 ++
 .../common/CommonRepositoryHandler.java         | 2286 ++++++++++++++++++
 ...RepositoryInsertUpdateDeleteSelectQuery.java |  550 +++++
 .../common/CommonRepositorySchemaConstants.java |  248 ++
 repository/repository-derby/pom.xml             |    5 +
 .../repository/derby/DerbyRepoConstants.java    |    1 -
 .../sqoop/repository/derby/DerbyRepoError.java  |  160 +-
 .../derby/DerbyRepositoryHandler.java           | 2252 +----------------
 ...erbySchemaInsertUpdateDeleteSelectQuery.java |  541 +----
 .../sqoop/repository/derby/TestJobHandling.java |    3 +-
 .../repository/derby/TestLinkHandling.java      |    5 +-
 .../derby/TestRespositorySchemaUpgrade.java     |    2 +-
 server/pom.xml                                  |    5 +
 test/pom.xml                                    |    5 +
 18 files changed, 3445 insertions(+), 2909 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/sqoop/blob/5de4b437/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 8859398..9ff51d1 100644
--- a/pom.xml
+++ b/pom.xml
@@ -286,6 +286,11 @@ limitations under the License.
       </dependency>
       <dependency>
         <groupId>org.apache.sqoop.repository</groupId>
+        <artifactId>sqoop-repository-common</artifactId>
+        <version>${project.version}</version>
+      </dependency>
+      <dependency>
+        <groupId>org.apache.sqoop.repository</groupId>
         <artifactId>sqoop-repository-derby</artifactId>
         <version>${project.version}</version>
       </dependency>

http://git-wip-us.apache.org/repos/asf/sqoop/blob/5de4b437/repository/pom.xml
----------------------------------------------------------------------
diff --git a/repository/pom.xml b/repository/pom.xml
index e3345c4..8c95c0e 100644
--- a/repository/pom.xml
+++ b/repository/pom.xml
@@ -33,6 +33,7 @@ limitations under the License.
   <packaging>pom</packaging>
 
   <modules>
+    <module>repository-common</module>
     <module>repository-derby</module>
   </modules>
 

http://git-wip-us.apache.org/repos/asf/sqoop/blob/5de4b437/repository/repository-common/pom.xml
----------------------------------------------------------------------
diff --git a/repository/repository-common/pom.xml b/repository/repository-common/pom.xml
new file mode 100644
index 0000000..37378c6
--- /dev/null
+++ b/repository/repository-common/pom.xml
@@ -0,0 +1,60 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements.  See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License.  You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.apache.sqoop</groupId>
+    <artifactId>repository</artifactId>
+    <version>2.0.0-SNAPSHOT</version>
+  </parent>
+
+  <groupId>org.apache.sqoop.repository</groupId>
+  <artifactId>sqoop-repository-common</artifactId>
+  <name>Sqoop Common Repository</name>
+
+  <dependencies>
+    <dependency>
+      <groupId>org.apache.sqoop</groupId>
+      <artifactId>sqoop-core</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>commons-lang</groupId>
+      <artifactId>commons-lang</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+
+    <dependency>
+      <groupId>org.apache.sqoop</groupId>
+      <artifactId>sqoop-core</artifactId>
+      <type>test-jar</type>
+      <scope>test</scope>
+    </dependency>
+
+  </dependencies>
+
+</project>

http://git-wip-us.apache.org/repos/asf/sqoop/blob/5de4b437/repository/repository-common/src/main/java/org/apache/sqoop/repository/common/CommonRepoConstants.java
----------------------------------------------------------------------
diff --git a/repository/repository-common/src/main/java/org/apache/sqoop/repository/common/CommonRepoConstants.java
b/repository/repository-common/src/main/java/org/apache/sqoop/repository/common/CommonRepoConstants.java
new file mode 100644
index 0000000..d1890b8
--- /dev/null
+++ b/repository/repository-common/src/main/java/org/apache/sqoop/repository/common/CommonRepoConstants.java
@@ -0,0 +1,24 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.sqoop.repository.common;
+
+public class CommonRepoConstants {
+
+  public static final String SYSKEY_VERSION = "repository.version";
+
+}

http://git-wip-us.apache.org/repos/asf/sqoop/blob/5de4b437/repository/repository-common/src/main/java/org/apache/sqoop/repository/common/CommonRepositoryError.java
----------------------------------------------------------------------
diff --git a/repository/repository-common/src/main/java/org/apache/sqoop/repository/common/CommonRepositoryError.java
b/repository/repository-common/src/main/java/org/apache/sqoop/repository/common/CommonRepositoryError.java
new file mode 100644
index 0000000..7a7b28c
--- /dev/null
+++ b/repository/repository-common/src/main/java/org/apache/sqoop/repository/common/CommonRepositoryError.java
@@ -0,0 +1,201 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.sqoop.repository.common;
+
+import org.apache.sqoop.common.ErrorCode;
+
+public enum CommonRepositoryError implements ErrorCode {
+  // JDBC Repository Handler Errors: Prefix COMMON
+
+  /** The system was unable to run the specified query. */
+  COMMON_0000("Unable to run specified query"),
+
+  /** The system was unable to query the repository for given entity */
+  COMMON_0001("Unable to retrieve entity data"),
+
+  /** The repository contains more than one connector with same name */
+  COMMON_0002("Invalid entity state - multiple connectors with name"),
+
+  /** The system does not support the given input type.*/
+  COMMON_0003("Unknown input type encountered"),
+
+  /** The system does not support the given config type.*/
+  COMMON_0004("Unknown config type encountered"),
+
+  /** No input was found for the given config. */
+  COMMON_0005("The config contains no input"),
+
+  /** The system could not load the config due to unexpected position of input.*/
+  COMMON_0006("The config input retrieved does not match expected position"),
+
+  /**
+   * The system could not load the connector due to unexpected position
+   * of config.
+   */
+  COMMON_0007("The config retrieved does not match expected position"),
+
+  /**
+   * The system was not able to register entity due to a pre-assigned
+   * persistence identifier.
+   */
+  COMMON_0008("Entity cannot have preassigned persistence id"),
+
+  /**
+   * The system was unable to register various entities.
+   */
+  COMMON_0009("Unexpected update count when registering entity"),
+
+  /**
+   * The system was unable to register entity due to a failure to retrieve
+   * the generated identifier.
+   */
+  COMMON_0010("Unable to retrieve generated identifier"),
+
+  /**
+   * The system was unable to register connector due to a server
+   * error.
+   */
+  COMMON_0011("Registration of connector failed"),
+
+  /**
+   * The system was not able to register connector due to an unexpected
+   * update count.
+   */
+  COMMON_0012("Unexpected update count on config registration"),
+
+  /**
+   * The system was unable to register connector due to a failure to
+   * retrieve the generated identifier for a config.
+   */
+  COMMON_0013("Unable to retrieve generated identifier for config"),
+
+  /**
+   * The system was unable to register connector due to an unexpected
+   * update count for config input registration.
+   */
+  COMMON_0014("Unexpected update count for config input"),
+
+  /**
+   * The system was unable to register connector due to a failure to
+   * retrieve the generated identifier for a config input.
+   */
+  COMMON_0015("Unable to retrieve generated identifier for config input"),
+
+  /** We cant create new link in repository **/
+  COMMON_0016("Unable to create new link data"),
+
+  /** We can't save values for input to repository **/
+  COMMON_0017("Unable to save input values to the repository"),
+
+  /** We can't update link in repository **/
+  COMMON_0018("Unable to update link in repository"),
+
+  /** We can't delete link in repository **/
+  COMMON_0019("Unable to delete link in repository"),
+
+  /** We can't restore link from repository **/
+  COMMON_0020("Unable to load link from repository"),
+
+  /** We can't restore specific link from repository **/
+  COMMON_0021("Unable to load specific link from repository"),
+
+  /** We're unable to check if given link already exists */
+  COMMON_0022("Unable to check if given link exists"),
+
+  /** We cant create new job in repository **/
+  COMMON_0023("Unable to create new job data"),
+
+  /** We can't update job in repository **/
+  COMMON_0024("Unable to update job in repository"),
+
+  /** We can't delete job in repository **/
+  COMMON_0025("Unable to delete job in repository"),
+
+  /** We're unable to check if given job already exists */
+  COMMON_0026("Unable to check if given job exists"),
+
+  /** We can't restore specific job from repository **/
+  COMMON_0027("Unable to load specific job from repository"),
+
+  /** We can't restore job from repository **/
+  COMMON_0028("Unable to load job from repository"),
+
+  /** Can't verify if link is referenced from somewhere **/
+  COMMON_0029("Unable to check if link is in use"),
+
+  /** We're unable to check if given submission already exists */
+  COMMON_0030("Unable to check if given submission exists"),
+
+  /** We cant create new submission in repository **/
+  COMMON_0031("Unable to create new submission data"),
+
+  /** We can't update submission in repository **/
+  COMMON_0032("Unable to update submission in the repository"),
+
+  /** Can't purge old submissions **/
+  COMMON_0033("Unable to purge old submissions"),
+
+  /** Can't retrieve unfinished submissions **/
+  COMMON_0034("Can't retrieve unfinished submissions"),
+
+  /** Can't update connector **/
+  COMMON_0035("Update of connector failed"),
+
+  /** Can't retrieve all submissions **/
+  COMMON_0036("Can't retrieve all submissions"),
+
+  /** Can't retrieve submissions for a job **/
+  COMMON_0037("Can't retrieve submissions for a job"),
+
+  /** Can't enable/disable link **/
+  COMMON_0038("Can't enable/disable link"),
+
+  /** Can't enable/disable job **/
+  COMMON_0039("Can't enable/disable job"),
+
+  /** Can't update driver config **/
+  COMMON_0040("Update of driver config failed"),
+
+  /** Can't retrieve all connectors **/
+  COMMON_0041("Can't retrieve all connectors"),
+
+  /** Can't register config direction **/
+  COMMON_0042("Could not register config direction"),
+
+  /** Can't set connector direction **/
+  COMMON_0043("Could not set connector direction"),
+
+  /** The system was unable to register driver due to a server error **/
+  COMMON_0044("Registration of driver failed")
+
+  ;
+
+  private final String message;
+
+  private CommonRepositoryError(String message) {
+    this.message = message;
+  }
+
+  public String getCode() {
+    return name();
+  }
+
+  public String getMessage() {
+    return message;
+  }
+}


Mime
View raw message