MySQL存储过程实现：将Table B非空值同步至匹配的Table A并删除对应行

先修正存储过程的问题，核心是避开MySQL不支持整行变量的限制，直接通过关联查询实现逻辑，同时保证操作的准确性：

DELIMITER //

CREATE PROCEDURE InsertAndSyncTables(
    IN NAME_IN VARCHAR(50),
    IN AGE_IN INT,
    IN HEIGHT_IN INT,
    IN WEIGHT_IN INT
)
BEGIN
    -- 1. 向TableA插入目标数据
    INSERT INTO tableA (NAME, AGE, HEIGHT, WEIGHT)
    VALUES (NAME_IN, AGE_IN, HEIGHT_IN, WEIGHT_IN);
    
    -- 2. 关联TableB匹配行，用B的非空值更新A对应字段
    UPDATE tableA a
    JOIN tableB b ON a.NAME = b.NAME
    SET 
        a.AGE = IFNULL(b.AGE, a.AGE),
        a.HEIGHT = IFNULL(b.HEIGHT, a.HEIGHT),
        a.WEIGHT = IFNULL(b.WEIGHT, a.WEIGHT)
    WHERE a.NAME = NAME_IN;
    
    -- 3. 删除TableB中已完成同步的行
    DELETE FROM tableB WHERE NAME = NAME_IN;
END //

DELIMITER ;

原存储过程的问题点 #

• MySQL不支持将整行查询结果存入单个变量（SELECT * INTO @Aentry 属于错误用法），变量仅能存储单个字段值。
• IF EXISTS 子查询内不能使用 INTO 语句，这会直接触发语法错误。
• 实际上无需查询TableA的插入行，因为我们已经明确要操作的是NAME_IN对应的记录，直接用该参数即可。

示例场景验证 #

执行调用语句：CALL InsertAndSyncTables('TIM', 4, 10, NULL);

1. 插入后TableA的TIM行初始为('TIM',4,10,NULL)
2. 关联TableB的TIM行（('TIM',NULL,20,20)），通过IFNULL保留TableA的非空AGE值（4），替换HEIGHT和WEIGHT为TableB的非空值（20、20）
3. 最后删除TableB中的TIM行，完全符合需求效果。

可选优化：事务保障原子性 #

如果需要确保插入、更新、删除操作要么全部成功要么全部回滚，可以添加事务控制：

DELIMITER //

CREATE PROCEDURE InsertAndSyncTables(
    IN NAME_IN VARCHAR(50),
    IN AGE_IN INT,
    IN HEIGHT_IN INT,
    IN WEIGHT_IN INT
)
BEGIN
    DECLARE EXIT HANDLER FOR SQLEXCEPTION
    BEGIN
        ROLLBACK;
        RESIGNAL;
    END;
    
    START TRANSACTION;
    
    INSERT INTO tableA (NAME, AGE, HEIGHT, WEIGHT)
    VALUES (NAME_IN, AGE_IN, HEIGHT_IN, WEIGHT_IN);
    
    UPDATE tableA a
    JOIN tableB b ON a.NAME = b.NAME
    SET 
        a.AGE = IFNULL(b.AGE, a.AGE),
        a.HEIGHT = IFNULL(b.HEIGHT, a.HEIGHT),
        a.WEIGHT = IFNULL(b.WEIGHT, a.WEIGHT)
    WHERE a.NAME = NAME_IN;
    
    DELETE FROM tableB WHERE NAME = NAME_IN;
    
    COMMIT;
END //

DELIMITER ;

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