You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@sqoop.apache.org by "Veena Basavaraj (JIRA)" <ji...@apache.org> on 2014/10/20 23:43:34 UTC
[jira] [Updated] (SQOOP-1597) Sqoop2: Refactor DerbySchemaQuery
into one for create/ update/ and then CRUD operarations
[ https://issues.apache.org/jira/browse/SQOOP-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Veena Basavaraj updated SQOOP-1597:
-----------------------------------
Description:
{code}
/**************************** DERBY CREATE SCHEMA queries ********************************/
// DDL: Create schema
public static final String QUERY_CREATE_SCHEMA_SQOOP =
"CREATE SCHEMA " + SCHEMA_SQOOP;
public static final String QUERY_SYSSCHEMA_SQOOP =
"SELECT SCHEMAID FROM SYS.SYSSCHEMAS WHERE SCHEMANAME = '"
+ SCHEMA_SQOOP + "'";
// DDL: Create table SQ_SYSTEM
public static final String QUERY_CREATE_TABLE_SQ_SYSTEM =
"CREATE TABLE " + TABLE_SQ_SYSTEM + " ("
+ COLUMN_SQM_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
+ COLUMN_SQM_KEY + " VARCHAR(64), "
+ COLUMN_SQM_VALUE + " VARCHAR(64) "
+ ")";
// DDL: Create table SQ_DIRECTION
public static final String QUERY_CREATE_TABLE_SQ_DIRECTION =
"CREATE TABLE " + TABLE_SQ_DIRECTION + " ("
+ COLUMN_SQD_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
+ COLUMN_SQD_NAME + " VARCHAR(64)"
+ ")";
// DDL: Create table SQ_CONNECTOR
@Deprecated // used only for upgrade
public static final String QUERY_CREATE_TABLE_SQ_CONNECTOR =
"CREATE TABLE " + TABLE_SQ_CONFIGURABLE + " ("
+ COLUMN_SQC_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
+ COLUMN_SQC_NAME + " VARCHAR(64), "
+ COLUMN_SQC_CLASS + " VARCHAR(255), "
+ COLUMN_SQC_VERSION + " VARCHAR(64) "
+ ")";
// DDL: Create table SQ_CONNECTOR_DIRECTIONS
public static final String QUERY_CREATE_TABLE_SQ_CONNECTOR_DIRECTIONS =
"CREATE TABLE " + TABLE_SQ_CONNECTOR_DIRECTIONS + " ("
+ COLUMN_SQCD_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
+ COLUMN_SQCD_CONNECTOR + " BIGINT, "
+ COLUMN_SQCD_DIRECTION + " BIGINT, "
+ "CONSTRAINT " + CONSTRAINT_SQCD_SQC + " "
+ "FOREIGN KEY (" + COLUMN_SQCD_CONNECTOR + ") "
+ "REFERENCES " + TABLE_SQ_CONFIGURABLE + " (" + COLUMN_SQC_ID + "), "
+ "CONSTRAINT " + CONSTRAINT_SQCD_SQD + " "
+ "FOREIGN KEY (" + COLUMN_SQCD_DIRECTION + ") "
+ "REFERENCES " + TABLE_SQ_DIRECTION + " (" + COLUMN_SQD_ID + ")"
+ ")";
// DDL: Create table SQ_FORM
public static final String QUERY_CREATE_TABLE_SQ_FORM =
"CREATE TABLE " + TABLE_SQ_FORM + " ("
+ COLUMN_SQF_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
+ COLUMN_SQF_CONNECTOR + " BIGINT, "
+ COLUMN_SQF_OPERATION + " VARCHAR(32), "
+ COLUMN_SQF_NAME + " VARCHAR(64), "
+ COLUMN_SQF_TYPE + " VARCHAR(32), "
+ COLUMN_SQF_INDEX + " SMALLINT, "
+ "CONSTRAINT " + CONSTRAINT_SQF_SQC + " "
+ "FOREIGN KEY (" + COLUMN_SQF_CONNECTOR + ") "
+ "REFERENCES " + TABLE_SQ_CONNECTOR + " (" + COLUMN_SQC_ID + ")"
+ ")";
// DDL: Create table SQ_CONFIG_DIRECTIONS ( same as SQ_FORM_DIRECTIONS)
// Note: that the form was renamed to config at one point and this code was added after the rename
// DDL: Create table SQ_CONFIG_DIRECTIONS
public static final String QUERY_CREATE_TABLE_SQ_CONFIG_DIRECTIONS =
"CREATE TABLE " + TABLE_SQ_CONFIG_DIRECTIONS + " ("
+ COLUMN_SQ_CFG_DIR_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
+ COLUMN_SQ_CFG_DIR_CONFIG + " BIGINT, "
+ COLUMN_SQ_CFG_DIR_DIRECTION + " BIGINT, "
+ "CONSTRAINT " + CONSTRAINT_SQ_CFG_DIR_CONFIG + " "
+ "FOREIGN KEY (" + COLUMN_SQ_CFG_DIR_CONFIG + ") "
+ "REFERENCES " + TABLE_SQ_CONFIG + " (" + COLUMN_SQ_CFG_ID + "), "
+ "CONSTRAINT " + CONSTRAINT_SQ_CFG_DIR_DIRECTION + " "
+ "FOREIGN KEY (" + COLUMN_SQ_CFG_DIR_DIRECTION + ") "
+ "REFERENCES " + TABLE_SQ_DIRECTION + " (" + COLUMN_SQD_ID + ")"
+ ")";
// DDL: Create table SQ_INPUT
public static final String QUERY_CREATE_TABLE_SQ_INPUT =
"CREATE TABLE " + TABLE_SQ_INPUT + " ("
+ COLUMN_SQI_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
+ COLUMN_SQI_NAME + " VARCHAR(64), "
+ COLUMN_SQI_FORM + " BIGINT, "
+ COLUMN_SQI_INDEX + " SMALLINT, "
+ COLUMN_SQI_TYPE + " VARCHAR(32), "
+ COLUMN_SQI_STRMASK + " BOOLEAN, "
+ COLUMN_SQI_STRLENGTH + " SMALLINT, "
+ COLUMN_SQI_ENUMVALS + " VARCHAR(100),"
+ "CONSTRAINT " + CONSTRAINT_SQI_SQF + " "
+ "FOREIGN KEY (" + COLUMN_SQI_FORM + ") "
+ "REFERENCES " + TABLE_SQ_FORM + " (" + COLUMN_SQF_ID + ")"
+ ")";
// DDL: Create table SQ_CONNECTION
public static final String QUERY_CREATE_TABLE_SQ_CONNECTION =
"CREATE TABLE " + TABLE_SQ_CONNECTION + " ("
+ COLUMN_SQN_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
+ COLUMN_SQN_CONNECTOR + " BIGINT, "
+ COLUMN_SQN_NAME + " VARCHAR(32),"
+ COLUMN_SQN_CREATION_DATE + " TIMESTAMP,"
+ COLUMN_SQN_UPDATE_DATE + " TIMESTAMP,"
+ "CONSTRAINT " + CONSTRAINT_SQN_SQC + " "
+ "FOREIGN KEY(" + COLUMN_SQN_CONNECTOR + ") "
+ " REFERENCES " + TABLE_SQ_CONFIGURABLE + " (" + COLUMN_SQC_ID + ")"
+ ")";
//DDL: Create table SQ_JOB
public static final String QUERY_CREATE_TABLE_SQ_JOB =
"CREATE TABLE " + TABLE_SQ_JOB + " ("
+ COLUMN_SQB_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
+ COLUMN_SQB_CONNECTION + " BIGINT, "
+ COLUMN_SQB_NAME + " VARCHAR(64), "
+ COLUMN_SQB_TYPE + " VARCHAR(64),"
+ COLUMN_SQB_CREATION_DATE + " TIMESTAMP,"
+ COLUMN_SQB_UPDATE_DATE + " TIMESTAMP,"
+ "CONSTRAINT " + CONSTRAINT_SQB_SQN + " "
+ "FOREIGN KEY(" + COLUMN_SQB_CONNECTION + ") "
+ "REFERENCES " + TABLE_SQ_CONNECTION + " (" + COLUMN_SQN_ID + ")"
+ ")";
// DDL: Create table SQ_CONNECTION_INPUT
public static final String QUERY_CREATE_TABLE_SQ_CONNECTION_INPUT =
"CREATE TABLE " + TABLE_SQ_CONNECTION_INPUT + " ("
+ COLUMN_SQNI_CONNECTION + " BIGINT, "
+ COLUMN_SQNI_INPUT + " BIGINT, "
+ COLUMN_SQNI_VALUE + " LONG VARCHAR,"
+ "PRIMARY KEY (" + COLUMN_SQNI_CONNECTION + ", " + COLUMN_SQNI_INPUT + "), "
+ "CONSTRAINT " + CONSTRAINT_SQNI_SQN + " "
+ "FOREIGN KEY (" + COLUMN_SQNI_CONNECTION + ") "
+ "REFERENCES " + TABLE_SQ_CONNECTION + " (" + COLUMN_SQN_ID + "),"
+ "CONSTRAINT " + CONSTRAINT_SQNI_SQI + " "
+ "FOREIGN KEY (" + COLUMN_SQNI_INPUT + ") "
+ "REFERENCES " + TABLE_SQ_INPUT + " (" + COLUMN_SQI_ID + ")"
+ ")";
// DDL: Create table SQ_JOB_INPUT
public static final String QUERY_CREATE_TABLE_SQ_JOB_INPUT =
"CREATE TABLE " + TABLE_SQ_JOB_INPUT + " ("
+ COLUMN_SQBI_JOB + " BIGINT, "
+ COLUMN_SQBI_INPUT + " BIGINT, "
+ COLUMN_SQBI_VALUE + " LONG VARCHAR,"
+ " PRIMARY KEY (" + COLUMN_SQBI_JOB + ", " + COLUMN_SQBI_INPUT + "), "
+ " CONSTRAINT " + CONSTRAINT_SQBI_SQB + " "
+ "FOREIGN KEY (" + COLUMN_SQBI_JOB + ") "
+ "REFERENCES " + TABLE_SQ_JOB + " (" + COLUMN_SQB_ID + "), "
+ " CONSTRAINT " + CONSTRAINT_SQBI_SQI + " "
+ "FOREIGN KEY (" + COLUMN_SQBI_INPUT + ") "
+ "REFERENCES " + TABLE_SQ_INPUT + " (" + COLUMN_SQI_ID + ")"
+ ")";
// DDL: Create table SQ_SUBMISSION
public static final String QUERY_CREATE_TABLE_SQ_SUBMISSION =
"CREATE TABLE " + TABLE_SQ_SUBMISSION + " ("
+ COLUMN_SQS_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1), "
+ COLUMN_SQS_JOB + " BIGINT, "
+ COLUMN_SQS_STATUS + " VARCHAR(20), "
+ COLUMN_SQS_CREATION_DATE + " TIMESTAMP,"
+ COLUMN_SQS_UPDATE_DATE + " TIMESTAMP,"
+ COLUMN_SQS_EXTERNAL_ID + " VARCHAR(50), "
+ COLUMN_SQS_EXTERNAL_LINK + " VARCHAR(150), "
+ COLUMN_SQS_EXCEPTION + " VARCHAR(150), "
+ COLUMN_SQS_EXCEPTION_TRACE + " VARCHAR(750), "
+ "PRIMARY KEY (" + COLUMN_SQS_ID + "), "
+ "CONSTRAINT " + CONSTRAINT_SQS_SQB + " "
+ "FOREIGN KEY (" + COLUMN_SQS_JOB + ") "
+ "REFERENCES " + TABLE_SQ_JOB + "(" + COLUMN_SQB_ID + ") ON DELETE CASCADE"
+ ")";
// DDL: Create table SQ_COUNTER_GROUP
public static final String QUERY_CREATE_TABLE_SQ_COUNTER_GROUP =
"CREATE TABLE " + TABLE_SQ_COUNTER_GROUP + " ("
+ COLUMN_SQG_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1), "
+ COLUMN_SQG_NAME + " VARCHAR(75), "
+ "PRIMARY KEY (" + COLUMN_SQG_ID + "),"
+ "UNIQUE ( " + COLUMN_SQG_NAME + ")"
+ ")";
// DDL: Create table SQ_COUNTER
public static final String QUERY_CREATE_TABLE_SQ_COUNTER =
"CREATE TABLE " + TABLE_SQ_COUNTER + " ("
+ COLUMN_SQR_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1), "
+ COLUMN_SQR_NAME + " VARCHAR(75), "
+ "PRIMARY KEY (" + COLUMN_SQR_ID + "), "
+ "UNIQUE ( " + COLUMN_SQR_NAME + ")"
+ ")";
// DDL: Create table SQ_COUNTER_SUBMISSION
public static final String QUERY_CREATE_TABLE_SQ_COUNTER_SUBMISSION =
"CREATE TABLE " + TABLE_SQ_COUNTER_SUBMISSION + " ("
+ COLUMN_SQRS_GROUP + " BIGINT, "
+ COLUMN_SQRS_COUNTER + " BIGINT, "
+ COLUMN_SQRS_SUBMISSION + " BIGINT, "
+ COLUMN_SQRS_VALUE + " BIGINT, "
+ "PRIMARY KEY (" + COLUMN_SQRS_GROUP + ", " + COLUMN_SQRS_COUNTER + ", " + COLUMN_SQRS_SUBMISSION + "), "
+ "CONSTRAINT " + CONSTRAINT_SQRS_SQG + " "
+ "FOREIGN KEY (" + COLUMN_SQRS_GROUP + ") "
+ "REFERENCES " + TABLE_SQ_COUNTER_GROUP + "(" + COLUMN_SQG_ID + "), "
+ "CONSTRAINT " + CONSTRAINT_SQRS_SQR + " "
+ "FOREIGN KEY (" + COLUMN_SQRS_COUNTER + ") "
+ "REFERENCES " + TABLE_SQ_COUNTER + "(" + COLUMN_SQR_ID + "), "
+ "CONSTRAINT " + CONSTRAINT_SQRS_SQS + " "
+ "FOREIGN KEY (" + COLUMN_SQRS_SUBMISSION + ") "
+ "REFERENCES " + TABLE_SQ_SUBMISSION + "(" + COLUMN_SQS_ID + ") ON DELETE CASCADE "
+ ")";
{code}
{code}
/********************************INSERT/UPDATE/DELETE/SELECT queries *************************************/
....
{code}
{code}
/****************** DERBY UPGRADE queries by version *******************************/
{code}
was:
{code}
package org.apache.sqoop.common;
/**
* Defines an error-code contract. Sqoop exceptions use the error code to
* communicate error information where possible. Each error code is associated
* with default message that identifies the high level information related to
* the underlying error condition.
*/
public interface ErrorCode {
/**
* @return the string representation of the error code.
*/
String getCode();
/**
* @return the message associated with error code.
*/
String getMessage();
}
{code}
to
{code}
package org.apache.sqoop.common;
/**
* Defines an error-code contract. Sqoop exceptions use the error code to
* communicate error information where possible. Each error code is associated
* with default message that identifies the high level information related to
* the underlying error condition.
*/
public abstract class ErrorCode {
/**
* @return the string representation of the error code.
*/
String getCode() {
}
/**
* @return the message associated with error code.
*/
String getMessage() {
}
}
{code}
> Sqoop2: Refactor DerbySchemaQuery into one for create/ update/ and then CRUD operarations
> -----------------------------------------------------------------------------------------
>
> Key: SQOOP-1597
> URL: https://issues.apache.org/jira/browse/SQOOP-1597
> Project: Sqoop
> Issue Type: Improvement
> Reporter: Veena Basavaraj
> Assignee: Veena Basavaraj
>
> {code}
> /**************************** DERBY CREATE SCHEMA queries ********************************/
> // DDL: Create schema
> public static final String QUERY_CREATE_SCHEMA_SQOOP =
> "CREATE SCHEMA " + SCHEMA_SQOOP;
> public static final String QUERY_SYSSCHEMA_SQOOP =
> "SELECT SCHEMAID FROM SYS.SYSSCHEMAS WHERE SCHEMANAME = '"
> + SCHEMA_SQOOP + "'";
> // DDL: Create table SQ_SYSTEM
> public static final String QUERY_CREATE_TABLE_SQ_SYSTEM =
> "CREATE TABLE " + TABLE_SQ_SYSTEM + " ("
> + COLUMN_SQM_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
> + COLUMN_SQM_KEY + " VARCHAR(64), "
> + COLUMN_SQM_VALUE + " VARCHAR(64) "
> + ")";
> // DDL: Create table SQ_DIRECTION
> public static final String QUERY_CREATE_TABLE_SQ_DIRECTION =
> "CREATE TABLE " + TABLE_SQ_DIRECTION + " ("
> + COLUMN_SQD_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
> + COLUMN_SQD_NAME + " VARCHAR(64)"
> + ")";
> // DDL: Create table SQ_CONNECTOR
> @Deprecated // used only for upgrade
> public static final String QUERY_CREATE_TABLE_SQ_CONNECTOR =
> "CREATE TABLE " + TABLE_SQ_CONFIGURABLE + " ("
> + COLUMN_SQC_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
> + COLUMN_SQC_NAME + " VARCHAR(64), "
> + COLUMN_SQC_CLASS + " VARCHAR(255), "
> + COLUMN_SQC_VERSION + " VARCHAR(64) "
> + ")";
> // DDL: Create table SQ_CONNECTOR_DIRECTIONS
> public static final String QUERY_CREATE_TABLE_SQ_CONNECTOR_DIRECTIONS =
> "CREATE TABLE " + TABLE_SQ_CONNECTOR_DIRECTIONS + " ("
> + COLUMN_SQCD_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
> + COLUMN_SQCD_CONNECTOR + " BIGINT, "
> + COLUMN_SQCD_DIRECTION + " BIGINT, "
> + "CONSTRAINT " + CONSTRAINT_SQCD_SQC + " "
> + "FOREIGN KEY (" + COLUMN_SQCD_CONNECTOR + ") "
> + "REFERENCES " + TABLE_SQ_CONFIGURABLE + " (" + COLUMN_SQC_ID + "), "
> + "CONSTRAINT " + CONSTRAINT_SQCD_SQD + " "
> + "FOREIGN KEY (" + COLUMN_SQCD_DIRECTION + ") "
> + "REFERENCES " + TABLE_SQ_DIRECTION + " (" + COLUMN_SQD_ID + ")"
> + ")";
> // DDL: Create table SQ_FORM
> public static final String QUERY_CREATE_TABLE_SQ_FORM =
> "CREATE TABLE " + TABLE_SQ_FORM + " ("
> + COLUMN_SQF_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
> + COLUMN_SQF_CONNECTOR + " BIGINT, "
> + COLUMN_SQF_OPERATION + " VARCHAR(32), "
> + COLUMN_SQF_NAME + " VARCHAR(64), "
> + COLUMN_SQF_TYPE + " VARCHAR(32), "
> + COLUMN_SQF_INDEX + " SMALLINT, "
> + "CONSTRAINT " + CONSTRAINT_SQF_SQC + " "
> + "FOREIGN KEY (" + COLUMN_SQF_CONNECTOR + ") "
> + "REFERENCES " + TABLE_SQ_CONNECTOR + " (" + COLUMN_SQC_ID + ")"
> + ")";
> // DDL: Create table SQ_CONFIG_DIRECTIONS ( same as SQ_FORM_DIRECTIONS)
> // Note: that the form was renamed to config at one point and this code was added after the rename
> // DDL: Create table SQ_CONFIG_DIRECTIONS
> public static final String QUERY_CREATE_TABLE_SQ_CONFIG_DIRECTIONS =
> "CREATE TABLE " + TABLE_SQ_CONFIG_DIRECTIONS + " ("
> + COLUMN_SQ_CFG_DIR_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
> + COLUMN_SQ_CFG_DIR_CONFIG + " BIGINT, "
> + COLUMN_SQ_CFG_DIR_DIRECTION + " BIGINT, "
> + "CONSTRAINT " + CONSTRAINT_SQ_CFG_DIR_CONFIG + " "
> + "FOREIGN KEY (" + COLUMN_SQ_CFG_DIR_CONFIG + ") "
> + "REFERENCES " + TABLE_SQ_CONFIG + " (" + COLUMN_SQ_CFG_ID + "), "
> + "CONSTRAINT " + CONSTRAINT_SQ_CFG_DIR_DIRECTION + " "
> + "FOREIGN KEY (" + COLUMN_SQ_CFG_DIR_DIRECTION + ") "
> + "REFERENCES " + TABLE_SQ_DIRECTION + " (" + COLUMN_SQD_ID + ")"
> + ")";
> // DDL: Create table SQ_INPUT
> public static final String QUERY_CREATE_TABLE_SQ_INPUT =
> "CREATE TABLE " + TABLE_SQ_INPUT + " ("
> + COLUMN_SQI_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
> + COLUMN_SQI_NAME + " VARCHAR(64), "
> + COLUMN_SQI_FORM + " BIGINT, "
> + COLUMN_SQI_INDEX + " SMALLINT, "
> + COLUMN_SQI_TYPE + " VARCHAR(32), "
> + COLUMN_SQI_STRMASK + " BOOLEAN, "
> + COLUMN_SQI_STRLENGTH + " SMALLINT, "
> + COLUMN_SQI_ENUMVALS + " VARCHAR(100),"
> + "CONSTRAINT " + CONSTRAINT_SQI_SQF + " "
> + "FOREIGN KEY (" + COLUMN_SQI_FORM + ") "
> + "REFERENCES " + TABLE_SQ_FORM + " (" + COLUMN_SQF_ID + ")"
> + ")";
> // DDL: Create table SQ_CONNECTION
> public static final String QUERY_CREATE_TABLE_SQ_CONNECTION =
> "CREATE TABLE " + TABLE_SQ_CONNECTION + " ("
> + COLUMN_SQN_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
> + COLUMN_SQN_CONNECTOR + " BIGINT, "
> + COLUMN_SQN_NAME + " VARCHAR(32),"
> + COLUMN_SQN_CREATION_DATE + " TIMESTAMP,"
> + COLUMN_SQN_UPDATE_DATE + " TIMESTAMP,"
> + "CONSTRAINT " + CONSTRAINT_SQN_SQC + " "
> + "FOREIGN KEY(" + COLUMN_SQN_CONNECTOR + ") "
> + " REFERENCES " + TABLE_SQ_CONFIGURABLE + " (" + COLUMN_SQC_ID + ")"
> + ")";
> //DDL: Create table SQ_JOB
> public static final String QUERY_CREATE_TABLE_SQ_JOB =
> "CREATE TABLE " + TABLE_SQ_JOB + " ("
> + COLUMN_SQB_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1) PRIMARY KEY, "
> + COLUMN_SQB_CONNECTION + " BIGINT, "
> + COLUMN_SQB_NAME + " VARCHAR(64), "
> + COLUMN_SQB_TYPE + " VARCHAR(64),"
> + COLUMN_SQB_CREATION_DATE + " TIMESTAMP,"
> + COLUMN_SQB_UPDATE_DATE + " TIMESTAMP,"
> + "CONSTRAINT " + CONSTRAINT_SQB_SQN + " "
> + "FOREIGN KEY(" + COLUMN_SQB_CONNECTION + ") "
> + "REFERENCES " + TABLE_SQ_CONNECTION + " (" + COLUMN_SQN_ID + ")"
> + ")";
> // DDL: Create table SQ_CONNECTION_INPUT
> public static final String QUERY_CREATE_TABLE_SQ_CONNECTION_INPUT =
> "CREATE TABLE " + TABLE_SQ_CONNECTION_INPUT + " ("
> + COLUMN_SQNI_CONNECTION + " BIGINT, "
> + COLUMN_SQNI_INPUT + " BIGINT, "
> + COLUMN_SQNI_VALUE + " LONG VARCHAR,"
> + "PRIMARY KEY (" + COLUMN_SQNI_CONNECTION + ", " + COLUMN_SQNI_INPUT + "), "
> + "CONSTRAINT " + CONSTRAINT_SQNI_SQN + " "
> + "FOREIGN KEY (" + COLUMN_SQNI_CONNECTION + ") "
> + "REFERENCES " + TABLE_SQ_CONNECTION + " (" + COLUMN_SQN_ID + "),"
> + "CONSTRAINT " + CONSTRAINT_SQNI_SQI + " "
> + "FOREIGN KEY (" + COLUMN_SQNI_INPUT + ") "
> + "REFERENCES " + TABLE_SQ_INPUT + " (" + COLUMN_SQI_ID + ")"
> + ")";
> // DDL: Create table SQ_JOB_INPUT
> public static final String QUERY_CREATE_TABLE_SQ_JOB_INPUT =
> "CREATE TABLE " + TABLE_SQ_JOB_INPUT + " ("
> + COLUMN_SQBI_JOB + " BIGINT, "
> + COLUMN_SQBI_INPUT + " BIGINT, "
> + COLUMN_SQBI_VALUE + " LONG VARCHAR,"
> + " PRIMARY KEY (" + COLUMN_SQBI_JOB + ", " + COLUMN_SQBI_INPUT + "), "
> + " CONSTRAINT " + CONSTRAINT_SQBI_SQB + " "
> + "FOREIGN KEY (" + COLUMN_SQBI_JOB + ") "
> + "REFERENCES " + TABLE_SQ_JOB + " (" + COLUMN_SQB_ID + "), "
> + " CONSTRAINT " + CONSTRAINT_SQBI_SQI + " "
> + "FOREIGN KEY (" + COLUMN_SQBI_INPUT + ") "
> + "REFERENCES " + TABLE_SQ_INPUT + " (" + COLUMN_SQI_ID + ")"
> + ")";
> // DDL: Create table SQ_SUBMISSION
> public static final String QUERY_CREATE_TABLE_SQ_SUBMISSION =
> "CREATE TABLE " + TABLE_SQ_SUBMISSION + " ("
> + COLUMN_SQS_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1), "
> + COLUMN_SQS_JOB + " BIGINT, "
> + COLUMN_SQS_STATUS + " VARCHAR(20), "
> + COLUMN_SQS_CREATION_DATE + " TIMESTAMP,"
> + COLUMN_SQS_UPDATE_DATE + " TIMESTAMP,"
> + COLUMN_SQS_EXTERNAL_ID + " VARCHAR(50), "
> + COLUMN_SQS_EXTERNAL_LINK + " VARCHAR(150), "
> + COLUMN_SQS_EXCEPTION + " VARCHAR(150), "
> + COLUMN_SQS_EXCEPTION_TRACE + " VARCHAR(750), "
> + "PRIMARY KEY (" + COLUMN_SQS_ID + "), "
> + "CONSTRAINT " + CONSTRAINT_SQS_SQB + " "
> + "FOREIGN KEY (" + COLUMN_SQS_JOB + ") "
> + "REFERENCES " + TABLE_SQ_JOB + "(" + COLUMN_SQB_ID + ") ON DELETE CASCADE"
> + ")";
> // DDL: Create table SQ_COUNTER_GROUP
> public static final String QUERY_CREATE_TABLE_SQ_COUNTER_GROUP =
> "CREATE TABLE " + TABLE_SQ_COUNTER_GROUP + " ("
> + COLUMN_SQG_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1), "
> + COLUMN_SQG_NAME + " VARCHAR(75), "
> + "PRIMARY KEY (" + COLUMN_SQG_ID + "),"
> + "UNIQUE ( " + COLUMN_SQG_NAME + ")"
> + ")";
> // DDL: Create table SQ_COUNTER
> public static final String QUERY_CREATE_TABLE_SQ_COUNTER =
> "CREATE TABLE " + TABLE_SQ_COUNTER + " ("
> + COLUMN_SQR_ID + " BIGINT GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1), "
> + COLUMN_SQR_NAME + " VARCHAR(75), "
> + "PRIMARY KEY (" + COLUMN_SQR_ID + "), "
> + "UNIQUE ( " + COLUMN_SQR_NAME + ")"
> + ")";
> // DDL: Create table SQ_COUNTER_SUBMISSION
> public static final String QUERY_CREATE_TABLE_SQ_COUNTER_SUBMISSION =
> "CREATE TABLE " + TABLE_SQ_COUNTER_SUBMISSION + " ("
> + COLUMN_SQRS_GROUP + " BIGINT, "
> + COLUMN_SQRS_COUNTER + " BIGINT, "
> + COLUMN_SQRS_SUBMISSION + " BIGINT, "
> + COLUMN_SQRS_VALUE + " BIGINT, "
> + "PRIMARY KEY (" + COLUMN_SQRS_GROUP + ", " + COLUMN_SQRS_COUNTER + ", " + COLUMN_SQRS_SUBMISSION + "), "
> + "CONSTRAINT " + CONSTRAINT_SQRS_SQG + " "
> + "FOREIGN KEY (" + COLUMN_SQRS_GROUP + ") "
> + "REFERENCES " + TABLE_SQ_COUNTER_GROUP + "(" + COLUMN_SQG_ID + "), "
> + "CONSTRAINT " + CONSTRAINT_SQRS_SQR + " "
> + "FOREIGN KEY (" + COLUMN_SQRS_COUNTER + ") "
> + "REFERENCES " + TABLE_SQ_COUNTER + "(" + COLUMN_SQR_ID + "), "
> + "CONSTRAINT " + CONSTRAINT_SQRS_SQS + " "
> + "FOREIGN KEY (" + COLUMN_SQRS_SUBMISSION + ") "
> + "REFERENCES " + TABLE_SQ_SUBMISSION + "(" + COLUMN_SQS_ID + ") ON DELETE CASCADE "
> + ")";
> {code}
> {code}
> /********************************INSERT/UPDATE/DELETE/SELECT queries *************************************/
> ....
> {code}
> {code}
> /****************** DERBY UPGRADE queries by version *******************************/
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)