最近需要對(duì)一個(gè)對(duì)數(shù)據(jù)表做清理的操作，這個(gè)環(huán)境是一個(gè)線上業(yè)務(wù)，因?yàn)楦鞣N原因，表中的數(shù)據(jù)比較臃腫，而磁盤(pán)空間又比較小，所以經(jīng)常導(dǎo)致磁盤(pán)空間爆滿，和業(yè)務(wù)確認(rèn)后對(duì)數(shù)據(jù)做定時(shí)刪除，實(shí)現(xiàn)方式如下，以下針對(duì)小項(xiàng)目。

[[286806]]

1. 開(kāi)啟事件調(diào)度器

set global event_scheduler= ON;             show variables like '%event_scheduler%';#my.cnf增加參數(shù)event_scheduler = on 

2. 創(chuàng)建日志刪除記錄表

CREATE TABLE IF NOT EXISTS mq_log( name VARCHAR(400) NOT NULL COMMENT '刪除信息', row INT COMMENT '刪除行數(shù)', del_time TIMESTAMP COMMENT '刪除時(shí)間') COMMENT = '日志刪除記錄表'; 

3. 創(chuàng)建日志刪除存儲(chǔ)過(guò)程

這里主要用了異常記錄、影響行數(shù)記錄、事務(wù)處理幾個(gè)特點(diǎn)

drop procedure if exists del_mq_log;DELIMITER // create procedure del_mq_log()BEGIN    DECLARE  affect_rows INT;       DECLARE  affect_rows2 INT;       DECLARE  affect_rows3 INT;       declare v_commit int default 2; -- 定義事務(wù)用，1為正常，-10為失敗    declare msg text;-- 記錄錯(cuò)誤信息    -- 異常的時(shí)候msg捕獲報(bào)錯(cuò)信息    declare continue handler for sqlexception     begin get diagnostics condition 1  msg = message_text;set v_commit = -10; end ;        start transaction;    -- 設(shè)置事務(wù)    delete from lcp_mq_record where last_update_date < DATE_SUB(CURDATE(),INTERVAL 30 DAY);    select ROW_COUNT() into @affect_rows;    delete from lcp_dd_service_record where last_update_date < DATE_SUB(CURDATE(),INTERVAL 30 DAY);    select ROW_COUNT() into @affect_rows2;    delete from lcp_api_service_record where last_update_date < DATE_SUB(CURDATE(),INTERVAL 30 DAY);    select ROW_COUNT() into @affect_rows3;    insert into mq_log values('刪除lcp_mq_record成功',@affect_rows,now()),('刪除lcp_dd_service_record成功',@affect_rows2,now()),('刪除lcp_api_service_record 成功',@affect_rows3,now()); -- 記錄刪除情況    -- 異常回滾且記錄日志    if v_commit = -10 then           ROLLBACK;        insert into mq_log values(msg,0,now());    end if ;END//DELIMITER ; 

4. 創(chuàng)建一個(gè)每天凌晨1點(diǎn)執(zhí)行存儲(chǔ)過(guò)程的定時(shí)任務(wù)

DROP event IF EXISTS e_del_mqlog;     CREATE EVENT e_del_mqlog     ON SCHEDULE   EVERY 1 DAY STARTS DATE_ADD(DATE_ADD(CURDATE(), INTERVAL 1 DAY), INTERVAL 1 HOUR)  DO call del_mq_log(); 

5. 第一次刪除需做回收

alter table lcp_mq_record engine=innodb;alter table lcp_dd_service_record engine=innodb;alter table lcp_api_service_record engine=innodb;