MySQL插入报错Error 1242：子查询返回多行，求排查方案

执行INSERT语句向top_semanal表插入数据时，反复出现**Error 1242（子查询返回多行）**错误，且相同数据环境下有时正常有时报错。需求是筛选出运动Escalada下经验值最高的3位用户，插入“每周排行榜”表top_semanal，并要求该查询作为触发器稳定运行。

使用的INSERT语句：

INSERT INTO top_semanal (id_usu, deporte)
SELECT DISTINCT actividades.dueno, actividades.deporte
FROM actividades
INNER JOIN usuario
ON actividades.dueno=usuario.id
WHERE actividades.deporte='Escalada'
ORDER BY usuario.Exp DESC
LIMIT 3;

数据库表关系：activities（用户活动表）与usuario（用户表）为一对多关系，top_semanal为排行榜表。

补充：top_semanal表存在插入触发器，代码如下：

BEGIN
    UPDATE insignias_usuarios
    SET proceso_Top = proceso_Top + 1
    WHERE id_usu = NEW.id_usu;
    
    IF ((SELECT proceso_Top FROM insignias_usuarios WHERE id_usu=NEW.id_usu AND proceso_Top=1 OR
        proceso_Top=3)IS NOT NULL) THEN
            UPDATE insignias_usuarios
            SET nivel_Top = nivel_Top + 1, nivel_Top_Next = nivel_Top_Next + 1
            WHERE id_usu = NEW.id_usu;  
    ELSEIF((SELECT proceso_Top FROM insignias_usuarios WHERE id_usu=NEW.id_usu AND proceso_Top=10)IS NOT NULL) THEN
        UPDATE insignias_usuarios
        SET nivel_Top = nivel_Top + 1, nivel_Top_Next = 1
        WHERE id_usu = NEW.id_usu;
    END IF;
END

疑问：是否因为触发器未逐行触发、而是同时执行导致的错误？使用环境为XAMPP下的MySQL。

错误根源 #

Error 1242的直接原因是触发器中的子查询返回多行，和触发器是否逐行触发无关（MySQL的INSERT触发器默认是逐行触发的，NEW代表当前插入的单行数据）。

触发器中的IF条件存在逻辑错误：

SELECT proceso_Top FROM insignias_usuarios WHERE id_usu=NEW.id_usu AND proceso_Top=1 OR proceso_Top=3

由于SQL中AND的优先级高于OR，该条件实际等价于：

(id_usu=NEW.id_usu AND proceso_Top=1) OR proceso_Top=3

这会返回所有proceso_Top=3的用户数据，而非仅当前插入用户的行，当存在多个proceso_Top=3的用户时，子查询就会返回多行，触发Error 1242。

修复步骤 #

1. 修正触发器的条件逻辑
   将OR的条件用括号包裹，确保仅查询当前用户的匹配行：

   BEGIN
       UPDATE insignias_usuarios
       SET proceso_Top = proceso_Top + 1
       WHERE id_usu = NEW.id_usu;
       
       -- 修正括号，限定仅当前用户的proceso_Top为1或3的情况
       IF ((SELECT proceso_Top FROM insignias_usuarios WHERE id_usu=NEW.id_usu AND (proceso_Top=1 OR proceso_Top=3)) IS NOT NULL) THEN
               UPDATE insignias_usuarios
               SET nivel_Top = nivel_Top + 1, nivel_Top_Next = nivel_Top_Next + 1
               WHERE id_usu = NEW.id_usu;  
       ELSEIF ((SELECT proceso_Top FROM insignias_usuarios WHERE id_usu=NEW.id_usu AND proceso_Top=10) IS NOT NULL) THEN
           UPDATE insignias_usuarios
           SET nivel_Top = nivel_Top + 1, nivel_Top_Next = 1
           WHERE id_usu = NEW.id_usu;
       END IF;
   END
   

   更优化的写法是直接使用更新后的proceso_Top值判断，避免子查询：

   BEGIN
       DECLARE current_proceso INT;
       UPDATE insignias_usuarios
       SET proceso_Top = proceso_Top + 1
       WHERE id_usu = NEW.id_usu;
       
       SELECT proceso_Top INTO current_proceso FROM insignias_usuarios WHERE id_usu=NEW.id_usu;
       
       IF current_proceso IN (1,3) THEN
               UPDATE insignias_usuarios
               SET nivel_Top = nivel_Top + 1, nivel_Top_Next = nivel_Top_Next + 1
               WHERE id_usu = NEW.id_usu;  
       ELSEIF current_proceso = 10 THEN
           UPDATE insignias_usuarios
           SET nivel_Top = nivel_Top + 1, nivel_Top_Next = 1
           WHERE id_usu = NEW.id_usu;
       END IF;
   END
   

2. 优化INSERT语句，避免重复用户
   原语句中的DISTINCT可能无法完全避免重复用户（比如同一用户有多条Escalada活动记录），建议先按用户分组，确保每个用户仅被选中一次：

   INSERT INTO top_semanal (id_usu, deporte)
   SELECT u.id, 'Escalada'
   FROM usuario u
   INNER JOIN actividades a ON u.id = a.dueno
   WHERE a.deporte='Escalada'
   GROUP BY u.id
   ORDER BY u.Exp DESC
   LIMIT 3;
   

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