mirror of
https://gitee.com/NexIoT/Universal-IoT-Java.git
synced 2026-08-29 06:51:35 +08:00
Join
340 lines
20 KiB
SQL
340 lines
20 KiB
SQL
-- =============================================
|
||
-- 步骤1：删除所有现有相关旧表（⚠️ 彻底清理，避免残留）
|
||
-- =============================================
|
||
-- 1.1 删除 iot_device_log_0~23 所有分表
|
||
DROP TABLE IF EXISTS
|
||
`iot_device_log_0`, `iot_device_log_1`, `iot_device_log_2`, `iot_device_log_3`,
|
||
`iot_device_log_4`, `iot_device_log_5`, `iot_device_log_6`, `iot_device_log_7`,
|
||
`iot_device_log_8`, `iot_device_log_9`, `iot_device_log_10`, `iot_device_log_11`,
|
||
`iot_device_log_12`, `iot_device_log_13`, `iot_device_log_14`, `iot_device_log_15`,
|
||
`iot_device_log_16`, `iot_device_log_17`, `iot_device_log_18`, `iot_device_log_19`,
|
||
`iot_device_log_20`, `iot_device_log_21`, `iot_device_log_22`, `iot_device_log_23`;
|
||
|
||
-- 1.2 删除 iot_device_log_metadata_0~23 所有分表
|
||
DROP TABLE IF EXISTS
|
||
`iot_device_log_metadata_0`, `iot_device_log_metadata_1`, `iot_device_log_metadata_2`,
|
||
`iot_device_log_metadata_3`, `iot_device_log_metadata_4`, `iot_device_log_metadata_5`,
|
||
`iot_device_log_metadata_6`, `iot_device_log_metadata_7`, `iot_device_log_metadata_8`,
|
||
`iot_device_log_metadata_9`, `iot_device_log_metadata_10`, `iot_device_log_metadata_11`,
|
||
`iot_device_log_metadata_12`, `iot_device_log_metadata_13`, `iot_device_log_metadata_14`,
|
||
`iot_device_log_metadata_15`, `iot_device_log_metadata_16`, `iot_device_log_metadata_17`,
|
||
`iot_device_log_metadata_18`, `iot_device_log_metadata_19`, `iot_device_log_metadata_20`,
|
||
`iot_device_log_metadata_21`, `iot_device_log_metadata_22`, `iot_device_log_metadata_23`;
|
||
|
||
-- =============================================
|
||
-- 步骤2：创建第一种类型分表：iot_device_log_0~23（共24个，每个分表内按时间分区）
|
||
-- =============================================
|
||
-- 2.1 创建 iot_device_log_0（分表示例，0~23结构完全一致，仅表名不同）
|
||
CREATE TABLE `iot_device_log_0`
|
||
(
|
||
`id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
||
`iot_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '设备唯一编码',
|
||
`device_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '设备自身序号',
|
||
`ext_device_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '第三方设备ID',
|
||
`product_key` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '产品ID',
|
||
`device_name` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '设备名称',
|
||
`message_type` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '消息类型（EVENT/PROPERTIES/FUNCTIONS）',
|
||
`command_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '指令ID',
|
||
`command_status` tinyint DEFAULT '0' COMMENT '指令状态（0未执行/1成功/2失败）',
|
||
`event` varchar(80) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '事件名称（如online/offline）',
|
||
`company_no` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '公司编号',
|
||
`protocol` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '通信协议（MQTT/TCP）',
|
||
`device_node` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '节点类型',
|
||
`classified_id` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '设备分类ID',
|
||
`org_id` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '所属机构ID',
|
||
`create_id` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '操作人ID',
|
||
`instance` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '0' COMMENT '实例名称',
|
||
`point` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '经纬度（经度,纬度）',
|
||
`content` text CHARACTER SET utf8mb4 COLLATE utf8mb4_bin COMMENT '日志详情（JSON格式）',
|
||
`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间（无0值）',
|
||
PRIMARY KEY (`id`, `create_time`) USING BTREE, -- 主键含分区键，确保分区生效
|
||
KEY `idx_iot_id` (`iot_id`) USING BTREE, -- 按设备编码查询
|
||
KEY `idx_product_device` (`product_key`, `device_id`) USING BTREE, -- 按产品+设备ID查询
|
||
KEY `idx_event_time` (`event`, `create_time`) USING BTREE -- 按事件+时间查询
|
||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT '设备日志分表0（按iotId哈希，内部分区）'
|
||
-- 分表内按时间分区（2025-09起，预留pmax兜底）
|
||
PARTITION BY RANGE (TO_DAYS(`create_time`)) (
|
||
PARTITION `p202509` VALUES LESS THAN (TO_DAYS('2025-10-01')), -- 2025年9月数据
|
||
PARTITION `p202510` VALUES LESS THAN (TO_DAYS('2025-11-01')), -- 2025年10月数据
|
||
PARTITION `p202511` VALUES LESS THAN (TO_DAYS('2025-12-01')), -- 2025年11月数据
|
||
PARTITION `pmax` VALUES LESS THAN MAXVALUE -- 兜底分区（未创建月份数据临时存入）
|
||
);
|
||
|
||
-- 2.2 创建 iot_device_log_1~23（复制log_0结构，仅表名不同）
|
||
CREATE TABLE `iot_device_log_1` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_1` COMMENT '设备日志分表1（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_2` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_2` COMMENT '设备日志分表2（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_3` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_3` COMMENT '设备日志分表3（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_4` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_4` COMMENT '设备日志分表4（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_5` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_5` COMMENT '设备日志分表5（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_6` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_6` COMMENT '设备日志分表6（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_7` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_7` COMMENT '设备日志分表7（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_8` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_8` COMMENT '设备日志分表8（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_9` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_9` COMMENT '设备日志分表9（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_10` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_10` COMMENT '设备日志分表10（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_11` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_11` COMMENT '设备日志分表11（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_12` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_12` COMMENT '设备日志分表12（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_13` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_13` COMMENT '设备日志分表13（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_14` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_14` COMMENT '设备日志分表14（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_15` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_15` COMMENT '设备日志分表15（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_16` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_16` COMMENT '设备日志分表16（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_17` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_17` COMMENT '设备日志分表17（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_18` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_18` COMMENT '设备日志分表18（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_19` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_19` COMMENT '设备日志分表19（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_20` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_20` COMMENT '设备日志分表20（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_21` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_21` COMMENT '设备日志分表21（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_22` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_22` COMMENT '设备日志分表22（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_23` LIKE `iot_device_log_0`;
|
||
ALTER TABLE `iot_device_log_23` COMMENT '设备日志分表23（按iotId哈希，内部分区）';
|
||
|
||
-- =============================================
|
||
-- 步骤3：创建第二种类型分表：iot_device_log_metadata_0~23（共24个，内部分区）
|
||
-- =============================================
|
||
-- 3.1 创建 iot_device_log_metadata_0（分表示例，0~23结构一致）
|
||
CREATE TABLE `iot_device_log_metadata_0`
|
||
(
|
||
`id` int unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
||
`iot_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NOT NULL COMMENT '设备唯一编码',
|
||
`product_key` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NOT NULL DEFAULT '' COMMENT '产品ID',
|
||
`device_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '设备名称',
|
||
`device_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '设备自身序号',
|
||
`message_type` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '消息类型',
|
||
`event` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '事件名称',
|
||
`property` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '设备属性（如battery/csq）',
|
||
`content` text CHARACTER SET utf8mb4 COLLATE utf8mb4_bin COMMENT '元数据详情',
|
||
`ext1` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '扩展字段1',
|
||
`ext2` varchar(655) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL COMMENT '扩展字段2（长文本）',
|
||
`ext3` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT '' COMMENT '扩展字段3',
|
||
`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间（无0值）',
|
||
PRIMARY KEY (`id`, `create_time`) USING BTREE, -- 主键含分区键
|
||
KEY `idx_iot_id` (`iot_id`) USING BTREE,
|
||
KEY `idx_product_device` (`product_key`, `device_id`) USING BTREE,
|
||
KEY `idx_time_property` (`create_time`, `property`) USING BTREE -- 按时间+属性查询
|
||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT '设备日志元数据分表0（按iotId哈希，内部分区）'
|
||
-- 分表内按时间分区（与log分表对齐）
|
||
PARTITION BY RANGE (TO_DAYS(`create_time`)) (
|
||
PARTITION `p202509` VALUES LESS THAN (TO_DAYS('2025-10-01')),
|
||
PARTITION `p202510` VALUES LESS THAN (TO_DAYS('2025-11-01')),
|
||
PARTITION `p202511` VALUES LESS THAN (TO_DAYS('2025-12-01')),
|
||
PARTITION `pmax` VALUES LESS THAN MAXVALUE
|
||
);
|
||
|
||
-- 3.2 创建 iot_device_log_metadata_1~23（复制metadata_0结构）
|
||
CREATE TABLE `iot_device_log_metadata_1` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_1` COMMENT '设备日志元数据分表1（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_2` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_2` COMMENT '设备日志元数据分表2（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_3` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_3` COMMENT '设备日志元数据分表3（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_4` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_4` COMMENT '设备日志元数据分表4（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_5` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_5` COMMENT '设备日志元数据分表5（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_6` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_6` COMMENT '设备日志元数据分表6（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_7` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_7` COMMENT '设备日志元数据分表7（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_8` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_8` COMMENT '设备日志元数据分表8（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_9` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_9` COMMENT '设备日志元数据分表9（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_10` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_10` COMMENT '设备日志元数据分表10（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_11` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_11` COMMENT '设备日志元数据分表11（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_12` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_12` COMMENT '设备日志元数据分表12（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_13` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_13` COMMENT '设备日志元数据分表13（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_14` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_14` COMMENT '设备日志元数据分表14（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_15` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_15` COMMENT '设备日志元数据分表15（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_16` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_16` COMMENT '设备日志元数据分表16（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_17` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_17` COMMENT '设备日志元数据分表17（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_18` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_18` COMMENT '设备日志元数据分表18（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_19` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_19` COMMENT '设备日志元数据分表19（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_20` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_20` COMMENT '设备日志元数据分表20（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_21` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_21` COMMENT '设备日志元数据分表21（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_22` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_22` COMMENT '设备日志元数据分表22（按iotId哈希，内部分区）';
|
||
|
||
CREATE TABLE `iot_device_log_metadata_23` LIKE `iot_device_log_metadata_0`;
|
||
ALTER TABLE `iot_device_log_metadata_23` COMMENT '设备日志元数据分表23（按iotId哈希，内部分区）';
|
||
|
||
-- =============================================
|
||
-- 步骤4：创建自动分区存储过程（批量为所有分表新增下月分区）
|
||
-- 功能：1次执行，为 log_0~23 和 metadata_0~23 共48个分表同步新增分区
|
||
-- =============================================
|
||
DELIMITER
|
||
//
|
||
-- 先删除旧存储过程（避免重复创建报错）
|
||
DROP PROCEDURE IF EXISTS `auto_add_partition_for_all_shards`;
|
||
//
|
||
CREATE PROCEDURE `auto_add_partition_for_all_shards`()
|
||
BEGIN
|
||
-- 变量定义：分表索引（0~23）、时间、分区名、表名
|
||
DECLARE
|
||
`shard_idx` INT DEFAULT 0;
|
||
DECLARE
|
||
`next_month` DATE;
|
||
DECLARE
|
||
`next_next_month` DATE;
|
||
DECLARE
|
||
`partition_name` VARCHAR(20);
|
||
DECLARE
|
||
`log_table_name` VARCHAR(50); -- log分表名（如iot_device_log_0）
|
||
DECLARE
|
||
`metadata_table_name` VARCHAR(50); -- metadata分表名（如iot_device_log_metadata_0）
|
||
|
||
-- 1. 计算分区时间：下月1号（分区名）、下下月1号（分区边界）
|
||
SET
|
||
`next_month` = DATE_FORMAT(CURDATE() + INTERVAL 1 MONTH, '%Y-%m-01');
|
||
SET
|
||
`next_next_month` = DATE_FORMAT(CURDATE() + INTERVAL 2 MONTH, '%Y-%m-01');
|
||
SET
|
||
`partition_name` = CONCAT('p', DATE_FORMAT(`next_month`, '%Y%m')); -- 分区名：p202512
|
||
|
||
-- 2. 循环处理0~23所有分表（同时处理log和metadata分表）
|
||
WHILE
|
||
`shard_idx` < 24 DO
|
||
-- 2.1 拼接当前分表名
|
||
SET `log_table_name` = CONCAT('iot_device_log_', `shard_idx`);
|
||
SET
|
||
`metadata_table_name` = CONCAT('iot_device_log_metadata_', `shard_idx`);
|
||
|
||
-- 2.2 为 log分表 新增分区
|
||
SET
|
||
@sql_log = CONCAT(
|
||
'ALTER TABLE ', `log_table_name`, ' ADD PARTITION (',
|
||
'PARTITION ', `partition_name`, ' VALUES LESS THAN (TO_DAYS(\'', `next_next_month`, '
|
||
\'))',
|
||
');'
|
||
);
|
||
PREPARE stmt_log FROM @sql_log;
|
||
EXECUTE stmt_log;
|
||
DEALLOCATE PREPARE stmt_log;
|
||
|
||
-- 2.3 为 metadata分表 新增分区（与log分表对齐）
|
||
SET
|
||
@sql_metadata = CONCAT(
|
||
'ALTER TABLE ', `metadata_table_name`, ' ADD PARTITION (',
|
||
'PARTITION ', `partition_name`, ' VALUES LESS THAN (TO_DAYS(\'', `next_next_month`, '
|
||
\'))',
|
||
');'
|
||
);
|
||
PREPARE stmt_metadata FROM @sql_metadata;
|
||
EXECUTE stmt_metadata;
|
||
DEALLOCATE PREPARE stmt_metadata;
|
||
|
||
-- 2.4 打印执行结果（便于验证）
|
||
SELECT CONCAT('✅ 已为分表 [', `log_table_name`, '] 和 [', `metadata_table_name`, '] 新增分区：',
|
||
`partition_name`) AS `result`;
|
||
|
||
-- 分表索引+1，继续下一张
|
||
SET
|
||
`shard_idx` = `shard_idx` + 1;
|
||
END WHILE;
|
||
|
||
-- 3. 最终提示
|
||
SELECT CONCAT('🎉 所有分表分区新增完成！本次新增分区：', `partition_name`, '，时间范围：', `next_month`,
|
||
' ~ ',
|
||
DATE_SUB(`next_next_month`, INTERVAL 1 DAY)) AS `final_result`;
|
||
END
|
||
//
|
||
DELIMITER ;
|
||
|
||
-- =============================================
|
||
-- 步骤5：验证脚本执行结果（确认分表和存储过程创建成功）
|
||
-- =============================================
|
||
-- 5.1 确认 log分表 已创建（共24个）
|
||
SELECT TABLE_NAME, TABLE_COMMENT
|
||
FROM INFORMATION_SCHEMA.TABLES
|
||
WHERE TABLE_SCHEMA = 'univ'
|
||
AND TABLE_NAME LIKE 'iot_device_log_%'
|
||
AND TABLE_NAME NOT IN ('iot_device_log');
|
||
-- 排除非分表
|
||
|
||
-- 5.2 确认 metadata分表 已创建（共24个）
|
||
SELECT TABLE_NAME, TABLE_COMMENT
|
||
FROM INFORMATION_SCHEMA.TABLES
|
||
WHERE TABLE_SCHEMA = 'univ'
|
||
AND TABLE_NAME LIKE 'iot_device_log_metadata_%'
|
||
AND TABLE_NAME NOT IN ('iot_device_log_metadata');
|
||
-- 排除非分表
|
||
|
||
-- 5.3 确认自动分区存储过程已创建
|
||
SELECT ROUTINE_NAME, ROUTINE_TYPE
|
||
FROM INFORMATION_SCHEMA.ROUTINES
|
||
WHERE ROUTINE_SCHEMA = 'univ'
|
||
AND ROUTINE_NAME = 'auto_add_partition_for_all_shards'; |