From f0881b65a1a023c7fe72d354d3266bc113bc3360 Mon Sep 17 00:00:00 2001
From: calvin <jianghuachinacom@163.com>
Date: Wed, 17 May 2023 08:59:24 +0800
Subject: [PATCH] fix syntax errors (#14124)

---
 .../postgresql/dolphinscheduler_ddl.sql       | 104 ++++++++++++------
 1 file changed, 70 insertions(+), 34 deletions(-)

diff --git a/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.2.0_schema/postgresql/dolphinscheduler_ddl.sql b/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.2.0_schema/postgresql/dolphinscheduler_ddl.sql
index e5c22cd5b5..233676c3a5 100644
--- a/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.2.0_schema/postgresql/dolphinscheduler_ddl.sql
+++ b/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.2.0_schema/postgresql/dolphinscheduler_ddl.sql
@@ -26,7 +26,8 @@ BEGIN
           AND TABLE_NAME='t_ds_command'
           AND COLUMN_NAME ='test_flag')
       THEN
-ALTER TABLE t_ds_command alter column test_flag type int DEFAULT NULL;
+ALTER TABLE t_ds_command alter column test_flag type int;
+ALTER TABLE t_ds_command alter column test_flag set DEFAULT NULL;
 END IF;
 END;
 $$ LANGUAGE plpgsql;
@@ -47,7 +48,8 @@ BEGIN
           AND TABLE_NAME='t_ds_error_command'
           AND COLUMN_NAME ='test_flag')
       THEN
-ALTER TABLE t_ds_error_command alter column test_flag type int DEFAULT NULL;
+ALTER TABLE t_ds_error_command alter column test_flag type int;
+ALTER TABLE t_ds_error_command alter column test_flag set DEFAULT NULL;
 END IF;
 END;
 $$ LANGUAGE plpgsql;
@@ -68,8 +70,10 @@ BEGIN
           AND TABLE_NAME='t_ds_datasource'
           AND COLUMN_NAME ='test_flag')
       THEN
-ALTER TABLE t_ds_datasource alter column test_flag type int DEFAULT NULL;
-ALTER TABLE t_ds_datasource alter column bind_test_id type int DEFAULT NULL;
+ALTER TABLE t_ds_datasource alter column test_flag type int;
+ALTER TABLE t_ds_datasource alter column test_flag set DEFAULT NULL;
+ALTER TABLE t_ds_datasource alter column bind_test_id type int;
+ALTER TABLE t_ds_datasource alter column bind_test_id set DEFAULT NULL;
 END IF;
 END;
 $$ LANGUAGE plpgsql;
@@ -90,7 +94,8 @@ BEGIN
           AND TABLE_NAME='t_ds_process_instance'
           AND COLUMN_NAME ='test_flag')
       THEN
-ALTER TABLE t_ds_process_instance alter column test_flag type int DEFAULT NULL;
+ALTER TABLE t_ds_process_instance alter column test_flag type int;
+ALTER TABLE t_ds_process_instance alter column test_flag set DEFAULT NULL;
 END IF;
 END;
 $$ LANGUAGE plpgsql;
@@ -111,7 +116,8 @@ BEGIN
           AND TABLE_NAME='t_ds_task_instance'
           AND COLUMN_NAME ='test_flag')
       THEN
-ALTER TABLE t_ds_task_instance alter column test_flag type int DEFAULT NULL;
+ALTER TABLE t_ds_task_instance alter column test_flag type int;
+ALTER TABLE t_ds_task_instance alter column test_flag set DEFAULT NULL;
 END IF;
 END;
 $$ LANGUAGE plpgsql;
@@ -161,7 +167,9 @@ BEGIN
           AND TABLE_NAME='t_ds_process_instance'
           AND COLUMN_NAME ='project_code')
       THEN
-ALTER TABLE t_ds_process_instance ADD `project_code` bigint DEFAULT NULL COMMENT 'project code';
+ALTER TABLE t_ds_process_instance ADD project_code bigint;
+ALTER TABLE t_ds_process_instance alter column project_code set DEFAULT NULL;
+comment on column t_ds_process_instance.project_code is 'project code';
 END IF;
 IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           WHERE TABLE_CATALOG=current_database()
@@ -169,7 +177,9 @@ IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           AND TABLE_NAME='t_ds_process_instance'
           AND COLUMN_NAME ='executor_name')
       THEN
-ALTER TABLE t_ds_process_instance ADD `executor_name` varchar(64) DEFAULT NULL COMMENT 'execute user name';
+ALTER TABLE t_ds_process_instance ADD executor_name varchar(64);
+ALTER TABLE t_ds_process_instance alter column executor_name set DEFAULT NULL;
+comment on column t_ds_process_instance.executor_name is 'execute user name';
 END IF;
 IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           WHERE TABLE_CATALOG=current_database()
@@ -177,7 +187,9 @@ IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           AND TABLE_NAME='t_ds_process_instance'
           AND COLUMN_NAME ='tenant_code')
       THEN
-ALTER TABLE t_ds_process_instance ADD `tenant_code` varchar(64) DEFAULT NULL COMMENT 'tenant code';
+ALTER TABLE t_ds_process_instance ADD tenant_code varchar(64);
+ALTER TABLE t_ds_process_instance alter column tenant_code set DEFAULT NULL;
+comment on column t_ds_process_instance.tenant_code is 'tenant code';
 END IF;
 END;
 $$ LANGUAGE plpgsql;
@@ -198,7 +210,9 @@ BEGIN
           AND TABLE_NAME='t_ds_task_instance'
           AND COLUMN_NAME ='process_instance_name')
       THEN
-ALTER TABLE t_ds_task_instance ADD `process_instance_name` varchar(255) DEFAULT NULL COMMENT 'process instance name';
+ALTER TABLE t_ds_task_instance ADD process_instance_name varchar(255);
+ALTER TABLE t_ds_task_instance alter column process_instance_name set DEFAULT NULL;
+comment on column t_ds_task_instance.process_instance_name is 'process instance name';
 END IF;
 IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           WHERE TABLE_CATALOG=current_database()
@@ -206,7 +220,9 @@ IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           AND TABLE_NAME='t_ds_task_instance'
           AND COLUMN_NAME ='project_code')
       THEN
-ALTER TABLE t_ds_process_instance ADD `project_code` bigint DEFAULT NULL COMMENT 'project code';
+ALTER TABLE t_ds_process_instance ADD project_code bigint;
+ALTER TABLE t_ds_process_instance alter column project_code set DEFAULT NULL;
+comment on column t_ds_process_instance.project_code is 'project code';
 END IF;
 IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           WHERE TABLE_CATALOG=current_database()
@@ -214,7 +230,9 @@ IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           AND TABLE_NAME='t_ds_task_instance'
           AND COLUMN_NAME ='executor_name')
       THEN
-ALTER TABLE t_ds_task_instance ADD `executor_name` varchar(64) DEFAULT NULL COMMENT 'execute user name';
+ALTER TABLE t_ds_task_instance ADD executor_name varchar(64);
+ALTER TABLE t_ds_task_instance alter column executor_name set DEFAULT NULL;
+comment on column t_ds_task_instance.executor_name is 'execute user name';
 END IF;
 END;
 $$ LANGUAGE plpgsql;
@@ -223,25 +241,37 @@ delimiter ;
 select add_t_ds_task_instance_add_project_code();
 DROP FUNCTION add_t_ds_task_instance_add_project_code();
 
