mysql 表分區、按時間函數分區、刪除分區、自動添加表分區


mysql 表分區的幾種方式:
RANGE分區:基於屬於一個給定連續區間的列值,把多行分配給分區。
LIST分區:類似於按RANGE分區,區別在於LIST分區是基於列值匹配一個離散值集合中的某個值來進行選擇。
HASH分區:基於用戶定義的表達式的返回值來進行選擇的分區,該表達式使用將要插入到表中的這些行的列值進行計算。這個函數可以包含MySQL中有效的、產生非負整數值的任何表達式。
KEY分區:類似於按HASH分區,區別在於KEY分區只支持計算一列或多列,且MySQL服務器提供其自身的哈希函數。必須有一列或多列包含整數值。
常用的按時間分區可以按照年、月、日等條件用來分區,因為是按時間條件分區所以選用RANGE分區方式。

分區的切條件判斷:
LESS THAN:如果是數值就是小於等於,時間則是小於。
LESS THAN MAX:不等於。
IN:包含於某某區間。
按實際分區的時間函數選用:
按日分區切分時的條件可以用day()、to_days()時間函數,需要注意的是必須是返回值是整形的。
按月分區采用month()時間函數;
其他條件分區時間函數可到我關於時間函數的博文查看:https://blog.csdn.net/qq_36216193/article/details/90404527
其中按時間字段create_date按天分區,首先需要把date字段改成主鍵,后添加分區切分規則

ALTER TABLE js_sys_log
DROP PRIMARY KEY,
ADD PRIMARY KEY (id, create_date); --之前id是主鍵,所以這里第2主鍵為聯合主鍵

ALTER TABLE js_sys_log ADD PRIMARY KEY (create_date);
1
2
3
4
5
為了便於管理分區名通常以“p時間”來命名。

示例一

select PARTITION_NAME, TABLE_ROWS FROM INFORMATION_SCHEMA.PARTITIONS WHERE TABLE_NAME = 'table';:

alter table table PARTITION by RANGE (created_at)(
PARTITION p20170101 values less than (UNIX_TIMESTAMP('2017-01-01')),
PARTITION p20180101 values less than (UNIX_TIMESTAMP('2018-01-01')),
PARTITION p20190101 values less than (UNIX_TIMESTAMP('2019-01-01')),
PARTITION p20200101 values less than (UNIX_TIMESTAMP('2020-01-01')),
PARTITION p20210101 values less than (UNIX_TIMESTAMP('2021-01-01')),
PARTITION pmax values less than (MAXVALUE)
);



后期添加分區:
示例二:
ALTER TABLE js_sys_log ADD PARTITION (PARTITION p20181111 VALUES LESS THAN (TO_DAYS ('2018-11-11')));
1
2
刪除分區:
示例三:
ALTER TABLE js_sys_log DROP PARTITION p20181101;
1
2
查詢MySQL的系統字典庫得知所有的分區詳情信息
示例四:
SELECT * FROM information_schema. PARTITIONS t WHERE t.PARTITION_NAME IS NOT NULL
1
2
在分區創建后可以通過過程和事件控制自動增加表分區。
1、查看是否開啟事件

show variables like "event_scheduler";
1

2、開啟事件(本次設置中生效)

SET GLOBAL event_scheduler = on;

SET GLOBAL event_scheduler = 1;

3、開啟時間(長期生效)
編輯 mysql 配置文件,並在【mysqld】下添加該變量:

再重啟 mysqld 服務, 登錄 mysql ,查看配置,確認是否生效。

4、設置分區腳本

use test;

