Simon
4 years ago
committed by
GitHub
11 changed files with 752 additions and 57 deletions
@ -0,0 +1,359 @@
|
||||
/* |
||||
* 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; |
||||
|
||||
@ -0,0 +1,366 @@
|
||||
/* |
||||
* 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. |
||||
*/ |
||||
-- uc_dolphin_T_t_ds_process_definition_A_modify_by |
||||
delimiter d// |
||||
CREATE OR REPLACE FUNCTION uc_dolphin_T_t_ds_process_definition_A_modify_by() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_NAME='t_ds_process_definition' |
||||
AND COLUMN_NAME ='modify_by') |
||||
THEN |
||||
ALTER TABLE t_ds_process_definition ADD COLUMN modify_by varchar(36) DEFAULT ''; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
|
||||
delimiter ; |
||||
SELECT uc_dolphin_T_t_ds_process_definition_A_modify_by(); |
||||
DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_process_definition_A_modify_by(); |
||||
|
||||
-- uc_dolphin_T_t_ds_task_instance_A_executor_id |
||||
delimiter d// |
||||
CREATE OR REPLACE FUNCTION uc_dolphin_T_t_ds_task_instance_A_executor_id() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_NAME='t_ds_task_instance' |
||||
AND COLUMN_NAME ='executor_id') |
||||
THEN |
||||
ALTER TABLE t_ds_task_instance ADD COLUMN executor_id int DEFAULT NULL; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
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(); |
||||
|
||||
|
||||
-- ac_dolphin_T_t_ds_resources_A_pid |
||||
delimiter d// |
||||
CREATE FUNCTION ac_dolphin_T_t_ds_resources_A_pid() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_resources' |
||||
AND COLUMN_NAME ='pid') |
||||
THEN |
||||
ALTER TABLE t_ds_resources ADD COLUMN pid int DEFAULT -1; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select ac_dolphin_T_t_ds_resources_A_pid(); |
||||
DROP FUNCTION ac_dolphin_T_t_ds_resources_A_pid(); |
||||
|
||||
-- ac_dolphin_T_t_ds_resources_A_full_name |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_resources_A_full_name(); |
||||
delimiter d// |
||||
CREATE FUNCTION ac_dolphin_T_t_ds_resources_A_full_name() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_resources' |
||||
AND COLUMN_NAME ='full_name') |
||||
THEN |
||||
ALTER TABLE t_ds_resources ADD COLUMN full_name varchar(255) DEFAULT null; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select ac_dolphin_T_t_ds_resources_A_full_name(); |
||||
DROP FUNCTION ac_dolphin_T_t_ds_resources_A_full_name(); |
||||
|
||||
-- ac_dolphin_T_t_ds_resources_A_is_directory |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_resources_A_is_directory(); |
||||
delimiter d// |
||||
CREATE FUNCTION ac_dolphin_T_t_ds_resources_A_is_directory() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_resources' |
||||
AND COLUMN_NAME ='is_directory') |
||||
THEN |
||||
ALTER TABLE t_ds_resources ADD COLUMN is_directory boolean DEFAULT false; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select ac_dolphin_T_t_ds_resources_A_is_directory(); |
||||
DROP FUNCTION ac_dolphin_T_t_ds_resources_A_is_directory(); |
||||
|
||||
-- ac_dolphin_T_t_ds_process_definition_A_resource_ids |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_process_definition_A_resource_ids(); |
||||
delimiter d// |
||||
CREATE FUNCTION ac_dolphin_T_t_ds_process_definition_A_resource_ids() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_process_definition' |
||||
AND COLUMN_NAME ='resource_ids') |
||||
THEN |
||||
ALTER TABLE t_ds_process_definition ADD COLUMN resource_ids varchar(255) DEFAULT null; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select ac_dolphin_T_t_ds_process_definition_A_resource_ids(); |
||||
DROP FUNCTION ac_dolphin_T_t_ds_process_definition_A_resource_ids(); |
||||
|
||||
|
||||
-- ac_dolphin_T_t_ds_process_instance_A_worker_group |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_process_instance_A_worker_group(); |
||||
delimiter d// |
||||
CREATE FUNCTION ac_dolphin_T_t_ds_process_instance_A_worker_group() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_process_instance' |
||||
AND COLUMN_NAME ='worker_group') |
||||
THEN |
||||
ALTER TABLE t_ds_process_instance ADD COLUMN worker_group varchar(64) DEFAULT null; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select ac_dolphin_T_t_ds_process_instance_A_worker_group(); |
||||
DROP FUNCTION ac_dolphin_T_t_ds_process_instance_A_worker_group(); |
||||
|
||||
-- dc_dolphin_T_t_ds_process_instance_D_worker_group_id |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS dc_dolphin_T_t_ds_process_instance_D_worker_group_id(); |
||||
delimiter d// |
||||
CREATE FUNCTION dc_dolphin_T_t_ds_process_instance_D_worker_group_id() RETURNS void AS $$ |
||||
BEGIN |
||||
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_process_instance' |
||||
AND COLUMN_NAME ='worker_group_id') |
||||
THEN |
||||
ALTER TABLE t_ds_process_instance DROP COLUMN worker_group_id; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select dc_dolphin_T_t_ds_process_instance_D_worker_group_id(); |
||||
DROP FUNCTION dc_dolphin_T_t_ds_process_instance_D_worker_group_id(); |
||||
|
||||
|
||||
-- ac_dolphin_T_t_ds_task_instance_A_worker_group |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_task_instance_A_worker_group(); |
||||
delimiter d// |
||||
CREATE FUNCTION ac_dolphin_T_t_ds_task_instance_A_worker_group() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_task_instance' |
||||
AND COLUMN_NAME ='worker_group') |
||||
THEN |
||||
ALTER TABLE t_ds_task_instance ADD COLUMN worker_group varchar(64) DEFAULT null; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select ac_dolphin_T_t_ds_task_instance_A_worker_group(); |
||||
DROP FUNCTION ac_dolphin_T_t_ds_task_instance_A_worker_group(); |
||||
|
||||
-- dc_dolphin_T_t_ds_task_instance_D_worker_group_id |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS dc_dolphin_T_t_ds_task_instance_D_worker_group_id(); |
||||
delimiter d// |
||||
CREATE FUNCTION dc_dolphin_T_t_ds_task_instance_D_worker_group_id() RETURNS void AS $$ |
||||
BEGIN |
||||
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_task_instance' |
||||
AND COLUMN_NAME ='worker_group_id') |
||||
THEN |
||||
ALTER TABLE t_ds_task_instance DROP COLUMN worker_group_id; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select dc_dolphin_T_t_ds_task_instance_D_worker_group_id(); |
||||
DROP FUNCTION dc_dolphin_T_t_ds_task_instance_D_worker_group_id(); |
||||
|
||||
-- ac_dolphin_T_t_ds_schedules_A_worker_group |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_schedules_A_worker_group(); |
||||
delimiter d// |
||||
CREATE FUNCTION ac_dolphin_T_t_ds_schedules_A_worker_group() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_schedules' |
||||
AND COLUMN_NAME ='worker_group') |
||||
THEN |
||||
ALTER TABLE t_ds_schedules ADD COLUMN worker_group varchar(64) DEFAULT null; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select ac_dolphin_T_t_ds_schedules_A_worker_group(); |
||||
DROP FUNCTION ac_dolphin_T_t_ds_schedules_A_worker_group(); |
||||
|
||||
-- dc_dolphin_T_t_ds_schedules_D_worker_group_id |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS dc_dolphin_T_t_ds_schedules_D_worker_group_id(); |
||||
delimiter d// |
||||
CREATE FUNCTION dc_dolphin_T_t_ds_schedules_D_worker_group_id() RETURNS void AS $$ |
||||
BEGIN |
||||
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_schedules' |
||||
AND COLUMN_NAME ='worker_group_id') |
||||
THEN |
||||
ALTER TABLE t_ds_schedules DROP COLUMN worker_group_id; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select dc_dolphin_T_t_ds_schedules_D_worker_group_id(); |
||||
DROP FUNCTION dc_dolphin_T_t_ds_schedules_D_worker_group_id(); |
||||
|
||||
-- ac_dolphin_T_t_ds_command_A_worker_group |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_command_A_worker_group(); |
||||
delimiter d// |
||||
CREATE FUNCTION ac_dolphin_T_t_ds_command_A_worker_group() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_command' |
||||
AND COLUMN_NAME ='worker_group') |
||||
THEN |
||||
ALTER TABLE t_ds_command ADD COLUMN worker_group varchar(64) DEFAULT null; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select ac_dolphin_T_t_ds_command_A_worker_group(); |
||||
DROP FUNCTION ac_dolphin_T_t_ds_command_A_worker_group(); |
||||
|
||||
-- dc_dolphin_T_t_ds_command_D_worker_group_id |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS dc_dolphin_T_t_ds_command_D_worker_group_id(); |
||||
delimiter d// |
||||
CREATE FUNCTION dc_dolphin_T_t_ds_command_D_worker_group_id() RETURNS void AS $$ |
||||
BEGIN |
||||
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_command' |
||||
AND COLUMN_NAME ='worker_group_id') |
||||
THEN |
||||
ALTER TABLE t_ds_command DROP COLUMN worker_group_id; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select dc_dolphin_T_t_ds_command_D_worker_group_id(); |
||||
DROP FUNCTION dc_dolphin_T_t_ds_command_D_worker_group_id(); |
||||
|
||||
-- ac_dolphin_T_t_ds_error_command_A_worker_group |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_error_command_A_worker_group(); |
||||
delimiter d// |
||||
CREATE FUNCTION ac_dolphin_T_t_ds_error_command_A_worker_group() RETURNS void AS $$ |
||||
BEGIN |
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_error_command' |
||||
AND COLUMN_NAME ='worker_group') |
||||
THEN |
||||
ALTER TABLE t_ds_error_command ADD COLUMN worker_group varchar(64) DEFAULT null; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select ac_dolphin_T_t_ds_error_command_A_worker_group(); |
||||
DROP FUNCTION ac_dolphin_T_t_ds_error_command_A_worker_group(); |
||||
|
||||
-- dc_dolphin_T_t_ds_error_command_D_worker_group_id |
||||
delimiter ; |
||||
DROP FUNCTION IF EXISTS dc_dolphin_T_t_ds_error_command_D_worker_group_id(); |
||||
delimiter d// |
||||
CREATE FUNCTION dc_dolphin_T_t_ds_error_command_D_worker_group_id() RETURNS void AS $$ |
||||
BEGIN |
||||
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS |
||||
WHERE TABLE_CATALOG=current_database() |
||||
AND TABLE_SCHEMA=current_schema() |
||||
AND TABLE_NAME='t_ds_error_command' |
||||
AND COLUMN_NAME ='worker_group_id') |
||||
THEN |
||||
ALTER TABLE t_ds_error_command DROP COLUMN worker_group_id; |
||||
END IF; |
||||
END; |
||||
$$ LANGUAGE plpgsql; |
||||
d// |
||||
delimiter ; |
||||
select dc_dolphin_T_t_ds_error_command_D_worker_group_id(); |
||||
DROP FUNCTION dc_dolphin_T_t_ds_error_command_D_worker_group_id(); |
||||
|
||||
|
||||
Loading…
Reference in new issue