MySQL 8.0存储函数JSON_OBJECT错误修复及动态WHERE子句实现

从你的代码来看，三个JSON_OBJECT调用的键值对都是成对的，理论上不会触发参数数量错误。导致该错误的最可能原因是**JSON_EXTRACT返回的是带双引号的JSON字符串**，导致WHERE条件无法匹配到数据，进而在某些分支下引发隐式的参数异常。

修复方案：

• 替换JSON_EXTRACT为->>操作符，直接获取不带双引号的字符串值，确保WHERE条件能正确匹配数据：
  比如将：

  SET ssoId = JSON_EXTRACT(user,'$.ssoId');
  

  改为：

  SET ssoId = user->>'$.ssoId';
  

  对所有JSON_EXTRACT调用做同样替换，包括emailId、firstName等变量的赋值，以及instructorId的判断逻辑。
• 额外检查：确认datahub.users表中所有在JSON_OBJECT中引用的字段都存在，避免因字段不存在导致的隐式参数异常。

在MySQL存储函数/过程中，可以通过拼接SQL字符串、预处理执行的方式实现动态WHERE条件（键和值都动态），示例代码如下：

BEGIN
    DECLARE ssoId VARCHAR(255) DEFAULT NULL;
    DECLARE emailId VARCHAR(255) DEFAULT NULL;
    DECLARE instructorId VARCHAR(255) DEFAULT NULL;
    DECLARE storedUser JSON DEFAULT NULL;
    DECLARE whereKey VARCHAR(64);
    DECLARE whereValue VARCHAR(255);
    DECLARE sqlStmt VARCHAR(1000);
    
    -- 简化JSON取值逻辑，使用->>获取无引号字符串
    SET ssoId = user->>'$.ssoId';
    SET emailId = user->>'$.email';
    SET instructorId = COALESCE(user->>'$.instructorId', user->>'$.instructorStudentId');
    
    -- 确定动态WHERE的键和值
    IF ssoId IS NOT NULL THEN
        SET whereKey = 'sso_id';
        SET whereValue = ssoId;
    ELSEIF instructorId IS NOT NULL THEN
        SET whereKey = 'instructor_id';
        SET whereValue = instructorId;
    ELSEIF emailId IS NOT NULL THEN
        SET whereKey = 'email';
        SET whereValue = emailId;
    ELSE
        -- 无查询条件时的默认返回
        RETURN -1;
    END IF;
    
    -- 拼接预处理SQL，用QUOTE函数防止SQL注入
    SET sqlStmt = CONCAT(
        'SELECT JSON_OBJECT(',
        '"id", id,',
        '"sso_id", sso_id,',
        '"email", email,',
        '"instructor_id", instructor_id,',
        '"first_name", first_name,',
        '"last_name", last_name,',
        '"source_created_at", source_created_at,',
        '"source_updated_at", source_updated_at',
        ') INTO @tempStoredUser FROM datahub.users WHERE ', whereKey, ' = ', QUOTE(whereValue)
    );
    
    -- 执行预处理语句
    PREPARE dynamicStmt FROM sqlStmt;
    EXECUTE dynamicStmt;
    DEALLOCATE PREPARE dynamicStmt;
    
    -- 将用户变量的值转给局部变量
    SET storedUser = @tempStoredUser;
    
    -- 清理临时用户变量（可选）
    SET @tempStoredUser = NULL;
    
    RETURN -1;
END;

关键注意点：

• 使用QUOTE()函数对动态值进行转义，避免SQL注入风险；
• 预处理语句无法直接将结果写入局部变量，因此先写入用户变量（@tempStoredUser）再转存；
• 必须处理无查询条件的分支，避免生成无效SQL。

内容的提问来源于stack exchange，提问作者Midhun Kumar