DELIMITER ||
-- 刪除存儲過程
drop procedure if exists 事件名稱 ||
-- 注意:使用該存儲過程必須保證相應數據庫表中至少有一個手動分區
-- 創建存儲過程[通過數據庫名和對應表名]-建多少個分區,分區時間間隔為多少
-- databasename:創建分區的數據庫
-- tablename:創建分區的表的名稱
-- partition_number:一次創建多少個分區
-- partitiontype:分區類型[0按天分區,1按月分區,2按年分區]
-- gaps:分區間隔,如果分區類型為0則表示每個分區的間隔為 gaps天;
-- 如果分區類型為1則表示每個分區的間隔為 gaps月
-- 如果分區類型為2則表示每個分區的間隔為 gaps年
create procedure 事件名稱 (in databasename varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci,in tablename varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci, in partition_number int, in partitiontype int, in gaps int)
L_END:
begin
declare max_partition_description varchar(255) default '';
declare p_name varchar(255) default 0;
declare p_description varchar(255) default 0;
declare isexist_partition varchar(255) default 0;
declare i int default 1;

-- 查看對應數據庫對應表是否已經有手動分區[自動分區前提是必須有手動分區]
select partition_name into isexist_partition from information_schema.partitions where table_schema = databasename and table_name = tablename limit 1;
-- 如果不存在則打印錯誤並退出存儲過程
if isexist_partition <=> "" then
select "partition table not is exist" as "ERROR";
leave L_END;
end if;

-- 獲取最大[降序獲取]的分區描述[值]
select partition_description into max_partition_description from information_schema.partitions where table_schema = databasename and table_name = tablename order by partition_description desc limit 1;

-- 如果最大分區沒有,說明沒有手動分區,則無法創建自動分區
if max_partition_description <=> "" then
select "partition table is error" as "ERROR";
leave L_END;
end if;

-- 替換前后的單引號[''兩個引號表示一個單引號的轉義]
-- set max_partition_description = REPLACE(max_partition_description, '''', '');
-- 或使用如下語句
set max_partition_description = REPLACE(max_partition_description-1, '\'', '');

-- 自動創建number個分區
while (i <= partition_number) do
if (partitiontype = 0) then
-- 每個分區按天遞增,遞增gaps天
set p_description = DATE_ADD(FROM_DAYS(max_partition_description), interval i*gaps day);
elseif (partitiontype = 1) then
-- 每個分區按月遞增,遞增gaps月
set p_description = DATE_ADD(FROM_DAYS(max_partition_description), interval i*gaps month);
else
-- 每個分區按年遞增,遞增gaps年
set p_description = DATE_ADD(FROM_DAYS(max_partition_description), interval i*gaps year);
end if;
-- 刪除空格
set p_name = REPLACE(p_description, ' ', '');
-- 例如10.20的記錄實際是less than 10.21
set p_description = DATE_ADD(p_description, interval 1 day);
-- 如果有橫桿替換為空
set p_name = REPLACE(p_name, '-', '');
-- 刪除時間冒號
set p_name = REPLACE(p_name, ':', '');
-- alter table tablename add partition ( partition pname values less than ('2019-05-22 23:59:59') );
set @sql=CONCAT('ALTER TABLE ', tablename ,' ADD PARTITION ( PARTITION p', p_name ,' VALUES LESS THAN (TO_DAYS(\'', p_description ,'\')))');
-- set @sql=CONCAT('ALTER TABLE ', tablename ,' ADD PARTITION ( PARTITION p', p_name ,' VALUES LESS THAN (TO_DAYS(\'', p_description ,'\')))');
-- 打印sql變量
-- select @sql;
-- 准備sql語句
PREPARE stmt from @sql;
-- 執行sql語句
EXECUTE stmt;
-- 釋放資源
DEALLOCATE PREPARE stmt;
-- 遞增變量
set i = (i + 1) ;

end while;
end ||
-- 恢復語句中斷符
DELIMITER ;
5、事件處理(每天執行一次)

DELIMITER ||
drop event if exists 事件名稱 ||
create event 事件名稱
on schedule every 1 day
starts '2019-05-22 23:59:59'
do
BEGIN
call 事件名稱 ('數據庫名', '分區表名', 1, 0, 1);
END ||
DELIMITER ;

6、刪除事件

DROP EVENT [IF EXISTS] 事件名稱;
1
7、查看事件

show events;
1
8、表分區查看:

explain partitions select * from 分區表名;

原文鏈接:https://blog.csdn.net/qq_36216193/java/article/details/90412637


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM