下载文档原格式
如何使用MySQL进行分片和分区管理MySQL是目前最受欢迎的开源关系型数据库管理系统之一，广泛应用于各类网站、企业和应用程序中。
随着数据量的不断增长，对数据库的性能和扩展性要求也越来越高。
为了应对这种需求，MySQL提供了分片和分区管理的功能，可以有效地提升数据库的处理能力和扩展性。
一、分片管理分片是将一个数据库水平切分成多个独立的部分，每个部分包含部分数据和相应的数据库节点。
通过将数据分散到多个节点，可以减轻单个数据库的负载，提高数据库的并发处理能力。
1. 设计分片键分片键是用于决定数据切分位置的字段，一般是根据业务需求来选择。
例如，可以根据用户ID来进行分片，将用户相关的数据分配到不同的节点上。
2. 创建分片表在进行分片之前，需要创建分片表。
分片表是指逻辑上的表，由多个物理表组成。
每个物理表存储一个分片的数据。
3. 配置数据切分规则在MySQL数据库中，有多种方式来进行数据切分。
例如，可以按照哈希值、范围、列表或自定义函数等方式来切分数据。
4. 配置分片节点每个分片节点是一个独立的数据库服务器，可以位于同一个物理服务器上，也可以位于不同的机器上。
需要将每个分片节点的连接信息、分片键范围等配置到中央管理节点上。
5. 启动分片服务配置完成后，可以启动分片服务。
分片服务会根据配置的分片规则，将数据自动分配到不同的节点上。
对外部应用程序来说，仍然可以像访问普通的单一数据库一样进行访问。
二、分区管理分区是将数据库的数据按照某种规则划分成多个单独的部分，每个部分称为一个分区。
通过对数据进行分区，可以提高查询性能，降低索引维护的成本。
1. 设计分区策略分区策略是用于决定如何划分分区的规则。
可以按照时间、地理位置、业务需求等多种方式进行划分。
例如，可以按照日期来划分分区，将每天的数据存储到不同的分区中。
2. 创建分区表在进行分区之前，需要创建分区表。
分区表是指逻辑上的表，由多个分区组成。
每个分区可以是一个独立的物理表、文件或目录。
Mysql分区表-分区操作⼀、查看MySQL是否⽀持分区1、MySQL5.6以及之前版本show variables like '%partition%';2、MySQL5.7show plugins;⼆、分区表的分类与限制1、分区表分类RANGE分区：基于属于⼀个给定连续区间的列值，把多⾏分配给分区。
LIST分区：类似于按RANGE分区，区别在于LIST分区是基于列值匹配⼀个离散值集合中的某个值来进⾏选择。
HASH分区：基于⽤户定义的表达式的返回值来进⾏选择的分区，该表达式使⽤将要插⼊到表中的这些⾏的列值进⾏计算。
这个函数可以包含MySQL 中有效的、产⽣⾮负整数值的任何表达式。
KEY分区：类似于按HASH分区，区别在于KEY分区只⽀持计算⼀列或多列，且MySQL服务器提供其⾃⾝的哈希函数。
必须有⼀列或多列包含整数值。
复合分区：在MySQL 5.6版本中，只⽀持RANGE和LIST的⼦分区，且⼦分区的类型只能为HASH和KEY。
2、分区表限制1）分区键必须包含在表的所有主键、唯⼀键中。
2）MYSQL只能在使⽤分区函数的列本⾝进⾏⽐较时才能过滤分区，⽽不能根据表达式的值去过滤分区，即使这个表达式就是分区函数也不⾏。
3）最⼤分区数：不使⽤NDB存储引擎的给定表的最⼤可能分区数为8192（包括⼦分区）。
如果当分区数很⼤，但是未达到8192时提⽰Got error … from storage engine: Out of resources when opening file,可以通过增加open_files_limit系统变量的值来解决问题，当然同时打开⽂件的数量也可能由操作系统限制。
4）不⽀持查询缓存：分区表不⽀持查询缓存，对于涉及分区表的查询，它⾃动禁⽤。
查询缓存⽆法启⽤此类查询。
5）分区的innodb表不⽀持外键。
6）服务器SQL_mode影响分区表的同步复制。
主机和从机上的不同SQL_mode可能会导致sql语句; 这可能导致分区之间的数据分配给定主从位置不同，甚⾄可能导致插⼊主机上成功的分区表在从库上失败。
MySQL数据库的分片及水平扩展技术概述MySQL是一种开源的关系型数据库管理系统，广泛应用于互联网领域。
在大规模应用中，MySQL的性能和扩展性是关键问题之一。
为了解决单个MySQL数据库的性能瓶颈和存储容量的限制，分片和水平扩展成为了常见的解决方案。
本文将探讨MySQL数据库的分片技术和水平扩展技术。
一、分片技术的基本原理分片是指将数据库的数据分散存储在多个节点上，每个节点存储部分数据，以达到提高系统性能和存储容量的目的。
分片技术的基本原理包括数据切分、路由和数据同步。
1.1 数据切分数据切分是指将数据库中的数据按照一定的规则进行分割和划分。
常见的数据切分方式有垂直分片和水平分片。
垂直分片是指将数据库中的表按照特定的规则进行拆分，将每个表的部分列存储在不同的节点上。
这种方式适用于数据表中存在明显的关系，但是数据访问频率差异较大的情况。
水平分片是指将数据库中的表按照特定的规则进行拆分，将每个表的部分行存储在不同的节点上。
这种方式适用于数据表中的行独立性较高，数据访问频率相对均衡的情况。
1.2 路由路由是指根据查询条件将数据库请求路由到对应的分片节点。
分片节点可以根据查询条件中的分片键进行路由，也可以通过中间件或负载均衡器进行路由。
对于基于分片键的路由，分片节点会根据查询条件中的分片键判断该请求应该路由到哪个分片节点。
分片键可以是表的某个字段，也可以是多个字段的组合。
对于中间件或负载均衡器进行路由，可以使用一些开源的中间件，例如MySQL Proxy、MyCat等。
这些中间件负责接收数据库请求，并将请求转发到对应的分片节点。
1.3 数据同步数据同步是指保持分片节点之间数据的一致性。
当一个分片节点发生数据变更时，需要将这个变更同步到其他的分片节点上。
常用的数据同步方式有同步复制和异步复制。
同步复制要求所有的分片节点在数据变更完成之前都要确认这个变更，确保数据的一致性；而异步复制则允许有一定的延迟，可以提高系统的性能，但是对于故障恢复和数据一致性的要求较高。
使用MySQL进行数据分片和分库分表处理在现代的互联网应用中，随着用户数量的增加和数据量的急剧增长，对数据库的需求也越来越高。
为了提高数据库的承载能力和性能，很多大型网站和应用选择使用数据分片和分库分表的方式来处理数据。
本文将介绍如何使用MySQL进行数据分片和分库分表处理。
一、什么是数据分片和分库分表？数据分片（Sharding）是指将一张巨大的表按照某种规则拆分成多个小表，把不同的数据分布在不同的数据库节点中。
这样可以实现数据的并行处理，提高数据库的并发能力。
分库分表（Separation）是指将一张表分散到多个数据库中的不同表中，将不同的数据分布在不同的表中。
这样可以减小单个数据库的负载，并提高查询性能。
二、为什么使用数据分片和分库分表？1. 提高数据库的承载能力：将海量数据分散到不同的节点中，可以充分利用系统资源，提高数据库的承载能力。
2. 提高查询性能：将数据分布在多个表或数据库中，可以并行查询多个节点，减少单点查询的压力，提高查询效率。
3. 提高系统的可用性：将数据分布到多个节点中，即使其中一个节点发生故障，其他节点仍然可以正常工作，提高了系统的可用性。
4. 降低数据库的维护成本：通过分片和分库分表，可以将数据分布到不同的节点中，降低了单个数据库的负载，减少了数据库的维护成本。
三、数据分片的策略在进行数据分片之前，需要选择一个合适的分片策略。
常用的分片策略包括：1. 哈希分片：根据数据的哈希值将数据分布到不同的节点中。
这种策略可以保证数据均匀分布，但对于范围查询和排序操作的支持较差。
2. 范围分片：根据数据的范围将数据分布到不同的节点中。
这种策略适合于按照某个范围进行查询的场景。
3. 一致性哈希分片：通过一致性哈希算法将数据分布到不同的节点中，可以保证数据的负载均衡和扩展性。
分片策略的选择需要根据具体的业务场景和需求进行，合理设计分片策略可以提高系统的性能和可扩展性。
四、分库分表的实现分库分表是在数据分片的基础上，进一步将数据分散到多个数据库中的不同表中。
数据库表分区和分区扩展
数据库表分区是一种数据库管理技术，它将表按照一定的规则划分成多个子集，称为分区。
分区可以提高查询性能、维护效率，并允许更容易地管理大型数据集。
分区通常基于表中的列值进行，例如，可以按照日期范围、地理位置、业务部门等进行分区。
分区扩展则是指在数据库表已经存在分区的基础上，需要进一步增加分区的过程。
这可能是由于数据量的增长或者需要重新调整分区策略。
以下是关于数据库表分区和分区扩展的一些基本概念：
数据库表分区：
1.分区策略：决定如何划分表的策略，可以基于范围、列表、哈希、合成等方式进行。
2.性能提升：通过分区，可以在查询时仅针对特定的分区进行操作，提高查询性能。
3.维护效率：可以针对单个分区进行备份、恢复、重建索引等维护操作，而无需影响整个表。
4.数据生命周期管理：有助于管理数据的生命周期，可以轻松地删除或迁移过期数据。
5.分区键：分区键是用于确定数据放入哪个分区的列。
这通常是一个经常被查询的列，例如日期列。
数据库表分区扩展：
1.增加新分区：当现有分区不足以容纳新数据时，可以增加新的分区。
这可能涉及到在分区键上添加新的范围或值。
2.调整分区策略：随着数据分布和访问模式的变化，可能需要重新评估和调整分区策略。
3.数据迁移：在进行分区扩展时，可能需要将现有数据迁移到新的分区中。
这可以通过数据库维护工具或脚本来实现。
4.性能评估：扩展分区后，需要评估系统性能，确保查询和维护操作仍然在可接受的性能范围内。
5.系统监控：在分区扩展后，建议实施系统监控，以便及时发现潜在的性能问题或瓶颈。
Mysql分区表及⾃动创建分区PartitionRange分区表建表语句如下，其中分区键必须和id构成主键和唯⼀键CREATE TABLE `test1` (`id` char(32) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '⾃增主键(guid)',`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`partition_key` int(8) NOT NULL COMMENT '分区键(格式:yyyyMMdd)',PRIMARY KEY (`id`,`partition_key`),UNIQUE KEY `id_UNIQUE` (`id`,`partition_key`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ciPARTITION BY RANGE (partition_key)(PARTITION p0 VALUES LESS THAN (20180619) ENGINE = InnoDB,PARTITION p2******* VALUES LESS THAN (20180620) ENGINE = InnoDB,PARTITION p2******* VALUES LESS THAN (20180622) ENGINE = InnoDB,PARTITION p2******* VALUES LESS THAN (20180623) ENGINE = InnoDB,PARTITION p2******* VALUES LESS THAN (20180624) ENGINE = InnoDB); 新增分区alter TABLE `test1` add PARTITION(PARTITION p2******* VALUES LESS THAN (20180630) ENGINE = InnoDB); 删除分区alter table `test1` drop PARTITION p2*******;Mysql不能⾃动创建分区，需要使⽤mysql event事件的⽅式⾃动创建分区1.创建分区的存储过程如下（每次执⾏先校验当前分区是否存在，如果存在则不处理；不存在则创建）：DELIMITER $$#该表所在数据库名称USE `demo`$$DROP PROCEDURE IF EXISTS `create_partition_by_day`$$CREATE PROCEDURE `create_partition_by_day`(IN_SCHEMANAME VARCHAR(64), IN_TABLENAME VARCHAR(64))BEGIN#当前⽇期存在的分区的个数DECLARE ROWS_CNT INT UNSIGNED;#⽬前⽇期，为当前⽇期的后⼀天DECLARE TARGET_DATE TIMESTAMP;#分区的名称，格式为p2*******DECLARE PARTITIONNAME VARCHAR(9);#当前分区名称的分区值上限，即为 PARTITIONNAME + 1DECLARE PARTITION_ADD_DAY VARCHAR(9);SET TARGET_DATE = NOW() + INTERVAL 1 DAY;SET PARTITIONNAME = DATE_FORMAT( TARGET_DATE, 'p%Y%m%d' );SET TARGET_DATE = TARGET_DATE + INTERVAL 1 DAY;SET PARTITION_ADD_DAY = DATE_FORMAT( TARGET_DATE, '%Y%m%d' );SELECT COUNT(*) INTO ROWS_CNT FROM information_schema.partitionsWHERE table_schema = IN_SCHEMANAME AND table_name = IN_TABLENAME AND partition_name = PARTITIONNAME;IF ROWS_CNT = 0 THENSET @SQL = CONCAT( 'ALTER TABLE `', IN_SCHEMANAME, '`.`', IN_TABLENAME, '`',' ADD PARTITION (PARTITION ', PARTITIONNAME, " VALUES LESS THAN (",PARTITION_ADD_DAY ,") ENGINE = InnoDB);" );PREPARE STMT FROM @SQL;EXECUTE STMT;DEALLOCATE PREPARE STMT;ELSESELECT CONCAT("partition `", PARTITIONNAME, "` for table `",IN_SCHEMANAME, ".", IN_TABLENAME, "` already exists") AS result; END IF;END$$DELIMITER ; 2.数据库定时任务(每⼩时执⾏⼀次)DELIMITER $$#该表所在的数据库名称USE `demo`$$CREATE EVENT IF NOT EXISTS `daily_generate_partition`ON SCHEDULE EVERY 1 hour #执⾏周期，还有天、⽉等等STARTS '2018-06-20 00:00:00'ON COMPLETION PRESERVEENABLECOMMENT 'Creating partitions'DO BEGIN#调⽤刚才创建的存储过程，第⼀个参数是数据库名称，第⼆个参数是表名称 CALL datacollectcenter.create_partition_by_day('demo','test1');END$$DELIMITER ; 如果没有执⾏，请检查Mysql是否开启了event(默认是关闭的) [mysqld]event_scheduler=ON。
使用MySQL进行数据分区的技巧和方法引言：随着数据量的不断增加，数据库的性能和扩展性成为了许多企业和开发者关注的焦点。
MySQL作为一种常见的关系型数据库管理系统，其提供了数据分区的功能，可以帮助提升数据库的性能和管理效率。
本文将介绍使用MySQL进行数据分区的一些技巧和方法。
1. 什么是数据分区数据分区是将一个大型数据库表拆分为多个小表的过程。
每个小表称为一个分区，它们可以分别存储在不同的物理设备上，或者是分别存储在同一个设备的不同目录中。
通过将数据分散到不同的分区中，可以提高查询性能、写入性能和管理效率。
2. MySQL的数据分区类型MySQL支持以下几种数据分区类型：- 范围分区：按照某个列的范围将数据分区，例如按照订单的时间范围进行分区。
- 列表分区：按照某个列的值列表进行分区，例如按照地区列表将数据分区。
- 哈希分区：按照某个列的哈希值进行分区，例如按照用户ID的哈希值将数据分区。
- 键分区：按照某个列的键值进行分区，例如按照用户ID进行分区。
3. 数据分区的优点- 提高查询性能：将数据分散到多个分区中，可以并行查询多个分区，从而提高查询性能。
- 提高写入性能：将数据分散到多个分区中，可以并行写入多个分区，从而提高写入性能。
- 管理效率：可以根据业务需求对每个分区进行独立的维护和管理，提高管理效率。
4. 如何选择数据分区的列选择合适的列进行数据分区是非常重要的。
一般来说，选择范围广泛且经常使用的列作为分区的列是比较合适的。
以订单表为例，可以选择按照订单的时间范围进行分区，因为根据时间范围查询订单是非常常见的操作。
5. 如何进行数据分区以下是使用MySQL进行数据分区的基本步骤：- 创建表时指定分区方式：在创建表时，可以通过PARTITION BY子句指定分区方式和列。
- 定义分区规则：根据选择的分区方式和列，定义具体的分区规则，例如范围分区可以定义每个分区的时间范围。
- 执行分区操作：在创建表后，可以使用ALTER TABLE语句执行分区操作，将已有数据按照分区规则进行重新分区。
如何通过MySQL实现分布式数据库的数据分片和分区分布式数据库是现代大规模数据存储与处理的必然选择，而MySQL是最常用的关系型数据库之一。
本文将探讨如何通过MySQL实现分布式数据库的数据分片和分区。
1. 引言在面对大规模数据存储与处理的需求时，传统单机数据库往往无法满足性能与可扩展性的要求。
因此，分布式数据库应运而生。
分布式数据库将数据分散存储在多个节点上，每个节点负责处理一部分数据。
其中，数据的分片和分区是分布式数据库的核心概念。
2. 数据分片数据分片是将整个数据库的数据按照某种规则拆分成若干片段，分散存储在不同的节点上。
这样做的好处是能够提高查询和写入的并发性能，减轻单节点的压力。
2.1 分片规则数据分片的规则有多种选择，可以根据数据的特点和业务需求进行定制。
常见的分片规则有以下几种：（1）基于范围的分片：按照某个列的值的范围进行分片，例如按照订单号的范围进行分片。
（2）基于哈希的分片：根据某个列的哈希值进行分片，例如根据用户ID进行哈希分片。
（3）基于一致性哈希的分片：使用一致性哈希算法将数据均匀地分布在多个节点上，保持负载均衡。
2.2 分片策略在选择分片规则的同时，还需要制定合适的分片策略。
分片策略涉及到分片的数量、节点的增减、数据的迁移等问题。
常见的分片策略有以下几种：（1）垂直分片：根据数据的业务属性将不同的表分散到不同的节点上，实现数据的分割与隔离。
（2）水平分片：根据数据的行数、大小等进行分片，保持每个节点上的数据量相对均匀。
（3）动态分片：根据实时的负载情况动态地调整分片策略，以应对业务的变化。
3. 数据分区数据分区是将每个数据分片进一步划分成更小的单元，提高查询性能和数据管理的灵活性。
分区可以根据时间、范围、列表等多个维度进行划分。
3.1 分区类型MySQL支持的分区类型有以下几种：（1）范围分区：根据某一列的值的范围进行分区，例如根据订单的创建时间进行范围分区。
（2）哈希分区：根据某一列的哈希值进行分区，例如根据用户ID进行哈希分区。
如何使用MySQL进行数据分区和分表在处理大量数据时，数据库的性能和可扩展性是至关重要的。
MySQL作为一种常用的关系型数据库管理系统，提供了数据分区和分表的功能，可以帮助我们优化查询性能并提高数据库的可扩展性。
本文将介绍如何使用MySQL进行数据分区和分表。
一、什么是数据分区数据分区是将表中的数据划分为不同的物理存储单元，可以根据特定的规则将数据分布在不同的分区中。
这样做的好处是可以提高查询效率，避免全表扫描，同时还可以通过分区策略优化备份和恢复操作。
MySQL提供了多种分区类型，包括范围分区、列表分区、哈希分区和键值分区。
在选择分区类型时，可以根据具体的业务需求和数据特点进行选择。
二、如何进行数据分区1. 创建分区表在MySQL中，可以使用CREATE TABLE语句来创建一个分区表。
在创建表的过程中，可以指定分区键（PARTITION BY），确定用于分区的列。
以下是一个示例：CREATE TABLE sales (id INT,amount DECIMAL(10,2),date DATE)PARTITION BY RANGE (YEAR(date)) (PARTITION p0 VALUES LESS THAN (2015),PARTITION p1 VALUES LESS THAN (2016),PARTITION p2 VALUES LESS THAN (2017),PARTITION p3 VALUES LESS THAN MAXVALUE);在上面的示例中，我们以年份作为分区的依据，将数据分为了4个分区。
可以根据具体的需求，调整分区的粒度和分区的数量。
2. 查询分区表在查询时，可以直接对分区表进行查询操作。
MySQL会自动将查询分发给对应的分区，只查询需要的数据，提高查询效率。
例如，可以使用以下语句查询2016年的销售数据：SELECT * FROM sales PARTITION (p1) WHERE YEAR(date) = 2016;3. 备份和恢复分区表备份和恢复分区表时，可以分别对每个分区进行操作，提高备份和恢复的效率。
如何在MySQL中实现数据库的动态扩容和收缩MySQL是一种开源的关系型数据库管理系统，被广泛应用于各种规模的企业和互联网应用中。
当应用规模不断扩大时，数据库的容量需求也会不断增长。
因此，了解如何在MySQL中实现数据库的动态扩容和收缩对于保障系统的可用性和性能至关重要。
数据库的动态扩容是指在不中断数据库服务的情况下，通过一系列措施来增加数据库的存储能力。
而数据库的动态收缩则是指在不中断数据库服务的前提下，通过一系列措施来减少数据库所占用的存储空间。
下面将从两个方面来介绍如何在MySQL中实现数据库的动态扩容和收缩。
一、动态扩容1. 分区表分区表是MySQL提供的一种将表数据按照指定的规则划分到多个分区（即表的分片）中的方式。
通过使用分区表，可以将数据分散存储在多个磁盘上，从而提高数据库的读写性能。
当需要扩容时，只需在新的磁盘上创建新的分区，并将数据迁移至新的分区中即可，而不需要中断数据库的服务。
这种方式适用于那些根据某个范围条件进行查询的表。
2. 数据库集群数据库集群是一种将多个数据库服务器组成一个逻辑数据库并提供高可用性和可扩展性的解决方案。
当需要扩容时，只需将新的数据库服务器加入到集群中即可实现对数据库容量的扩展。
数据库集群通常使用主从复制或者多主复制的方式实现数据的同步与复制，以保证数据的一致性和可用性。
3. 数据库分片数据库分片是一种将一个数据库分成多个较小的数据库，并将数据根据某种规则（如ID为奇数的数据存储在一个数据库中，ID为偶数的数据存储在另一个数据库中）分散存储在不同的数据库中的方式。
数据库分片可以提高系统的并发处理能力和负载均衡能力。
当需要扩容时，只需在新的数据库中创建新的分片，并将部分数据迁移到新的分片中即可，而不需要中断数据库的服务。
二、动态收缩1. 清理无效数据数据库中会存在一些无效数据，如已删除的数据、过期的数据等。
定期清理这些无效数据可以减少数据库所占用的存储空间。
MySQL实现定时建立删除分区来源：中国自学编程网发布日期：2008-09-29最近需要把一个oralce数据库向mysql数据库移植。
oracle库用到了job和存储过程，因为mysql中没有job，所有要用新功能event代替一下，这个是5.1以后才有的新功能，所以稍微研究了一下。
原来需要实现的功能是每间隔一段时间就会建立几个分区，并删除几个分区，以保持数据库只存一段时间内的数据，以下是实现步骤1）首先我们建立表，这个时候就遇到了一点问题，因为mysql PARTITION BY RANGE 的时候只支持按数字类型进行分区，所以不支持直接用date类型分区，而且有很多函数不能在PARTITION BY RANGE 中使用，所以我使用了到公元元年的描述作为划分分区的依据CREATE TABLE `data_table` (`dtime` datetime NOT NULL,`alarm_no` int(8) NOT NULL,`alarm_level` int(1) NOT NULL,`color_index` int(1) NOT NULL,`server_name` varchar(64) NOT NULL,`process_name` varchar(64) NOT NULL,`desciption` varchar(600) NOT NULL) ENGINE=MyISAM DEFAULT CHARSET=gb2312 /*!50100 PARTITION BY RANGE(TO_DAYS(dtime)*24*60*60+TIME_TO_SEC(dtime)) (PARTITION p0 VALUES LESS THAN (0) ENGINE = MyISAM) */;2）然后我们建立存储过程这里是添加表部分的实现，第2个存储过程调用第一个存储过程，control表中存的是一些参数，值得注意的时，因为有可能插入重复的分区，所有我们进行了异常处理，如果出现重复分区异常我们会跳过这次循环继续delimiter //CREATE PROCEDURE `gen_partion_script_proc`(spec_date DATETIME, table_name VARCHAR(64), table_space VARCHAR(64), prefix VARCHAR(64), key_type INTEGER(10), qty_day INTEGER(10))NOT DETERMINISTICSQL SECURITY DEFINERCOMMENT ''begindeclare repeated int default 0;declare result varchar(256);declare par_name varchar(128);declare verrinfo varchar(200);declare fdbk int(10);declare v_sqlcursor int(10);declare v_num int(10);declare i integer(10);declare continue handler for 1493 set repeated=1;declare continue handler for 1517 set repeated=1;set i = 1;dayloop :loopif i > qty_day then leave dayloop;end if;set par_name = concat(prefix,date_format(spec_date, '%Y%m%d'),case when char_length(i) < 2 then concat('0', i) else i end);if key_type = 1 thenset @par_value = round((to_days(spec_date) + i / qty_day) * 24 * 60 * 60); end if;set result = concat('alter table ',table_name,' add partition (partition ',par_name,' values less than (',@par_value,'))');set @v_sql = result;prepare stmt from @v_sql;execute stmt;set i = i + 1;end loop;end;CREATE PROCEDURE `procaddpart`(p_datefrom DATETIME, p_days INTEGER(10)) NOT DETERMINISTICSQL SECURITY DEFINERCOMMENT ''begindeclare done int default 0;declare v_table varchar(64);declare v_tablespace varchar(64);declare v_prefix varchar(64);declare v_keytype integer(10);declare v_qty_day integer(10);declare verrinfo varchar(200);declare i integer(10);declare partion_control cursor forselect table_name, tablesapace, prefix, qty_day, key_typefrom control;declare continue handler for not found set done = 1;set i=1;open partion_control;repeatfetch partion_control into v_table, v_tablespace, v_prefix, v_qty_day, v_keytype;until doneend repeat;close partion_control;dayloop:loopif i>p_days thenleave dayloop;end if;call gen_partion_script_proc (adddate(adddate(p_datefrom,i), -1),v_table,v_tablespace,v_prefix,v_keytype,v_qty_day);set i=i+1;end loop;end;下面是删除分区过程CREATE PROCEDURE `remove_partition_script_proc`(spec_date DATETIME, table_name VARCHAR(64), prefix VARCHAR(64), qty_day INTEGER(10))NOT DETERMINISTICSQL SECURITY DEFINERCOMMENT ''begindeclare par_name varchar(128);declare result varchar(256);declare i integer(10);declare repeated int default 0;declare continue handler for 1507 set repeated=1;set i=1;dayloop:loopif i>qty_day thenleave dayloop;end if;set par_name=concat(prefix,date_format(spec_date,'%Y%m%d'),case whenchar_length(i)<2 then concat('0',i) else i end);set result=concat('alter table ',table_name,' drop partition ',par_name); set @v_sql=result;prepare stmt from @v_sql;execute stmt;set i=i+1;end loop;end;CREATE PROCEDURE `procdelpart`(p_date DATETIME)NOT DETERMINISTICSQL SECURITY DEFINERCOMMENT ''begindeclare done int default 0;declare v_table varchar(64);declare v_prefix varchar(64);declare v_qty_day integer(10);declare partion_control cursor forselect table_name, prefix, qty_dayfrom partition_control_tab;declare continue handler for not found set done = 1;set @i=0;open partion_control;repeatfetch control into v_table,v_prefix,v_qty_day;if not done thenset @i=@i+1;call remove_partition_script_proc(p_date,v_table,v_prefix,v_qty_day); end if;until doneend repeat;close partion_control;commit;end;CREATE PROCEDURE `report_job`(pdate DATETIME)NOT DETERMINISTICSQL SECURITY DEFINERCOMMENT ''begincommit;select data_keeped_daysinto @keeped_daysfrom config;if @keeped_days > 0thencall procdelpart (adddate(pdate,-@keeped_days));end if;commit;end;3）最后我们建立event，跟 oracle的job作用一样，定时执行任务。
