From 4b98d4a0a31059ad0497f6454306e6236284bc5f Mon Sep 17 00:00:00 2001 From: Simon <3656562@qq.com> Date: Mon, 11 May 2020 12:55:09 +0800 Subject: [PATCH] Delete dolphinscheduler_ddl.sql --- .../mysql/dolphinscheduler_ddl.sql | 381 ------------------ 1 file changed, 381 deletions(-) delete mode 100644 sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql diff --git a/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql b/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql deleted file mode 100644 index 1c9aacfafc..0000000000 --- a/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql +++ /dev/null @@ -1,381 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. -*/ - -SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY','')); --- uc_dolphin_T_t_ds_process_definition_A_modify_by -drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_process_definition_A_modify_by; -delimiter d// -CREATE PROCEDURE uc_dolphin_T_t_ds_process_definition_A_modify_by() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_process_definition' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='modify_by') - THEN - ALTER TABLE t_ds_process_definition ADD `modify_by` varchar(36) DEFAULT '' COMMENT 'modify user'; - END IF; - END; - -d// - -delimiter ; -CALL uc_dolphin_T_t_ds_process_definition_A_modify_by; -DROP PROCEDURE uc_dolphin_T_t_ds_process_definition_A_modify_by; - --- uc_dolphin_T_t_ds_task_instance_A_executor_id -drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_task_instance_A_executor_id; -delimiter d// -CREATE PROCEDURE uc_dolphin_T_t_ds_task_instance_A_executor_id() - 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 ='executor_id') - THEN - ALTER TABLE t_ds_task_instance ADD `executor_id` int(11) DEFAULT NULL COMMENT 'executor id'; - END IF; - END; - -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; - --- 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; - --- ac_dolphin_T_t_ds_resources_A_pid -drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_resources_A_pid; -delimiter d// -CREATE PROCEDURE ac_dolphin_T_t_ds_resources_A_pid() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_resources' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='pid') - THEN - ALTER TABLE t_ds_resources ADD `pid` int(11) DEFAULT -1 COMMENT 'parent id'; - END IF; - END; - -d// - -delimiter ; -CALL ac_dolphin_T_t_ds_resources_A_pid; -DROP PROCEDURE ac_dolphin_T_t_ds_resources_A_pid; - --- ac_dolphin_T_t_ds_resources_A_full_name -drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_resources_A_full_name; -delimiter d// -CREATE PROCEDURE ac_dolphin_T_t_ds_resources_A_full_name() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_resources' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='full_name') - THEN - ALTER TABLE t_ds_resources ADD `full_name` varchar(255) DEFAULT NULL COMMENT 'full name'; - END IF; - END; - -d// - -delimiter ; -CALL ac_dolphin_T_t_ds_resources_A_full_name; -DROP PROCEDURE ac_dolphin_T_t_ds_resources_A_full_name; - --- ac_dolphin_T_t_ds_resources_A_pid -drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_resources_is_directory; -delimiter d// -CREATE PROCEDURE ac_dolphin_T_t_ds_resources_is_directory() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_resources' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='is_directory') - THEN - ALTER TABLE t_ds_resources ADD `is_directory` tinyint(1) DEFAULT 0 COMMENT 'is directory'; - END IF; - END; - -d// - -delimiter ; -CALL ac_dolphin_T_t_ds_resources_is_directory; -DROP PROCEDURE ac_dolphin_T_t_ds_resources_is_directory; - --- ac_dolphin_T_t_ds_process_definition_A_resource_ids -drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_process_definition_A_resource_ids; -delimiter d// -CREATE PROCEDURE ac_dolphin_T_t_ds_process_definition_A_resource_ids() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_process_definition' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='resource_ids') - THEN - ALTER TABLE t_ds_process_definition ADD `resource_ids` varchar(255) DEFAULT NULL COMMENT 'resource ids'; - END IF; - END; - -d// - -delimiter ; -CALL ac_dolphin_T_t_ds_process_definition_A_resource_ids; -DROP PROCEDURE ac_dolphin_T_t_ds_process_definition_A_resource_ids; - - --- ac_dolphin_T_t_ds_process_instance_A_worker_group -drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_process_instance_A_worker_group; -delimiter d// -CREATE PROCEDURE ac_dolphin_T_t_ds_process_instance_A_worker_group() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_process_instance' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='worker_group') - THEN - ALTER TABLE t_ds_process_instance ADD `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; - END IF; - END; - -d// - -delimiter ; -CALL ac_dolphin_T_t_ds_process_instance_A_worker_group; -DROP PROCEDURE ac_dolphin_T_t_ds_process_instance_A_worker_group; - --- dc_dolphin_T_t_ds_process_instance_D_worker_group_id -drop PROCEDURE if EXISTS dc_dolphin_T_t_ds_process_instance_D_worker_group_id; -delimiter d// -CREATE PROCEDURE dc_dolphin_T_t_ds_process_instance_D_worker_group_id() - BEGIN - IF EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_process_instance' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='worker_group_id') - THEN - ALTER TABLE t_ds_process_instance DROP COLUMN worker_group_id; - END IF; - END; - -d// - -delimiter ; -CALL dc_dolphin_T_t_ds_process_instance_D_worker_group_id; -DROP PROCEDURE dc_dolphin_T_t_ds_process_instance_D_worker_group_id; - --- ac_dolphin_T_t_ds_task_instance_A_worker_group -drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_task_instance_A_worker_group; -delimiter d// -CREATE PROCEDURE ac_dolphin_T_t_ds_task_instance_A_worker_group() - 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 ='worker_group') - THEN - ALTER TABLE t_ds_task_instance ADD `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; - END IF; - END; - -d// - -delimiter ; -CALL ac_dolphin_T_t_ds_task_instance_A_worker_group; -DROP PROCEDURE ac_dolphin_T_t_ds_task_instance_A_worker_group; - --- dc_dolphin_T_t_ds_task_instance_D_worker_group_id -drop PROCEDURE if EXISTS dc_dolphin_T_t_ds_task_instance_D_worker_group_id; -delimiter d// -CREATE PROCEDURE dc_dolphin_T_t_ds_task_instance_D_worker_group_id() - BEGIN - IF EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_task_instance' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='worker_group_id') - THEN - ALTER TABLE t_ds_task_instance DROP COLUMN worker_group_id; - END IF; - END; - -d// - -delimiter ; -CALL dc_dolphin_T_t_ds_task_instance_D_worker_group_id; -DROP PROCEDURE dc_dolphin_T_t_ds_task_instance_D_worker_group_id; - --- ac_dolphin_T_t_ds_schedules_A_worker_group -drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_schedules_A_worker_group; -delimiter d// -CREATE PROCEDURE ac_dolphin_T_t_ds_schedules_A_worker_group() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_schedules' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='worker_group') - THEN - ALTER TABLE t_ds_schedules ADD `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; - END IF; - END; - -d// - -delimiter ; -CALL ac_dolphin_T_t_ds_schedules_A_worker_group; -DROP PROCEDURE ac_dolphin_T_t_ds_schedules_A_worker_group; - --- dc_dolphin_T_t_ds_schedules_D_worker_group_id -drop PROCEDURE if EXISTS dc_dolphin_T_t_ds_schedules_D_worker_group_id; -delimiter d// -CREATE PROCEDURE dc_dolphin_T_t_ds_schedules_D_worker_group_id() - BEGIN - IF EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_schedules' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='worker_group_id') - THEN - ALTER TABLE t_ds_schedules DROP COLUMN worker_group_id; - END IF; - END; - -d// - -delimiter ; -CALL dc_dolphin_T_t_ds_schedules_D_worker_group_id; -DROP PROCEDURE dc_dolphin_T_t_ds_schedules_D_worker_group_id; - --- ac_dolphin_T_t_ds_command_A_worker_group -drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_command_A_worker_group; -delimiter d// -CREATE PROCEDURE ac_dolphin_T_t_ds_command_A_worker_group() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_command' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='worker_group') - THEN - ALTER TABLE t_ds_command ADD `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; - END IF; - END; - -d// - -delimiter ; -CALL ac_dolphin_T_t_ds_command_A_worker_group; -DROP PROCEDURE ac_dolphin_T_t_ds_command_A_worker_group; - --- dc_dolphin_T_t_ds_command_D_worker_group_id -drop PROCEDURE if EXISTS dc_dolphin_T_t_ds_command_D_worker_group_id; -delimiter d// -CREATE PROCEDURE dc_dolphin_T_t_ds_command_D_worker_group_id() - BEGIN - IF EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_command' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='worker_group_id') - THEN - ALTER TABLE t_ds_command DROP COLUMN worker_group_id; - END IF; - END; - -d// - -delimiter ; -CALL dc_dolphin_T_t_ds_command_D_worker_group_id; -DROP PROCEDURE dc_dolphin_T_t_ds_command_D_worker_group_id; - --- ac_dolphin_T_t_ds_error_command_A_worker_group -drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_error_command_A_worker_group; -delimiter d// -CREATE PROCEDURE ac_dolphin_T_t_ds_error_command_A_worker_group() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_error_command' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='worker_group') - THEN - ALTER TABLE t_ds_error_command ADD `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; - END IF; - END; - -d// - -delimiter ; -CALL ac_dolphin_T_t_ds_error_command_A_worker_group; -DROP PROCEDURE ac_dolphin_T_t_ds_error_command_A_worker_group; - --- dc_dolphin_T_t_ds_error_command_D_worker_group_id -drop PROCEDURE if EXISTS dc_dolphin_T_t_ds_error_command_D_worker_group_id; -delimiter d// -CREATE PROCEDURE dc_dolphin_T_t_ds_error_command_D_worker_group_id() - BEGIN - IF EXISTS (SELECT 1 FROM information_schema.COLUMNS - WHERE TABLE_NAME='t_ds_error_command' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND COLUMN_NAME ='worker_group_id') - THEN - ALTER TABLE t_ds_error_command DROP COLUMN worker_group_id; - END IF; - END; - -d// - -delimiter ; -CALL dc_dolphin_T_t_ds_error_command_D_worker_group_id; -DROP PROCEDURE dc_dolphin_T_t_ds_error_command_D_worker_group_id; - - --- uc_dolphin_T_t_ds_process_definition_A_process_definition_unique -drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_process_definition_A_process_definition_unique; -delimiter d// -CREATE PROCEDURE uc_dolphin_T_t_ds_process_definition_A_modify_by() - BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.STATISTICS - WHERE TABLE_NAME='t_ds_process_definition' - AND TABLE_SCHEMA=(SELECT DATABASE()) - AND INDEX_NAME ='process_definition_unique') - THEN - ALTER TABLE t_ds_process_definition ADD UNIQUE KEY `process_definition_unique` (`name`,`project_id`); - END IF; - END; - -d// - -delimiter ; -CALL uc_dolphin_T_t_ds_process_definition_A_process_definition_unique; -DROP PROCEDURE uc_dolphin_T_t_ds_process_definition_A_process_definition_unique; - -