MySQL SQL优化——分片搜索

DELIMITER $$

DROP PROCEDURE IF EXISTS `test_release`.`Sp_JP_A_NotifyBegin`$$

CREATE DEFINER=`encysys48`@`%` PROCEDURE `Sp_JP_A_NotifyBegin`(
    OUT v_Result          varchar(10),  
    OUT v_OrderID         varchar(500), 
    OUT v_HFserialid      varchar(500), 
    OUT v_ChargeSerialID  varchar(500), 
    OUT v_ErrorCode       varchar(100), 
    OUT v_FullMoney       varchar(200), 
    OUT v_PlatId          varchar(200), 
    OUT v_NotifyCount     varchar(4),   
    OUT v_PHONERESMONEY   varchar(200), 
    OUT v_AGENTID         varchar(500)
)
    MODIFIES SQL DATA
    SQL SECURITY INVOKER
BEGIN
    label2: BEGIN
        DECLARE l_hforderid       varchar(30);
        DECLARE l_hfserialid      varchar(30);
        DECLARE l_errorcode       varchar(10);
        DECLARE l_charserialid    varchar(50);
        DECLARE l_fullmoney       decimal(10, 2);
        DECLARE l_platid          int(10);
        DECLARE l_notofynum       int(4);
        DECLARE l_status          int(4);
        DECLARE l_increce         int(10);
        DECLARE l_nowtime         timestamp;
        DECLARE l_phoneresmoney    varchar(30);
        DECLARE l_agentid         varchar(30);
        DECLARE l_CheckCode       varchar(100);
        DECLARE l_PlatCheckResult varchar(10);
        DECLARE l_stop_flag       int(2);
        DECLARE l_flag            int(2);  
        DECLARE l_cursorEmpty     int(2) DEFAULT 0; #游标是否为空标记位，0-为空  ;1-不为空
        DECLARE l_cursorOpen      int(2) DEFAULT 0; #游标是否打开标记位，0-没打开;1-已打开
        DECLARE l_cursorClose     int(2) DEFAULT 0; #游标是否关闭标记位，0-未关闭;1-已关闭
      
        #定义游标
        DECLARE cur_notify CURSOR FOR
        SELECT a.hf_serialid
          FROM (SELECT hf_serialid
              FROM jp_fullnote s
             WHERE charge_status IN (0, 3) 
               AND (notify_flag = 1 OR (notify_flag = 2 AND DATE_ADD(end_time, INTERVAL 3 MINUTE) < l_nowtime))
               AND DATE_ADD(begin_time, INTERVAL 48 HOUR) > l_nowtime
               AND DATE_ADD(begin_time, INTERVAL 3 HOUR) < l_nowtime
               ORDER BY DATE_ADD(end_time, INTERVAL notify_count MINUTE) ASC
            ) a
        LIMIT 0, 10;
      
        #其他异常  
        DECLARE EXIT HANDLER FOR SQLWARNING, SQLEXCEPTION, NOT FOUND
            BEGIN
            #先判断是否需要关闭游标：如果游标“已打开且未关闭”，则需要关闭
            IF l_cursorOpen = 1 AND l_cursorClose = 0 THEN
                CLOSE cur_notify;
            END IF;
            
            IF l_cursorEmpty = 0 THEN
                SET v_OrderID = '-1';
                SET v_HFserialid = '-1';
                SET v_ErrorCode = '-1';
                SET v_FullMoney = '-1';
                SET v_PlatId = '-1';
                SET v_result = '11111';
                SET v_PHONERESMONEY = '-1';
                SET v_AGENTID = '-1';
                ROLLBACK;
            ELSE
                SET v_result = '0';
                SET v_notifycount = l_increce;
                COMMIT;
            END IF;
            END;
      
        #赋初始值
        SET v_result = '82001';
        SET v_OrderID = '';
        SET v_HFserialid = '';
        SET v_ChargeSerialID = '';
        SET v_ErrorCode = '';
        SET v_FullMoney = '';
        SET v_PlatId = '';
        SET l_notofynum = 0;
        SET l_increce = 0;
        SET v_PHONERESMONEY = '';
        SET v_AGENTID = '';
        SET l_nowtime = now();
        SET l_stop_flag = 0;
        SET l_flag = 0;
      
        #自动流程监控
        SELECT CONCAT('ChPlat', t.sys_id, '_A8002_NotifyHF') INTO l_CheckCode
          FROM jp_sysplat t;
        CALL Sp_MO_PlatAutoCheck(l_CheckCode, '3B', l_PlatCheckResult);
      
        #使用游标
        BEGIN
        DECLARE EXIT HANDLER FOR SQLSTATE '02000'
            BEGIN
              SET l_stop_flag = 1;
            END;
        
        #打开游标
        OPEN cur_notify;
        SET l_cursorOpen = 1; #打开游标后，把游标打开的标记位置为1，表示已打开
        
        FETCH cur_notify INTO l_hfserialid;
        #进入游标循环
        label1: WHILE l_stop_flag < 1 DO
            #每次循环计数
            SET l_cursorEmpty = l_cursorEmpty + 1;
        
            SELECT charge_status,ERROR_CODE,hf_orderid,hf_serialid,finish_money,
               f.senderobj,charge_serialid,PHONE_RESMONEY,AGENT_ID 
              INTO l_status, l_errorcode, l_hforderid, l_hfserialid, l_fullmoney,
               l_platid, l_charserialid, l_phoneresmoney, l_agentid
              FROM jp_fullnote f
             WHERE hf_serialid = l_hfserialid;
        
            
            IF l_status = 3 THEN
            SET l_fullmoney = 0;
            END IF;
        
            
            BEGIN
            DECLARE EXIT HANDLER FOR SQLWARNING, SQLEXCEPTION, NOT FOUND 
                SET l_flag = 1;
      
            SELECT notify_return_code 
              INTO l_errorcode
              FROM jp_return_code r
             WHERE r.error_code = l_errorcode;
            END;
        
            IF l_flag = 1 THEN
            FETCH cur_notify INTO l_hfserialid;
            ITERATE label1;
            END IF;
        
            
            SET v_OrderID = CONCAT(v_OrderID, l_hforderid, ',');
            SET v_HFserialid = CONCAT(v_HFserialid, l_hfserialid, ',');
            SET v_ChargeSerialID = CONCAT(v_ChargeSerialID, l_charserialid, ',');
            SET v_ErrorCode = CONCAT(v_ErrorCode, l_errorcode, ',');
            SET v_FullMoney = CONCAT(v_FullMoney, l_fullmoney, ',');
            SET v_PlatId = CONCAT(v_PlatId, l_platid, ',');
        
            IF l_phoneresmoney > 10000 THEN
            SET v_PHONERESMONEY = CONCAT(v_PHONERESMONEY, '', ',');
            ELSE
            SET v_PHONERESMONEY = CONCAT(v_PHONERESMONEY, l_phoneresmoney, ',');
            END IF;
        
            SET v_AGENTID = CONCAT(v_AGENTID, l_agentid, ',');
        
            UPDATE jp_fullnote
               SET notify_flag = 2,
               notify_count = notify_count + 1,
               end_time = l_nowtime
            WHERE hf_serialid = l_hfserialid;
        
            SET l_increce = l_increce + 1;
            COMMIT;
        
             
            FETCH cur_notify INTO l_hfserialid;
        END WHILE label1;
        END;
      
        #关闭游标
        CLOSE cur_notify;
        SET l_cursorClose = 1; #关闭游标后，把游标关闭的标记位置为1，表示已关闭
      
        #判断游标是否为空
        IF l_cursorEmpty = 0 THEN
        SET v_OrderID = '-1';
        SET v_HFserialid = '-1';
        SET v_ChargeSerialID = '-1';
        SET v_ErrorCode = '-1';
        SET v_FullMoney = '-1';
        SET v_PlatId = '-1';
        SET v_PHONERESMONEY = '-1';
        SET v_AGENTID = '-1';
        LEAVE label2;
        END IF;
      
        SET v_NotifyCount = l_increce;
        SET v_result = '0';
        COMMIT;
    END;
    END$$

DELIMITER ;

优化前