文章目录
- 1.按天分片的概念
- 1.按天分片的概念
- 2.按照天数对某张表进行水平拆分
- 2.1.在所有的分片节点中创建表结构
- 2.2.配置Mycat实现字符串按天分片的水平分表
- 2.2.1.配置Schema配置文件
- 2.2.2.配置Rule分片规则配置文件
- 2.2.3.配置Server配置文件
- 2.2.4.重启Mycat
- 2.3.写入数据观察分片效果
1.按天分片的概念
1.按天分片的概念
按照日期进行分片,单位为天,根据设置的规则属性,例如10天一分表,每10天就会进行一次分表。
如下图所示,设置分表的属性为10天进行一次分表,分表周期是2022-01-01到2022-01-30这个时间范围,每隔10天进行一次分表,那么在这个范围内一共会进行3次分片,注意以时间范围进行分表,分表的次数要与分片的节点数相对应,否则将会分表失败。
2.按照天数对某张表进行水平拆分
需求:目前有一张tb_datepart表,以create_time字段作为分表依据,每10天进行一次分表。
2.1.在所有的分片节点中创建表结构
分片依旧是2个,还是之前垂直分库分表时使用的两套双主双从集群。
#在分片1节点中创建表结构
[root@mysql-1 ~]# mysql -uroot -p123456 -P3306 -h 192.168.20.11
mysql> use db_2;
mysql> create table tb_datepart (id int,name varchar(10),create_time date);
#在分片2节点中创建表结构
[root@mysql-1 ~]# mysql -uroot -p123456 -P3307 -h 192.168.20.11
mysql> use db_2;
mysql> create table tb_datepart (id int,name varchar(10),create_time date);
2.2.配置Mycat实现字符串按天分片的水平分表
2.2.1.配置Schema配置文件
[root@mysql-1 ~]# vim /data/mycat/conf/schema.xml
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
<!--定义逻辑库 库名叫做db_shopping 该逻辑库关联dn1这个数据节点-->
<schema name="db_2" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1">
<!-- 按天分片 -->
<table name="tb_datepart" dataNode="dn1,dn2" rule="sharding-by-date" />
</schema>
<!--定义数据节点 也就是分片 一个分片会关联一个数据主机组 然后对应真实的数据库名称-->
<dataNode name="dn1" dataHost="mysqlcluster-1" database= "db_2" />
<dataNode name="dn2" dataHost="mysqlcluster-2" database= "db_2" />
<!--定义数据主机 在这个标签下定义具体的读写操作路由的数据库实例地址 schema、table划分如何指定的是该数据主机关联的数据节点 那么对应的库、表都会被存储在数据主机定义的数据库实例中-->
<dataHost name="mysqlcluster-1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<!--定义写操作路由的数据库实例-->
<writeHost host="c1-1-master3306" url="192.168.20.11:3306" user="root" password="123456">
<!--定义读操作路由的数据库实例-->
<readHost host="c1-1-slave3308" url="192.168.20.11:3308" user="root" password="123456" />
</writeHost>
<!--备用的主库 也是提供写操作的数据库,当主库c1-1-master3306故障后 备用库开始提供写操作-->
<writeHost host="c1-2-master3306" url="192.168.20.12:3306" user="root" password="123456">
<!--备用主库的从库 从始至终 只要备用主库不故障 会一直提供读服务-->
<readHost host="c1-2-slave3308" url="192.168.20.12:3308" user="root" password="123456" />
</writeHost>
</dataHost>
<dataHost name="mysqlcluster-2" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="c2-1-master3307" url="192.168.20.11:3307" user="root" password="123456">
<readHost host="c2-1-slave3309" url="192.168.20.11:3309" user="root" password="123456" />
</writeHost>
<!--备用主库db3 主库db1故障后 开始提供写操作-->
<writeHost host="c2-2-master3307" url="192.168.20.12:3307" user="root" password="123456">
<!--备用主库的从库 从始至终 只要备用主库不故障 会一直提供读服务-->
<readHost host="c2-2-slave3309" url="192.168.20.12:3309" user="root" password="123456" />
</writeHost>
</dataHost>
</mycat:schema>
2.2.2.配置Rule分片规则配置文件
[root@mysql-1 ~]# vim /data/mycat/conf/rule.xml
<tableRule name="sharding-by-date">
<rule>
<columns>create_time</columns>
<algorithm>sharding-by-date</algorithm>
</rule>
</tableRule>
<function name="sharding-by-date" class="io.mycat.route.function.PartitionByDate">
<!--定义日期格式-->
<property name="dateFormat">yyyy-MM-dd</property>
<!--定义按天分表的开始日期-->
<property name="sBeginDate">2022-01-01</property>
<!--定义按天分表的结束日期-->
<property name="sEndDate">2022-01-30</property>
<!--分表的间隔天数 按照天数分表后,在范围内分表的次数一定要和分片的数据量相对于,比如10天分一次表,指定时间范围内分3次表,那么分片节点的数量一定要大于等于3,否则分表将会失败-->
<property name="sPartionDay">15</property>
<!--我们只有2个分片,因此每个月分两张表-->
</function>
2.2.3.配置Server配置文件
[root@mysql-1 ~]# vim /data/mycat/conf/server.xml
<user name="root" defaultAccount="true">
<!--登录用户的密码-->
<property name="password">123456</property>
<!--该用户登录后可以显示那些Schema-->
<property name="schemas">db_2</property>
</user>
2.2.4.重启Mycat
[root@mysql-1 ~]# mycat restart
Stopping Mycat-server...
Stopped Mycat-server.
Starting Mycat-server...
2.3.写入数据观察分片效果
[root@mysql-1 ~]# mysql -uroot -p123456 -P8066 -h 192.168.20.11
mysql> use db_2;
mysql> insert into tb_datepart(id,name ,create_time) values(1,'Tom','2022-01-01');
mysql> insert into tb_datepart(id,name ,create_time) values(2,'Cat','2022-01-10');
mysql> insert into tb_datepart(id,name ,create_time) values(3,'Rose','2022-01-11');
mysql> insert into tb_datepart(id,name ,create_time) values(4,'Coco','2022-01-20');
mysql> insert into tb_datepart(id,name ,create_time) values(5,'Rose2','2022-01-21');
mysql> insert into tb_datepart(id,name ,create_time) values(6,'Coco2','2022-01-30');
mysql> insert into tb_datepart(id,name ,create_time) values(7,'Coco3','2022-01-31');
可以看到1号到15号的数据写入到了分片1中,15-30号的数据写入到了分片2中,31号的数据相当于下一个轮回,写入到分片1。
在rule配置文件中定义的日期并不是写死的,下个月的数据也会按照响应的天数再进行分表。