add worker_group field and remove worker_group_id field of the table... (0bad7c2f) · Commits · SUMMER2020 / students / proj-2002252

sql/upgrade/1.2.2_schema/mysql/dolphinscheduler_ddl.sql

+79 −0

Original line number	Diff line number	Diff line
		@@ -277,4 +277,83 @@ 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(255) 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(255) 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;

sql/upgrade/1.2.2_schema/postgresql/dolphinscheduler_ddl.sql

+84 −0

Original line number	Diff line number	Diff line
		@@ -279,4 +279,88 @@ 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(255) 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(255) 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();