MariaDB全表文本字段批量替换Vimeo链接为YouTube链接求助

原存储过程存在以下关键问题，导致执行无效果或报错：

1. 表/字段名未转义：当表名或字段名包含空格、特殊字符或MariaDB保留字时，直接拼接SQL会触发语法错误
2. 关联逻辑错误：使用JOIN url_mapping的方式批量替换，若单条记录的字段中包含多个不同的old_url，会导致重复更新；同时old_url中的%、_等LIKE通配符会被当作匹配符号，无法精准匹配目标URL
3. 遍历顺序不合理：先遍历字段再关联映射表，无法保证所有old_url都被逐一替换（同一字段内的多个不同old_url无法单次处理完成）

修正后的存储过程 #

DELIMITER //

CREATE PROCEDURE update_urls()
BEGIN
    DECLARE done INT DEFAULT FALSE;
    DECLARE v_old_url VARCHAR(255);
    DECLARE v_new_url VARCHAR(255);
    DECLARE table_name VARCHAR(255);
    DECLARE column_name VARCHAR(255);
    
    -- 定义映射表游标，遍历每条URL映射记录
    DECLARE url_cursor CURSOR FOR 
        SELECT old_url, new_url FROM url_mapping WHERE old_url IS NOT NULL AND new_url IS NOT NULL;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
    
    -- 开启事务（大型库建议开启，出错可回滚）
    START TRANSACTION;

    OPEN url_cursor;
    url_loop: LOOP
        FETCH url_cursor INTO v_old_url, v_new_url;
        IF done THEN
            LEAVE url_loop;
        END IF;

        -- 遍历所有文本类型字段
        DECLARE field_cursor CURSOR FOR 
            SELECT TABLE_NAME, COLUMN_NAME 
            FROM INFORMATION_SCHEMA.COLUMNS 
            WHERE TABLE_SCHEMA = DATABASE() 
            AND DATA_TYPE IN ('VARCHAR', 'TEXT', 'MEDIUMTEXT', 'LONGTEXT');
        DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
        
        OPEN field_cursor;
        field_loop: LOOP
            FETCH field_cursor INTO table_name, column_name;
            IF done THEN
                LEAVE field_loop;
            END IF;

            -- 拼接SQL：用反引号转义表/字段名，转义LIKE中的通配符，确保精准匹配
            SET @sql = CONCAT(
                'UPDATE `', table_name, '` t ',
                'SET t.`', column_name, '` = REPLACE(t.`', column_name, '`, ?, ?) ',
                'WHERE t.`', column_name, '` LIKE CONCAT(''%'', REPLACE(REPLACE(?, ''%'', ''\\%''), ''_'', ''\\_''), ''%'')'
            );
            
            -- 使用预处理语句传递参数，避免SQL注入，同时处理通配符转义
            PREPARE stmt FROM @sql;
            SET @old = v_old_url;
            SET @new = v_new_url;
            SET @escaped_old = v_old_url;
            EXECUTE stmt USING @old, @new, @escaped_old;
            DEALLOCATE PREPARE stmt;
        END LOOP field_loop;
        CLOSE field_cursor;
        -- 重置done标记，用于下一轮URL遍历
        SET done = FALSE;
    END LOOP url_loop;
    CLOSE url_cursor;

    -- 提交事务（若开启了事务）
    COMMIT;
END //

DELIMITER ;

关键改进点说明 #

1. 表/字段名转义：用反引号`包裹表名和字段名，避免特殊字符或保留字导致的语法错误
2. 遍历顺序调整：先遍历url_mapping的每条记录，再遍历所有文本字段，确保每个old_url都被全局替换
3. 通配符转义：对old_url中的%和_进行转义，保证LIKE能精准匹配目标URL，不会误匹配包含通配符的其他内容
4. 参数化预处理：使用USING传递参数，避免SQL注入风险，同时提升重复执行的效率
5. 事务控制：添加事务支持，若中途执行出错可回滚，避免数据部分更新导致的不一致
6. 空值过滤：映射表查询时过滤掉old_url或new_url为空的记录，避免无效操作

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