背景:旧库唯一键,没加唯一索引,导致有重复的数据产生。
思路:晚上跑任务,利用存储过程将唯一键重置,然后添加唯一索引。
1、新建存储过程:重置Null唯一键值
DELIMITER $$
USE `库`$$
DROP PROCEDURE IF EXISTS `resetNullUniqueId`$$
CREATE DEFINER=`用户`@`%` PROCEDURE `resetNullUniqueId`()
BEGIN
DECLARE i BIGINT;
SET i = (SELECT COUNT(1) FROM 表WHERE unique_id IS NULL );
SELECT CONCAT('共更新:' , i , '条数据');
WHILE i>0 DO
UPDATE 表 SET unique_id=REPLACE(UUID(),'-','') WHERE unique_id IS NULL LIMIT 1 ;
SET i=i-1;
END WHILE;
END$$
DELIMITER ;
2、新建存储过程:重置重复唯一键值
DELIMITER $$
USE `库`$$
DROP PROCEDURE IF EXISTS `resetUniqueId`$$
CREATE DEFINER=`用户`@`%` PROCEDURE `resetUniqueId`()
BEGIN
-- 遍历数据结束标志,两层循环用同一个标志,需要特别主意
DECLARE done INT DEFAULT FALSE;
DECLARE _unique_id VARCHAR(35) DEFAULT '';
DECLARE row_id BIGINT DEFAULT 0;
DECLARE i INT DEFAULT 0;
-- 定义游标
DECLARE rs_cursor CURSOR FOR
SELECT unique_id FROM 表 WHERE unique_id IS NOT NULL GROUP BY unique_id HAVING COUNT(unique_id)>1;
DECLARE rs_cursor_update CURSOR FOR
SELECT id FROM 表 WHERE unique_id=_unique_id;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
OPEN rs_cursor;
cursor_loop:LOOP
FETCH rs_cursor INTO _unique_id; -- 取数据
IF done=1 THEN
LEAVE cursor_loop;
END IF;
-- 更新
SET i = 0;
OPEN rs_cursor_update;
cursor_update_loop:LOOP
FETCH rs_cursor_update INTO row_id; -- 取数据
IF done THEN
LEAVE cursor_update_loop;
END IF;
-- 更新表
UPDATE 表 SET unique_id=CONCAT(unique_id,i) WHERE id=row_id;
SET i = i+1;
END LOOP cursor_update_loop;
CLOSE rs_cursor_update;
SET done=FALSE; -- 这个很重要
END LOOP cursor_loop;
CLOSE rs_cursor;
END$$
DELIMITER ;
3、新建定时任务
DELIMITER $$
ALTER DEFINER=`用户`@`%` EVENT `事件名称` ON SCHEDULE AT '2018-09-11 03:00:00' ON COMPLETION PRESERVE ENABLE COMMENT '事件描述' DO BEGIN
ALTER TABLE 表 MODIFY COLUMN unique_id VARCHAR(35) COMMENT '唯一键';
CALL resetUniqueId();
CALL resetNullUniqueId();
CREATE UNIQUE INDEX uk_unique_id ON 表(unique_id);
END$$
DELIMITER ;
4、回家睡觉,第二天过来检查执行效果。