From d7614c059b68f6ab8cd358444a3488ab130e7b34 Mon Sep 17 00:00:00 2001
From: Yelli <amarantine@my.com>
Date: Thu, 12 Mar 2020 21:52:48 +0800
Subject: [PATCH] fix bug: data too long for column 'app_link' (#2146)

* fix bug: data to long for app_link field

* change app_link field length in 1.2.2 ddl

* change app_link field type to text
---
 .../mysql/dolphinscheduler_ddl.sql            | 22 ++++++++++++++++++-
 .../postgresql/dolphinscheduler_ddl.sql       | 18 +++++++++++++++
 2 files changed, 39 insertions(+), 1 deletion(-)

diff --git a/sql/upgrade/1.2.2_schema/mysql/dolphinscheduler_ddl.sql b/sql/upgrade/1.2.2_schema/mysql/dolphinscheduler_ddl.sql
index e5785d9997..049484ce3a 100644
--- a/sql/upgrade/1.2.2_schema/mysql/dolphinscheduler_ddl.sql
+++ b/sql/upgrade/1.2.2_schema/mysql/dolphinscheduler_ddl.sql
@@ -54,4 +54,24 @@ d//
 
 delimiter ;
 CALL uc_dolphin_T_t_ds_task_instance_A_executor_id;
-DROP PROCEDURE uc_dolphin_T_t_ds_task_instance_A_executor_id;
\ No newline at end of file
+DROP PROCEDURE uc_dolphin_T_t_ds_task_instance_A_executor_id;
+
+-- uc_dolphin_T_t_ds_task_instance_C_app_link
+drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_task_instance_C_app_link;
+delimiter d//
+CREATE PROCEDURE uc_dolphin_T_t_ds_task_instance_C_app_link()
+   BEGIN
+       IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
+           WHERE TABLE_NAME='t_ds_task_instance'
+           AND TABLE_SCHEMA=(SELECT DATABASE())
+           AND COLUMN_NAME ='app_link')
+   THEN
+         ALTER TABLE t_ds_task_instance CHANGE COLUMN app_link app_link text COMMENT 'yarn app id';
+       END IF;
+ END;
+
+d//
+
+delimiter ;
+CALL uc_dolphin_T_t_ds_task_instance_C_app_link;
+DROP PROCEDURE uc_dolphin_T_t_ds_task_instance_C_app_link;
\ No newline at end of file
diff --git a/sql/upgrade/1.2.2_schema/postgresql/dolphinscheduler_ddl.sql b/sql/upgrade/1.2.2_schema/postgresql/dolphinscheduler_ddl.sql
index 70471cb26d..b1e0fd941c 100644
--- a/sql/upgrade/1.2.2_schema/postgresql/dolphinscheduler_ddl.sql
+++ b/sql/upgrade/1.2.2_schema/postgresql/dolphinscheduler_ddl.sql
@@ -49,3 +49,21 @@ d//
 delimiter ;
 SELECT uc_dolphin_T_t_ds_task_instance_A_executor_id();
 DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_task_instance_A_executor_id();
+
+-- uc_dolphin_T_t_ds_task_instance_C_app_link
+delimiter d//
+CREATE OR REPLACE FUNCTION uc_dolphin_T_t_ds_task_instance_C_app_link() RETURNS void AS $$
+BEGIN
+       IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
+          WHERE TABLE_NAME='t_ds_task_instance'
+                            AND COLUMN_NAME ='app_link')
+      THEN
+         ALTER TABLE t_ds_task_instance ALTER COLUMN app_link type text;
+       END IF;
+END;
+$$ LANGUAGE plpgsql;
+d//
+
+delimiter ;
+SELECT uc_dolphin_T_t_ds_task_instance_C_app_link();
+DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_task_instance_C_app_link();
\ No newline at end of file