Browse Source

modify t_ds_task_instance app_link change sql (#2861)

pull/3/MERGE
Yelli 4 years ago committed by gaojun2048
parent
commit
6e20d3d34a
  1. 4
      sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql
  2. 2
      sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql

4
sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql

@ -61,12 +61,12 @@ 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
IF 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';
ALTER TABLE t_ds_task_instance CHANGE `app_link` `app_link` text COMMENT 'yarn app id';
END IF;
END;

2
sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql

@ -54,7 +54,7 @@ DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_task_instance_A_executor_id();
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
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS
WHERE TABLE_NAME='t_ds_task_instance'
AND COLUMN_NAME ='app_link')
THEN

Loading…
Cancel
Save