SQOOP-728 Increase varchar limits for external link and exceptions (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/caaecf1a Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/caaecf1a Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/caaecf1a Branch: refs/heads/sqoop2 Commit: caaecf1af2a8c29c4be4aa9d85cbb6b55776e647 Parents: 6de60c2 Author: Bilung Lee <[email protected]> Authored: Thu Nov 29 16:38:26 2012 -0800 Committer: Bilung Lee <[email protected]> Committed: Thu Nov 29 16:38:26 2012 -0800 ---------------------------------------------------------------------- .../sqoop/repository/derby/DerbySchemaQuery.java | 14 +++++++------- 1 files changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/caaecf1a/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbySchemaQuery.java ---------------------------------------------------------------------- diff --git a/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbySchemaQuery.java b/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbySchemaQuery.java index 55d7128..f836500 100644 --- a/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbySchemaQuery.java +++ b/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbySchemaQuery.java @@ -128,9 +128,9 @@ import static org.apache.sqoop.repository.derby.DerbySchemaConstants.*; * | SQS_CREATION_DATE: TIMESTAMP | * | SQS_UPDATE_DATE: TIMESTAMP | * | SQS_EXTERNAL_ID: VARCHAR(25) | - * | SQS_EXTERNAL_LINK: VARCHAR(75) | - * | SQS_EXCEPTION: VARCHAR(75) | - * | SQS_EXCEPTION_TRACE: VARCHAR(500) | + * | SQS_EXTERNAL_LINK: VARCHAR(150) | + * | SQS_EXCEPTION: VARCHAR(150) | + * | SQS_EXCEPTION_TRACE: VARCHAR(750) | * +-----------------------------------+ * </pre> * </p> @@ -263,9 +263,9 @@ public final class DerbySchemaQuery { + COLUMN_SQS_CREATION_DATE + " TIMESTAMP," + COLUMN_SQS_UPDATE_DATE + " TIMESTAMP," + COLUMN_SQS_EXTERNAL_ID + " VARCHAR(25), " - + COLUMN_SQS_EXTERNAL_LINK + " VARCHAR(75), " - + COLUMN_SQS_EXCEPTION + " VARCHAR(75), " - + COLUMN_SQS_EXCEPTION_TRACE + " VARCHAR(500), " + + COLUMN_SQS_EXTERNAL_LINK + " VARCHAR(150), " + + COLUMN_SQS_EXCEPTION + " VARCHAR(150), " + + COLUMN_SQS_EXCEPTION_TRACE + " VARCHAR(750), " + "PRIMARY KEY (" + COLUMN_SQS_ID + "), " + "FOREIGN KEY (" + COLUMN_SQS_JOB + ") REFERENCES " + TABLE_SQ_JOB + "(" + COLUMN_SQB_ID + ") ON DELETE CASCADE" + ")"; @@ -472,7 +472,7 @@ public final class DerbySchemaQuery { + COLUMN_SQS_EXTERNAL_LINK + ", " + COLUMN_SQS_EXCEPTION + ", " + COLUMN_SQS_EXCEPTION_TRACE + ") " - + " VALUES(?, ?, ?, ?, ?, ?, ?, ?)"; + + " VALUES(?, ?, ?, ?, ?, substr(?, 1, 150) , substr(?, 1, 150), substr(?, 1, 750))"; // DML: Update existing submission public static final String STMT_UPDATE_SUBMISSION =
