Skip to content

Commit 4aa7526

Browse files
authored
Solve the problem of missing error in schema field refs of t_flink_project table in pgsql and mysql databases (#4210)
1 parent 883f6f2 commit 4aa7526

File tree

4 files changed

+11
-2
lines changed

4 files changed

+11
-2
lines changed

streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql

+1-1
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@ create table `t_flink_project` (
200200
`team_id` bigint not null,
201201
`name` varchar(255) collate utf8mb4_general_ci default null,
202202
`url` varchar(255) collate utf8mb4_general_ci default null,
203-
`branches` varchar(64) collate utf8mb4_general_ci default null,
203+
`refs` varchar(255) collate utf8mb4_general_ci default null,
204204
`user_name` varchar(64) collate utf8mb4_general_ci default null,
205205
`password` varchar(512) collate utf8mb4_general_ci default null,
206206
`prvkey_path` varchar(128) collate utf8mb4_general_ci default null,

streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql

+1-1
Original file line numberDiff line numberDiff line change
@@ -434,7 +434,7 @@ create table "public"."t_flink_project" (
434434
"team_id" int8,
435435
"name" varchar(255) collate "pg_catalog"."default",
436436
"url" varchar(255) collate "pg_catalog"."default",
437-
"branches" varchar(64) collate "pg_catalog"."default",
437+
"refs" varchar(64) collate "pg_catalog"."default",
438438
"user_name" varchar(64) collate "pg_catalog"."default",
439439
"password" varchar(512) collate "pg_catalog"."default",
440440
"prvkey_path" varchar(128) collate "pg_catalog"."default",

streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql

+3
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,9 @@ alter table `t_flink_project`
5353
add column `salt` varchar(26) collate utf8mb4_general_ci default null comment 'password salt',
5454
modify column `password` varchar(512) collate utf8mb4_general_ci default null comment 'password';
5555

56+
ALTER TABLE `t_flink_project`
57+
change column `branches` `refs` varchar(255) collate utf8mb4_general_ci default null;
58+
5659
alter table `t_flink_sql`
5760
add column `team_resource` varchar(64) default null;
5861

streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.2.sql

+6
Original file line numberDiff line numberDiff line change
@@ -30,3 +30,9 @@ comment on column "public"."t_flink_project"."salt" is 'password salt';
3030

3131
alter table "public"."t_flink_project"
3232
alter column `password` type varchar(512) collate "pg_catalog"."default";
33+
34+
ALTER TABLE "public"."t_flink_project"
35+
ALTER COLUMN "branches" TYPE varchar(255) collate "pg_catalog"."default";
36+
37+
ALTER TABLE "public"."t_flink_project"
38+
rename column "branches" to "refs";

0 commit comments

Comments
 (0)