[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>
DataLinkDC · May 16, 2024 · eba854d · eba854d
1 parent 6801c4f
commit eba854d
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git 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
@@ -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;