mysql动态新建以及删除分区表
因为项目需要，最近研究了一下在mysql
数据库下如何动态新建以及删除分区表。如果全部借助存储过程的话，新建以及删除分区表在逻辑上比较死板、不灵活，而且还容易出错。因此，我新建了一个数据表table_fen_qu，借助这个表可以很(相对)灵活的对分区表进行管理。以下是操作过程，不足之处请各位看官指正。
第一步：建立存储过程。
建立新建分区表的存储过程代码如下：
001
drop procedure if exists general_procedure;
002
-- general_procedure的作用：新建分区表及在table_fen_qu表中存储新建分区表时的相关参数
003
-- general_procedure的参数：表名，分区表之间的时间间隔(单位为小时)，要新增的分区表个数
004
create procedure general_procedure(in tablenamein varchar(50),in intervalHour int,in newIntervalNum int)
005
general_pro:begin
006
-- 参数：最大时间
007
declare maxMonitTime datetime default SYSDATE();
008
-- 参数：最大时间对应的字符串
009
declare maxMonitTimeStr varchar(50);
010
-- 参数：最小时间
011
declare minMonitTime datetime default SYSDATE();
012
-- 参数：最大时间对应的字符串
013
declare minMonitTimeStr varchar(50);
014
-- 参数：数据库记录数
015
declare recoidNum int default 0;
016
-- 判断传入的表名是否为空
017
if tablenamein is null then
018
leave general_pro;
019
end if;
020
-- 判断传入的时间间隔
021
if intervalHour <= 0 then
022
set intervalHour = 6;
023
end if;
024
-- 判断新增分区表个数
025
if newIntervalNum <= 0 then
026
set newIntervalNum = 1;
027
end if;
028
029
-- 在该表中，查询符合条件的记录数，backupflag=0说明是未备份
030
select count(*) into recoidNum from table_fen_qu where tablename=tablenamein and backupflag=0;
031
if recoidNum > 0 then
032
-- 查询该表在table_fen_qu表中的最大监测时间
033
select monittime into maxMonitTime from table_fen_qu where tablename=tablenamein and backupflag=0 order by monittime desc limit 1;
034
-- 判断监测时间是否为null
035
if maxMonitTime is null then
036
set maxMonitTime = SYSDATE();
037
end if;
038
-- 比较最大时间减去72个小时之后的时间与
系统时间的早晚
039
set recoidNum = timestampdiff(hour,SYSDATE(),DATE_SUB(maxMonitTime,INTERVAL 3 DAY));
040
-- 如果recoidNum大于0，说明最大监测时间减去72小时之后的时间仍然在系统时间之后,
041
-- 说明不用建立新的分区表，反之，则建立最大监测时间之后newIntervalNum个以每intervalHour小时为间隔的分区表
042
if recoidNum <= 0 then
043
set recoidNum = 1;
044
while recoidNum <= newIntervalNum do
045
set maxMonitTime = ADDDATE(maxMonitTime,INTERVAL intervalHour HOUR);
046
set maxMonitTimeStr = CONCAT('p',DATE_FORMAT(maxMonitTime,"%Y%m%d%H%i%s"));
047
-- 开始添加分区表
048
/*拼接分区表代码段*/
049
set @v_add_s = CONCAT('ALTER TABLE ',tablenamein,' ADD PARTITION (PARTITION ',maxMonitTimeStr,' VALUES LESS THAN (\'',maxMonitTime,'\') ENGINE = InnoDB )');
050
/*定义预处理语句*/
051
prepare stmt from @v_add_s;
052
/*执行预处理语句*/
053
execute stmt;
054
/*释放预处理语句*/
055
deallocate prepare stmt;
056
-- 开始在table_fen_qu中添加记录
057
insert into table_fen_qu(fenquname,tablename,monittime,backupflag) VALUES(maxMonitTimeStr,tablenamein,maxMonitTime,0);
058
-- 记录数加1
059
set recoidNum = recoidNum + 1;
060
end while;
061
end if;
062
else
063
set recoidNum = 1;
064
-- 计算最小时间
065
set minMonitTimeStr = CONCAT(DATE_FORMAT(DATE_SUB(maxMonitTime,INTER