修正MYSQL错误数据的一个存储过程

-- 添加索引
CREATE INDEX idx_STRUCTURE_ID ON t_resource_info(STRUCTURE_ID); 

DROP PROCEDURE IF EXISTS `P_RepairSchemeIdError`;

CREATE  PROCEDURE `P_RepairSchemeIdError`()
BEGIN
    DECLARE v_scheme_id_int int ;
    DECLARE v_maxId int;
  DECLARE v_CurrentId int;
    set v_scheme_id_int=100003059;
    select MAX(id), MIN(id) into v_maxId,v_CurrentId from t_resource_info where scheme_id_int=v_scheme_id_int;

  while (v_CurrentId<v_maxId) do 

        UPDATE t_resource_info p INNER JOIN t_resource_structure pp ON p.STRUCTURE_ID = pp.STRUCTURE_ID
        SET p.SCHEME_ID_INT = pp.SCHEME_ID_INT WHERE p.SCHEME_ID_INT=v_scheme_id_int and p.id<v_CurrentId;

        set v_CurrentId=v_CurrentId+100000;

    end while; 

    UPDATE t_resource_info p INNER JOIN t_resource_structure pp ON p.STRUCTURE_ID = pp.STRUCTURE_ID
        SET p.SCHEME_ID_INT = pp.SCHEME_ID_INT WHERE p.SCHEME_ID_INT=v_scheme_id_int;
END


call P_RepairSchemeIdError;