(streampark) branch dev updated: Solve the problem of missing error in schema field refs of t_flink_project table in pgsql and mysql databases (#4210)

[be...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new 4aa752610 Solve the problem of missing error in schema field refs of t_flink_project table in pgsql and mysql databases (#4210)
4aa752610 is described below

commit 4aa752610d25f43f5bd24d9bdab4f4867627ce37
Author: Aalron <48...@users.noreply.github.com>
AuthorDate: Tue Mar 18 23:30:05 2025 +0800

    Solve the problem of missing error in schema field refs of t_flink_project table in pgsql and mysql databases (#4210)
---
 .../src/main/assembly/script/schema/mysql-schema.sql                | 2 +-
 .../src/main/assembly/script/schema/pgsql-schema.sql                | 2 +-
 .../src/main/assembly/script/upgrade/mysql/2.2.0.sql                | 3 +++
 .../src/main/assembly/script/upgrade/pgsql/2.2.2.sql                | 6 ++++++
 4 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql b/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
index 25cc8c9ca..fc5023706 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
@@ -200,7 +200,7 @@ create table `t_flink_project` (
   `team_id` bigint not null,
   `name` varchar(255) collate utf8mb4_general_ci default null,
   `url` varchar(255) collate utf8mb4_general_ci default null,
-  `branches` varchar(64) collate utf8mb4_general_ci default null,
+  `refs` varchar(255) collate utf8mb4_general_ci default null,
   `user_name` varchar(64) collate utf8mb4_general_ci default null,
   `password` varchar(512) collate utf8mb4_general_ci default null,
   `prvkey_path` varchar(128) collate utf8mb4_general_ci default null,
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql b/streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
index 4462bd207..f002b8f70 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
@@ -434,7 +434,7 @@ create table "public"."t_flink_project" (
   "team_id" int8,
   "name" varchar(255) collate "pg_catalog"."default",
   "url" varchar(255) collate "pg_catalog"."default",
-  "branches" varchar(64) collate "pg_catalog"."default",
+  "refs" varchar(64) collate "pg_catalog"."default",
   "user_name" varchar(64) collate "pg_catalog"."default",
   "password" varchar(512) collate "pg_catalog"."default",
   "prvkey_path" varchar(128) collate "pg_catalog"."default",
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
index 13f86f0ed..3d7b8ac03 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
@@ -53,6 +53,9 @@ alter table `t_flink_project`
     add column `salt` varchar(26) collate utf8mb4_general_ci default null comment 'password salt',
     modify column `password` varchar(512) collate utf8mb4_general_ci default null comment 'password';
 
+ALTER TABLE `t_flink_project`
+    change column `branches` `refs` varchar(255) collate utf8mb4_general_ci default null;
+
 alter table `t_flink_sql`
     add column `team_resource` varchar(64) default null;
 
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.2.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.2.sql
index bc69fb9b6..b48af8148 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.2.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.2.sql
@@ -30,3 +30,9 @@ comment on column "public"."t_flink_project"."salt" is 'password salt';
 
 alter table "public"."t_flink_project"
     alter column `password` type varchar(512) collate "pg_catalog"."default";
+
+ALTER TABLE "public"."t_flink_project"
+    ALTER COLUMN "branches" TYPE varchar(255) collate "pg_catalog"."default";
+
+ALTER TABLE "public"."t_flink_project"
+    rename column "branches" to "refs";