Просмотр исходного кода

modify t_ds_task_instance app_link change sql (#2861)

Yelli 4 лет назад
Родитель
Сommit
3cbe865776

+ 2 - 2
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;
 

+ 1 - 1
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