You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by jo...@apache.org on 2020/05/25 02:18:08 UTC
[incubator-dolphinscheduler] branch dev-1.3.0 updated: rename
worker_group_id to worker_group and set the value of worker_group_name
(#2801)
This is an automated email from the ASF dual-hosted git repository.
journey pushed a commit to branch dev-1.3.0
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git
The following commit(s) were added to refs/heads/dev-1.3.0 by this push:
new 470bd59 rename worker_group_id to worker_group and set the value of worker_group_name (#2801)
470bd59 is described below
commit 470bd59db708ea70e203744d4a9428dbf00e7d47
Author: lgcareer <18...@163.com>
AuthorDate: Mon May 25 10:18:01 2020 +0800
rename worker_group_id to worker_group and set the value of worker_group_name (#2801)
---
.../1.3.0_schema/mysql/dolphinscheduler_ddl.sql | 160 ++++---------------
.../1.3.0_schema/mysql/dolphinscheduler_dml.sql | 5 +
.../postgresql/dolphinscheduler_ddl.sql | 170 +++++----------------
.../postgresql/dolphinscheduler_dml.sql | 7 +-
4 files changed, 76 insertions(+), 266 deletions(-)
diff --git a/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql b/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql
index d4eeac5..2dd72ac 100644
--- a/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql
+++ b/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql
@@ -157,205 +157,105 @@ 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;
+-- uc_dolphin_T_t_ds_process_instance_R_worker_group_id
+drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_process_instance_R_worker_group_id;
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()
+CREATE PROCEDURE uc_dolphin_T_t_ds_process_instance_R_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;
+ ALTER TABLE t_ds_process_instance change `worker_group_id` `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group';
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;
+CALL uc_dolphin_T_t_ds_process_instance_R_worker_group_id;
+DROP PROCEDURE uc_dolphin_T_t_ds_process_instance_R_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;
+-- uc_dolphin_T_t_ds_task_instance_R_worker_group_id
+drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_task_instance_R_worker_group_id;
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()
+CREATE PROCEDURE uc_dolphin_T_t_ds_task_instance_R_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;
+ ALTER TABLE t_ds_task_instance change `worker_group_id` `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group';
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;
+CALL uc_dolphin_T_t_ds_task_instance_R_worker_group_id;
+DROP PROCEDURE uc_dolphin_T_t_ds_task_instance_R_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;
+-- uc_dolphin_T_t_ds_schedules_R_worker_group_id
+drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_schedules_R_worker_group_id;
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()
+CREATE PROCEDURE uc_dolphin_T_t_ds_schedules_R_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';
+ ALTER TABLE t_ds_schedules change `worker_group_id` `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;
+CALL uc_dolphin_T_t_ds_schedules_R_worker_group_id;
+DROP PROCEDURE uc_dolphin_T_t_ds_schedules_R_worker_group_id;
--- dc_dolphin_T_t_ds_command_D_worker_group_id
-drop PROCEDURE if EXISTS dc_dolphin_T_t_ds_command_D_worker_group_id;
+-- uc_dolphin_T_t_ds_command_R_worker_group_id
+drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_command_R_worker_group_id;
delimiter d//
-CREATE PROCEDURE dc_dolphin_T_t_ds_command_D_worker_group_id()
+CREATE PROCEDURE uc_dolphin_T_t_ds_command_R_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';
+ ALTER TABLE t_ds_command change `worker_group_id` `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;
+CALL uc_dolphin_T_t_ds_command_R_worker_group_id;
+DROP PROCEDURE uc_dolphin_T_t_ds_command_R_worker_group_id;
--- 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;
+-- uc_dolphin_T_t_ds_error_command_R_worker_group_id
+drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_error_command_R_worker_group_id;
delimiter d//
-CREATE PROCEDURE dc_dolphin_T_t_ds_error_command_D_worker_group_id()
+CREATE PROCEDURE uc_dolphin_T_t_ds_error_command_R_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;
+ ALTER TABLE t_ds_error_command change `worker_group_id` `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group';
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;
+CALL uc_dolphin_T_t_ds_error_command_R_worker_group_id;
+DROP PROCEDURE uc_dolphin_T_t_ds_error_command_R_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;
diff --git a/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_dml.sql b/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_dml.sql
index 67b005f..6f0e145 100644
--- a/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_dml.sql
+++ b/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_dml.sql
@@ -19,3 +19,8 @@ SET FOREIGN_KEY_CHECKS=0;
UPDATE t_ds_resources SET pid=-1,is_directory=false WHERE pid IS NULL;
UPDATE t_ds_resources SET full_name = concat('/',alias) WHERE pid=-1 and full_name IS NULL;
UPDATE QRTZ_JOB_DETAILS SET JOB_CLASS_NAME='org.apache.dolphinscheduler.service.quartz.ProcessScheduleJob' WHERE JOB_CLASS_NAME='org.apache.dolphinscheduler.server.quartz.ProcessScheduleJob';
+UPDATE t_ds_process_instance instance SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE instance.worker_group=CONCAT(id,'')),'default');
+UPDATE t_ds_task_instance instance SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE instance.worker_group=CONCAT(id,'')),'default');
+UPDATE t_ds_schedules schedule SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE schedule.worker_group=CONCAT(id,'')),'default');
+UPDATE t_ds_command command SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE command.worker_group=CONCAT(id,'')),'default');
+UPDATE t_ds_error_command command SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE command.worker_group=CONCAT(id,'')),'default');
\ No newline at end of file
diff --git a/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql b/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql
index 16a49a8..b9d55bd 100644
--- a/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql
+++ b/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql
@@ -152,32 +152,11 @@ 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
+-- uc_dolphin_T_t_ds_process_instance_R_worker_group_id
delimiter ;
-DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_process_instance_A_worker_group();
+DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_process_instance_R_worker_group_id();
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 $$
+CREATE FUNCTION uc_dolphin_T_t_ds_process_instance_R_worker_group_id() RETURNS void AS $$
BEGIN
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS
WHERE TABLE_CATALOG=current_database()
@@ -185,42 +164,22 @@ BEGIN
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;
+ ALTER TABLE t_ds_process_instance RENAME worker_group_id TO worker_group;
+ ALTER TABLE t_ds_process_instance ALTER COLUMN worker_group type varchar(64);
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();
+select uc_dolphin_T_t_ds_process_instance_R_worker_group_id();
+DROP FUNCTION uc_dolphin_T_t_ds_process_instance_R_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
+-- uc_dolphin_T_t_ds_task_instance_R_worker_group_id
delimiter ;
-DROP FUNCTION IF EXISTS dc_dolphin_T_t_ds_task_instance_D_worker_group_id();
+DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_task_instance_R_worker_group_id();
delimiter d//
-CREATE FUNCTION dc_dolphin_T_t_ds_task_instance_D_worker_group_id() RETURNS void AS $$
+CREATE FUNCTION uc_dolphin_T_t_ds_task_instance_R_worker_group_id() RETURNS void AS $$
BEGIN
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS
WHERE TABLE_CATALOG=current_database()
@@ -228,41 +187,21 @@ BEGIN
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;
+ ALTER TABLE t_ds_task_instance rename worker_group_id to worker_group;
+ ALTER TABLE t_ds_task_instance alter column worker_group type varchar(64);
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();
+select uc_dolphin_T_t_ds_task_instance_R_worker_group_id();
+DROP FUNCTION uc_dolphin_T_t_ds_task_instance_R_worker_group_id();
--- ac_dolphin_T_t_ds_schedules_A_worker_group
+-- uc_dolphin_T_t_ds_schedules_R_worker_group_id
delimiter ;
-DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_schedules_A_worker_group();
+DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_schedules_R_worker_group_id();
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 $$
+CREATE FUNCTION uc_dolphin_T_t_ds_schedules_R_worker_group_id() RETURNS void AS $$
BEGIN
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS
WHERE TABLE_CATALOG=current_database()
@@ -270,20 +209,21 @@ BEGIN
AND TABLE_NAME='t_ds_schedules'
AND COLUMN_NAME ='worker_group_id')
THEN
- ALTER TABLE t_ds_schedules DROP COLUMN worker_group_id;
+ ALTER TABLE t_ds_schedules rename worker_group_id to worker_group;
+ ALTER TABLE t_ds_schedules alter column worker_group type varchar(64);
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();
+select uc_dolphin_T_t_ds_schedules_R_worker_group_id();
+DROP FUNCTION uc_dolphin_T_t_ds_schedules_R_worker_group_id();
--- ac_dolphin_T_t_ds_command_A_worker_group
+-- uc_dolphin_T_t_ds_command_R_worker_group_id
delimiter ;
-DROP FUNCTION IF EXISTS ac_dolphin_T_t_ds_command_A_worker_group();
+DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_command_R_worker_group_id();
delimiter d//
-CREATE FUNCTION ac_dolphin_T_t_ds_command_A_worker_group() RETURNS void AS $$
+CREATE FUNCTION uc_dolphin_T_t_ds_command_R_worker_group_id() RETURNS void AS $$
BEGIN
IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
WHERE TABLE_CATALOG=current_database()
@@ -291,62 +231,21 @@ BEGIN
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;
+ ALTER TABLE t_ds_command rename worker_group_id to worker_group;
+ ALTER TABLE t_ds_command alter column worker_group type varchar(64);
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();
+select uc_dolphin_T_t_ds_command_R_worker_group_id();
+DROP FUNCTION uc_dolphin_T_t_ds_command_R_worker_group_id();
--- dc_dolphin_T_t_ds_error_command_D_worker_group_id
+-- uc_dolphin_T_t_ds_error_command_R_worker_group_id
delimiter ;
-DROP FUNCTION IF EXISTS dc_dolphin_T_t_ds_error_command_D_worker_group_id();
+DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_error_command_R_worker_group_id();
delimiter d//
-CREATE FUNCTION dc_dolphin_T_t_ds_error_command_D_worker_group_id() RETURNS void AS $$
+CREATE FUNCTION uc_dolphin_T_t_ds_error_command_R_worker_group_id() RETURNS void AS $$
BEGIN
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS
WHERE TABLE_CATALOG=current_database()
@@ -354,14 +253,15 @@ BEGIN
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;
+ ALTER TABLE t_ds_error_command rename worker_group_id to worker_group;
+ ALTER TABLE t_ds_error_command alter column worker_group type varchar(64);
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();
+select uc_dolphin_T_t_ds_error_command_R_worker_group_id();
+DROP FUNCTION uc_dolphin_T_t_ds_error_command_R_worker_group_id();
-- uc_dolphin_T_t_ds_process_definition_A_process_definition_unique
diff --git a/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_dml.sql b/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_dml.sql
index abf85cd..fba0315 100644
--- a/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_dml.sql
+++ b/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_dml.sql
@@ -16,4 +16,9 @@
*/
UPDATE t_ds_resources SET pid=-1,is_directory=false WHERE pid IS NULL;
UPDATE t_ds_resources SET full_name = concat('/',alias) WHERE pid=-1 and full_name IS NULL;
-UPDATE QRTZ_JOB_DETAILS SET JOB_CLASS_NAME='org.apache.dolphinscheduler.service.quartz.ProcessScheduleJob' WHERE JOB_CLASS_NAME='org.apache.dolphinscheduler.server.quartz.ProcessScheduleJob';
\ No newline at end of file
+UPDATE QRTZ_JOB_DETAILS SET JOB_CLASS_NAME='org.apache.dolphinscheduler.service.quartz.ProcessScheduleJob' WHERE JOB_CLASS_NAME='org.apache.dolphinscheduler.server.quartz.ProcessScheduleJob';
+UPDATE t_ds_process_instance instance SET worker_group=COALESCE((SELECT name from t_ds_worker_group WHERE instance.worker_group=CONCAT(id,'')),'default');
+UPDATE t_ds_task_instance instance SET worker_group=COALESCE((SELECT name from t_ds_worker_group WHERE instance.worker_group=CONCAT(id,'')),'default');
+UPDATE t_ds_schedules schedule SET worker_group=COALESCE((SELECT name from t_ds_worker_group WHERE schedule.worker_group=CONCAT(id,'')),'default');
+UPDATE t_ds_command command SET worker_group=COALESCE((SELECT name from t_ds_worker_group WHERE command.worker_group=CONCAT(id,'')),'default');
+UPDATE t_ds_error_command command SET worker_group=COALESCE((SELECT name from t_ds_worker_group WHERE command.worker_group=CONCAT(id,'')),'default');
\ No newline at end of file