【实战演练】Linux操作系统21-MyCat实现Mysql数据库分表分库

本文欢迎转载，转载请注明出处和作者。

理论部分，详见《【理论研究】业务系统高可用及负载均衡》。

本篇主要实现“9、Mysql分表分库”，需要在上一篇MyCat读写分离完成的基础上。

1、Mycat配置

如果原来mysql01(30.28)有一个数据库例如dqzqcw，打算存放2张表格，一张表格叫test01，另外一张表格叫test02。

现在test01依然保留在30.28的dqzqcw里面，30.28创建一个新的数据库假设叫spilt的数据库，然后计划将test02原来的数据，分片到放到dqzqcw与split两个数据库里面存放。

在30.28的数据库dqzqcw与split两个库分别创建一张叫test02的数据库表。

CREATE DATABASE split CHARACTER SET utf8 COLLATE utf8_general_ci;  

use split;

CREATE TABLE test02 (
    id INT NOT NULL AUTO_INCREMENT,
    city varchar(50) NOT NULL,
    PRIMARY KEY (id)
    )AUTO_INCREMENT= 1 ENGINE=InnoDB DEFAULT CHARSET=utf8;

插入数据

insert into split.test02 values(1,"beijing");

切换数据库

use dqzqcw;

CREATE TABLE test02(
    id INT NOT NULL AUTO_INCREMENT,
    city varchar(50) NOT NULL,
    PRIMARY KEY (id)
    )AUTO_INCREMENT= 1 ENGINE=InnoDB DEFAULT CHARSET=utf8;

插入数据

insert into dqzqcw.test02 values(1,"shanghai");

登录mycat进行server.xml文件、rule.xml文件、schema.xml文件修改。Server与前面一样。

rule.xml文件配置（定义分片规则）如下：

（如果删除原有rule.xml文件，重新新建，则以下为全部内容）

<?xml version="1.0" encoding="UTF-8"?>
<!-- - - Licensed under the Apache License, Version 2.0 (the "License");
    - you may not use this file except in compliance with the License. - You
    may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0
    - - Unless required by applicable law or agreed to in writing, software -
    distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT
    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the
    License for the specific language governing permissions and - limitations
    under the License. -->
<!DOCTYPE mycat:rule SYSTEM "rule.dtd">
<mycat:rule xmlns:mycat="http://io.mycat/">

    <tableRule name="mycat-rule">                <!-- test02表分片的规则名，这里定义为mycat-rule，这个需要在schema.xml文件中引用 -->
        <rule>
            <columns>id</columns>                  <!-- test02表的分片列 -->
            <algorithm>mod-long</algorithm>
        </rule>
    </tableRule>

    <function name="mod-long" class="io.mycat.route.function.PartitionByMod">
        <!-- how many data nodes -->
        <property name="count">2</property>        <!-- count值与分片个数相同，这里test02表分片到dqzqcw库和split库里，共2份。 -->
    </function>
</mycat:rule>

（如果直接修改rule.xml文件，则需要新增mycat-rule规则，并且将原有的function name="mod"-long内容由3修改为2）

以下内容为新增内容

    <tableRule name="mycat-rule">
    <!-- test02表分片的规则名，这里定义为mycat-rule，这个需要在schema.xml文件中引用 -->
        <rule>
            <columns>id</columns>     
            <!-- test02表的分片列 -->
            <algorithm>mod-long</algorithm>
        </rule>
    </tableRule>

以下内容为修改部分

<function name="mod-long" class="io.mycat.route.function.PartitionByMod">
        <!-- how many data nodes -->
        <property name="count">2</property>        
        <!-- count值与分片个数相同，这里test02表分片到dqzqcw库和split库里，共2份。 -->
 </function>

schema.xml文件

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">

<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100" >
        <table name="test01" primaryKey="id"  dataNode=" dqzqcw_db " />
        <table name="test02" primaryKey="id" dataNode="dqzqcw_db,split_db " rule="mycat-rule" />
</schema>

<dataNode name="dqzqcw_db" dataHost="Mycat-node" database="dqzqcw" />
<dataNode name="split_db" dataHost="Mycat-node" database="split" />

<dataHost name="Mycat-node" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
        <heartbeat>show slave status</heartbeat>
        <writeHost host="Mysql-node1" url="10.1.30.28:3306" user="root" password="1qaz!QAZ">
             <readHost host="Mysql-node2" url="10.1.30.29:3306" user="root" password="1qaz!QAZ ">
             </readHost>
        </writeHost>
        <writeHost host="Mysql-node1" url="10.1.30.29:3306" user="root" password="1qaz!QAZ">
        </writeHost>
    </dataHost>
</mycat:schema>

<table>部分定义了那些表从哪个dataNode进行读写，依照什么规则分片。

综上，可以看到其他writeHost、ReadHost配置与上面读写分离+主从自动切换时一致的，也就是说也具备读写分离+主从自动切换+分表分库的作用，重启mycat服务生效。

./mycat stop
./mycat start
service keepalived restart

2、测试分表分库

2.1手动插入数据测试分表分库

登录mycat

mysql -u root -h 10.1.30.30 -P 8066 -p

查询做了分表分库的数据库表数据

select * from test02

尝试插入数据

insert into test02(id,city) values(20,"chognqing");  
insert into test02 (id,city) values(22,"xianggang");
insert into test02 (id,city) values(23,"huoqiu");
insert into test02 (id,city) values(24,"haikou");
insert into test02 (id,city) values(25,"anqing");
insert into test02 (id,city) values(26,"tianqing");
insert into test02 (id,city) values(27,"hangzhou");
insert into test02 (id,city) values(28,"chengdu");

然后直接登录mysql01数据库，查看刚插入的数据在dqzqcw与split库里面的分布。

select * from dqzqcw.test02 
select * from split.test02

在mycat里往做了分片策略的test02表里写入的数据，已经分片到dqzqcw和split两个库里了，即成功实现了分库分表功能。