mysql游标表间数据迁移_MySQL存储过程--通过游标遍历和异常处理迁移数据到历史表...
-- 大表數據遷移,每天凌晨1點到5點執行,執行間隔時間10分鐘,遷移舊數據到歷史表。DELIMITER $$
USE `dbx`$$
DROP PROCEDURE IF EXISTS `pro_xx`$$
CREATE PROCEDURE `pro_xx`()
BEGIN
DECLARE p_oalid INT DEFAULT 0;
DECLARE STOP INT DEFAULT 0;
DECLARE cur_oalid CURSOR FOR
SELECToal.id FROM oal_xxx oal WHERE oal.`ymd`
DAY(DATE_ADD(NOW(),INTERVAL-1 MONTH ))) LIMIT 1000;
DECLARE EXIT HANDLER FOR SQLSTATE '02000' /**包含游標not found*/
BEGIN
SET STOP=1;
INSERTINTO db_logs(log_type,table_name,action_name,log_msg,create_time)
SELECT1, 'oal_xxx','pro_oal_log_move',CONCAT('primary key:',p_oalid,' 游標執行正常結束!'),NOW();
END;
DECLARE EXIT HANDLER FOR SQLEXCEPTION
BEGIN
SETSTOP=1;
INSERTINTO db_logs(log_type,table_name,action_name,log_msg,create_time)
SELECT2, 'oal_xxx','pro_oal_log_move',CONCAT('primary key:',p_oalid,' 移動執行失敗'),NOW();
END;
OPEN cur_oalid;
--讀取一行數據到變量FETCH cur_oalid INTO p_oalid;
--這個就是判斷是否游標已經到達了最后WHILE STOP <> 1 DO
-- select p_id;
START TRANSACTION;
--進行數據遷移REPLACE INTO oal_xxx_history SELECT oal.*FROM oal_xxx oal WHERE oal.id=p_oalid ;
DELETE FROM oal_xxx WHERE id=p_oalid;
-- INSERT INTO t (tid) VALUES (p_tid);
COMMIT;
--讀取下一行的數據FETCH cur_oalid INTO p_oalid;
END WHILE;
CLOSE cur_oalid; -- 關閉游標
END$$
DELIMITER ;
以上就是MySQL存儲過程-->通過游標遍歷和異常處理遷移數據到歷史表 的內容,更多相關內容請關注PHP中文網(www.gxlcms.com)!
本條技術文章來源于互聯網,如果無意侵犯您的權益請點擊此處反饋版權投訴
本文系統來源:php中文網
總結
以上是生活随笔為你收集整理的mysql游标表间数据迁移_MySQL存储过程--通过游标遍历和异常处理迁移数据到历史表...的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: mysql 更新 字段 递增_MySQL
- 下一篇: mysql mycat 路由规则_Myc