MySQL 动态分区管理自动化与优化实践记录

CREATE PROCEDURE create_partition_log(IN IN_TABLENAME VARCHAR(64))
BEGIN
DECLARE BEGINTIME TIMESTAMP;
DECLARE ENDTIME TIMESTAMP;
DECLARE PARTITIONNAME VARCHAR(16);
DECLARE DATEVALUE VARCHAR(16);

-- 设置分区的开始时间（明天）
SET BEGINTIME = NOW() + INTERVAL 1 DAY;
-- 生成分区名称（格式：pYYYYMMDD）
SET PARTITIONNAME = DATE_FORMAT(BEGINTIME, 'p%Y%m%d');
-- 设置分区的结束时间（后天）
SET ENDTIME = BEGINTIME + INTERVAL 1 DAY;
-- 生成分区的值范围（格式：YYYY-MM-DD）
SET DATEVALUE = DATE_FORMAT(ENDTIME, '%Y-%m-%d');
-- 动态生成分区语句
SET @sqlstr = CONCAT('ALTER TABLE `', IN_TABLENAME, '` ADD PARTITION (PARTITION ', PARTITIONNAME, ' VALUES LESS THAN (', "'", DATEVALUE, "','))');
-- 执行分区语句
PREPARE stmt1 FROM @sqlstr;
EXECUTE stmt1;
DEALLOCATE PREPARE stmt1;

CREATE EVENT IF NOT EXISTS partition_manager_event
ON SCHEDULE EVERY 1 MONTH
STARTS ‘2025-02-25 01:00:00' – 指定事件开始执行的时间
DO
BEGIN
CALL create_partition_log(‘report_monitor');
END //

CREATE PROCEDURE create_partition_log(IN IN_TABLENAME VARCHAR(64))
BEGIN
DECLARE BEGINTIME TIMESTAMP;
DECLARE ENDTIME TIMESTAMP;
DECLARE PARTITIONNAME VARCHAR(16);
DECLARE DATEVALUE VARCHAR(16);
DECLARE existing_partition_name VARCHAR(50);
DECLARE done INT DEFAULT FALSE;
DECLARE cur CURSOR FOR
SELECT PARTITION_NAME
FROM information_schema.PARTITIONS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = IN_TABLENAME;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

-- 设置分区的开始时间（明天）
SET BEGINTIME = NOW() + INTERVAL 1 DAY;
-- 生成分区名称（格式：pYYYYMMDD）
SET PARTITIONNAME = DATE_FORMAT(BEGINTIME, 'p%Y%m%d');
-- 设置分区的结束时间（后天）
SET ENDTIME = BEGINTIME + INTERVAL 1 DAY;
-- 生成分区的值范围（格式：YYYY-MM-DD）
SET DATEVALUE = DATE_FORMAT(ENDTIME, '%Y-%m-%d');
-- 检查现有分区
OPEN cur;
read_loop: LOOP
    FETCH cur INTO existing_partition_name;
    IF done THEN
        LEAVE read_loop;
    END IF;
    -- 如果分区名称匹配，跳过该分区
    IF existing_partition_name = PARTITIONNAME THEN
        LEAVE read_loop;
    END IF;
END LOOP;
CLOSE cur;
-- 动态生成分区语句
SET @sqlstr = CONCAT('ALTER TABLE `', IN_TABLENAME, '` ADD PARTITION (PARTITION ', PARTITIONNAME, ' VALUES LESS THAN (', "'", DATEVALUE, "','))');
-- 执行分区语句
PREPARE stmt1 FROM @sqlstr;
EXECUTE stmt1;
DEALLOCATE PREPARE stmt1;

CALL create_partition_log(‘report_monitor');检查分区是否创建成功

SHOW CREATE TABLE report_monitor;检查事件状态

SHOW EVENTS;手动触发事件（可选）

SET GLOBAL event_scheduler = ON; – 确保事件调度器已开启
ALTER EVENT partition_manager_event ON COMPLETION PRESERVE ENABLE; – 确保事件启用