-ALTER TABLE `t_ds_alert`
-    MODIFY `title` varchar(512) DEFAULT NULL ;
-
-ALTER TABLE `t_ds_command` MODIFY `worker_group` varchar(255);
-ALTER TABLE `t_ds_project` MODIFY name varchar(255) DEFAULT NULL ;
-ALTER TABLE `t_ds_schedules` MODIFY worker_group varchar(255);
-ALTER TABLE `t_ds_task_instance` MODIFY worker_group varchar(255);
-ALTER TABLE `t_ds_udfs` MODIFY func_name varchar(255) NOT NULL ;
-ALTER TABLE `t_ds_version` MODIFY version varchar(63) NOT NULL;
-ALTER TABLE `t_ds_plugin_define` MODIFY plugin_name varchar(255) NOT NULL;
-ALTER TABLE `t_ds_plugin_define` MODIFY plugin_type varchar(63) NOT NULL;
-ALTER TABLE `t_ds_alert_plugin_instance` MODIFY instance_name varchar(255) NULL;
-ALTER TABLE `t_ds_dq_rule` MODIFY "name" varchar(255) DEFAULT NULL;
-ALTER TABLE `t_ds_environment` MODIFY name varchar(255) DEFAULT NULL;
-ALTER TABLE `t_ds_task_group_queue` MODIFY task_name    VARCHAR(255) DEFAULT NULL ;
-ALTER TABLE `t_ds_task_group` MODIFY name        varchar(255) DEFAULT NULL ;
-ALTER TABLE `t_ds_k8s` MODIFY k8s_name    VARCHAR(255) DEFAULT NULL ;
-ALTER TABLE `t_ds_k8s_namespace` MODIFY namespace          varchar(255) DEFAULT NULL ;
-ALTER TABLE `t_ds_cluster` MODIFY name        varchar(255) DEFAULT NULL;
+ALTER TABLE t_ds_alert alter column title type varchar(512);
+ALTER TABLE t_ds_alert alter column title set DEFAULT NULL;
+ALTER TABLE t_ds_command alter column worker_group type varchar(255);
+ALTER TABLE t_ds_project alter column name type varchar(255);
+ALTER TABLE t_ds_project alter column name set DEFAULT NULL;
+ALTER TABLE t_ds_schedules alter column worker_group type varchar(255);
+ALTER TABLE t_ds_task_instance alter column worker_group type varchar(255);
+ALTER TABLE t_ds_udfs alter column func_name type varchar(255);
+ALTER TABLE t_ds_udfs alter column func_name set NOT NULL ;
+ALTER TABLE t_ds_version alter column version type varchar(63);
+ALTER TABLE t_ds_version alter column version set NOT NULL;
+ALTER TABLE t_ds_plugin_define alter column plugin_name type varchar(255);
+ALTER TABLE t_ds_plugin_define alter column plugin_name set NOT NULL;
+ALTER TABLE t_ds_plugin_define alter column plugin_type type varchar(63);
+ALTER TABLE t_ds_plugin_define alter column plugin_type set NOT NULL;
+ALTER TABLE t_ds_alert_plugin_instance alter column instance_name type varchar(255);
+ALTER TABLE t_ds_alert_plugin_instance alter column instance_name set DEFAULT NULL;
+ALTER TABLE t_ds_dq_rule alter column name type varchar(255);
+ALTER TABLE t_ds_dq_rule alter column name set DEFAULT NULL;
+ALTER TABLE t_ds_environment alter column name type varchar(255);
+ALTER TABLE t_ds_environment alter column name set DEFAULT NULL;
+ALTER TABLE t_ds_task_group_queue alter column task_name type VARCHAR(255);
+ALTER TABLE t_ds_task_group_queue alter column task_name set DEFAULT NULL ;
+ALTER TABLE t_ds_task_group alter column name type varchar(255);
+ALTER TABLE t_ds_task_group alter column name set DEFAULT NULL ;
+ALTER TABLE t_ds_k8s alter column k8s_name type VARCHAR(255);
+ALTER TABLE t_ds_k8s alter column k8s_name set DEFAULT NULL ;
+ALTER TABLE t_ds_k8s_namespace alter column namespace type varchar(255);
+ALTER TABLE t_ds_k8s_namespace alter column namespace set DEFAULT NULL;
+ALTER TABLE t_ds_cluster alter column name type varchar(255);
+ALTER TABLE t_ds_cluster alter column name set DEFAULT NULL;
 
 -- tenant improvement
 delimiter ;
@@ -255,7 +285,9 @@ BEGIN
           AND TABLE_NAME='t_ds_command'
           AND COLUMN_NAME ='tenant_code')
       THEN
-ALTER TABLE t_ds_command ADD `tenant_code` varchar(64) DEFAULT 'default' COMMENT 'tenant code';
+ALTER TABLE t_ds_command ADD tenant_code varchar(64);
+ALTER TABLE t_ds_command alter column tenant_code set DEFAULT 'default';
+comment on column t_ds_command.tenant_code is 'tenant code';
 END IF;
 IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           WHERE TABLE_CATALOG=current_database()
@@ -263,7 +295,9 @@ IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           AND TABLE_NAME='t_ds_error_command'
           AND COLUMN_NAME ='tenant_code')
       THEN
-ALTER TABLE t_ds_error_command ADD `tenant_code` varchar(64) DEFAULT 'default' COMMENT 'tenant code';
+ALTER TABLE t_ds_error_command ADD tenant_code varchar(64);
+ALTER TABLE t_ds_error_command alter column tenant_code set DEFAULT 'default';
+comment on column t_ds_error_command.tenant_code is 'tenant code';
 END IF;
 IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           WHERE TABLE_CATALOG=current_database()
@@ -271,7 +305,9 @@ IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS
           AND TABLE_NAME='t_ds_schedules'
           AND COLUMN_NAME ='tenant_code')
       THEN
-ALTER TABLE t_ds_schedules ADD `tenant_code` varchar(64) DEFAULT NULL COMMENT 'tenant code';
+ALTER TABLE t_ds_schedules ADD tenant_code varchar(64);
+ALTER TABLE t_ds_schedules alter column tenant_code  set DEFAULT NULL;
+comment on column t_ds_schedules.tenant_code is 'tenant code';
 END IF;
 END;
 $$ LANGUAGE plpgsql;