Apache DolphinScheduler 3.2.2版本MySQL升级SQL语法问题解析

在Apache DolphinScheduler 3.2.2版本的数据库升级过程中，当执行MySQL升级脚本时可能会遇到SQL语法错误。这个问题主要出现在3.2.0_schema升级路径下的dolphinscheduler_dml.sql文件中。

问题现象

当用户从3.1.5版本升级到3.2.2版本时，按照标准升级流程执行MySQL升级脚本会出现以下错误：

ERROR 1064 (42000) at line 34: You have an error in your SQL syntax...

错误发生在执行dolphinscheduler_dml.sql文件时，具体位置是在处理存储过程和分隔符相关的语句处。

问题原因分析

经过深入分析，发现问题的根源在于SQL脚本中分隔符(delimiter)的使用方式存在问题。在MySQL中，当需要定义存储过程、函数或触发器时，由于这些对象内部会包含分号(;)，所以需要临时修改分隔符以避免MySQL客户端提前解析分号。

原脚本中存在以下问题：

1. 分隔符修改语句(delimiter d//)和存储过程定义语句之间缺少必要的换行或空格
2. 存储过程定义结束后，分隔符恢复语句(delimiter ;)与后续SQL语句直接相连
3. 整体脚本格式不够清晰，可能导致MySQL解析器混淆

解决方案

正确的SQL脚本应该采用以下结构：

-- 首先确保删除可能已存在的同名存储过程
DROP PROCEDURE IF EXISTS dolphin_t_ds_tenant_insert_default;

-- 修改分隔符以正确定义存储过程
delimiter d//
CREATE PROCEDURE dolphin_t_ds_tenant_insert_default()
BEGIN
    IF NOT EXISTS(SELECT 1 FROM t_ds_tenant WHERE id = -1) THEN
        INSERT INTO `t_ds_tenant` VALUES ('-1', 'default', 'default tenant', '1', current_timestamp, current_timestamp);
    END IF;
END;
d//

-- 恢复标准分隔符
delimiter ;

-- 执行租户相关的数据更新
UPDATE `t_ds_user` SET `tenant_id` = '-1' WHERE (`user_name` = 'admin') AND (`tenant_id` = '0');

-- 调用存储过程并清理
CALL dolphin_t_ds_tenant_insert_default();
DROP PROCEDURE dolphin_t_ds_tenant_insert_default;

技术要点说明

1. MySQL分隔符机制：在MySQL客户端中，默认使用分号(;)作为语句结束符。当定义包含分号的存储对象时，需要临时修改分隔符。

2. 存储过程定义规范：

   • 使用DROP PROCEDURE IF EXISTS确保不会因重复定义而报错
   • 修改分隔符后，新分隔符(如d//)应独占一行
   • 存储过程定义结束后，应立即恢复标准分隔符

3. 升级脚本设计原则：

   • 每个SQL语句应保持独立性和清晰性
   • 临时对象(如存储过程)使用后应及时清理
   • 包含充分的注释说明每个步骤的作用

最佳实践建议

对于分布式任务调度系统的数据库升级，建议采取以下措施：

1. 预检查：在执行升级脚本前，先检查目标数据库版本和当前系统版本是否匹配

2. 备份优先：执行升级前务必备份现有数据库

3. 测试验证：在测试环境先验证升级脚本，确认无误后再在生产环境执行

4. 分步执行：对于复杂的升级脚本，可考虑分步执行并验证每步结果

5. 错误处理：准备回滚方案，确保升级失败时可快速恢复

通过遵循这些原则，可以确保Apache DolphinScheduler的数据库升级过程更加平滑可靠。