From eba854d81d8d95657baf7625b3f338ae8a5993cc Mon Sep 17 00:00:00 2001 From: Lex Li Date: Thu, 16 May 2024 14:13:16 +0800 Subject: [PATCH] [Optimization] [SQL] Optimize Dinky task's statement column length to avoid sql statement too long error (#3471) Signed-off-by: Zzm0809 <934230207@qq.com> Co-authored-by: Zzm0809 <934230207@qq.com> --- script/sql/dinky-mysql.sql | 6 +++--- script/sql/upgrade/1.1.0_schema/mysql/dinky_ddl.sql | 6 ++++++ 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/script/sql/dinky-mysql.sql b/script/sql/dinky-mysql.sql index eb1c403af4..87003fe050 100644 --- a/script/sql/dinky-mysql.sql +++ b/script/sql/dinky-mysql.sql @@ -1182,7 +1182,7 @@ CREATE TABLE `dinky_history` ( `status` int(11) NOT NULL DEFAULT 0 COMMENT 'status', `batch_model` boolean NOT NULL DEFAULT false COMMENT 'is batch model', `type` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'job type', - `statement` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'statement set', + `statement` mediumtext CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'statement set', `error` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'error message', `result` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'result set', `config_json` json NULL COMMENT 'config json', @@ -1344,7 +1344,7 @@ CREATE TABLE `dinky_task` ( `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'create time', `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 'update time', `version_id` int(11) NULL DEFAULT NULL COMMENT 'version id', - `statement` longtext default null COMMENT ' sql statement', + `statement` mediumtext DEFAULT NULL COMMENT 'sql statement', `creator` int(11) DEFAULT NULL COMMENT 'creator', `updater` int(11) DEFAULT NULL COMMENT 'updater', `operator` int(11) DEFAULT NULL COMMENT 'operator user id', @@ -1363,7 +1363,7 @@ CREATE TABLE `dinky_task_version` ( `task_id` int(11) NOT NULL COMMENT 'task ID ', `tenant_id` int(11) NOT NULL DEFAULT 1 COMMENT 'tenant id', `version_id` int(11) NOT NULL COMMENT 'version ID ', - `statement` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'flink sql statement', + `statement` mediumtext CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'flink sql statement', `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'version name', `dialect` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'dialect', `type` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'type', diff --git a/script/sql/upgrade/1.1.0_schema/mysql/dinky_ddl.sql b/script/sql/upgrade/1.1.0_schema/mysql/dinky_ddl.sql index ad2f682516..17ba8d604c 100644 --- a/script/sql/upgrade/1.1.0_schema/mysql/dinky_ddl.sql +++ b/script/sql/upgrade/1.1.0_schema/mysql/dinky_ddl.sql @@ -29,4 +29,10 @@ ALTER TABLE dinky_task ALTER TABLE dinky_task add COLUMN `second_level_owners` varchar(128) DEFAULT NULL comment 'list of secondary responsible persons ids'; +ALTER TABLE dinky_history CHANGE COLUMN `statement` `statement` mediumtext DEFAULT NULL COMMENT 'statement set'; + +ALTER TABLE dinky_task CHANGE COLUMN `statement` `statement` mediumtext DEFAULT NULL COMMENT 'sql statement'; + +ALTER TABLE dinky_task_version CHANGE COLUMN `statement` `statement` mediumtext DEFAULT NULL COMMENT 'flink sql statement'; + SET FOREIGN_KEY_CHECKS = 1;