使用mycat分库分表

旧城等待， 2021-09-01 08:10 472阅读 0赞

本教程是在window环境下运行的，实际生产推荐在Linux上运行。  
必备条件(软件请自行安装)：

JDK：建议是1.7及其以上。
    MySQL：必须是5.5及其以上。
    
    
    
    两张表users和item，三个数据库test01,test02,test03（三个库在一个数据库实例上）
    users只在test01中存储。
    item表被分割到test02和test03中存储。

create database test01 if not exists test01;
    use test01;
     CREATE TABLE users ( 
        id INT NOT NULL AUTO_INCREMENT, 
        name varchar(50) NOT NULL default '', 
        indate DATETIME NOT NULL default '0000-00-00 00:00:00', 
        PRIMARY KEY (id) 
    )AUTO_INCREMENT= 1 ENGINE=InnoDB DEFAULT CHARSET=utf8;

在test02和test03中分别创建item表，SQL脚本如下

create database test02 if not exists test02;
    use test02;
     CREATE TABLE item ( 
        id INT NOT NULL AUTO_INCREMENT, 
        value INT NOT NULL default 0, 
        indate DATETIME NOT NULL default '0000-00-00 00:00:00', 
        PRIMARY KEY (id) 
    )AUTO_INCREMENT= 1 ENGINE=InnoDB DEFAULT CHARSET=utf8;
     
    create database test03 if not exists test03;
    use test03;
    CREATE TABLE item ( 
        id INT NOT NULL AUTO_INCREMENT, 
        value INT NOT NULL default 0, 
        indate DATETIME NOT NULL default '0000-00-00 00:00:00', 
        PRIMARY KEY (id) 
    )AUTO_INCREMENT= 1 ENGINE=InnoDB DEFAULT CHARSET=utf8;

开始使用

先打mycat官方网站上下载安装包，网址为mycat 下载图如下所示： http://dl.mycat.io/1.6-RELEASE/

下载：Mycat-server-1.6-RELEASE-20161028204710-win.tar.gz

然后在conf目录下编辑service.xml，rule.xml，schema.xml三个文件。
    service.xml主要配置mycat服务的参数，比如端口号，myact用户名和密码使用的逻辑数据库等
    role.xml主要配置路由策略，主要有分片的片键，拆分的策略（取模还是按区间划分等）
    schema.xml文件主要配置数据库的信息，例如逻辑数据库名称，物理上真实的数据源以及表和数据源之间的对应关系和路由策略等。
    
    配置如下所示：

Service.xml

<?xml version="1.0" encoding="UTF-8"?> 
    <!DOCTYPE mycat:server SYSTEM "server.dtd"> 
    <mycat:server xmlns:mycat="http://io.mycat/"> 
            <system> 
                 
                    <property name="defaultSqlParser">druidparser</property> 
                    <property name="mutiNodeLimitType">1</property> 
                    <property name="serverPort">8066</property> 
                    <property name="managerPort">9066</property>  
            </system> 
             
            <user name="test"> 
                    <property name="password">test</property> 
                    <property name="schemas">TESTDB</property> 
            </user> 
     
            <user name="user"> 
                    <property name="password">user</property> 
                    <property name="schemas">TESTDB</property> 
                    <property name="readOnly">true</property> 
            </user> 
           
    </mycat:server>

Rule.xml

<?xml version="1.0" encoding="UTF-8"?>
    
    <!DOCTYPE mycat:rule SYSTEM "rule.dtd">
    <mycat:rule xmlns:mycat="http://io.mycat/">
    	<tableRule name="rule1">
    		<rule>
    			<columns>id</columns>
    			<algorithm>mod-long</algorithm>
    		</rule>
    	</tableRule>
    
    	<function name="mod-long" class="io.mycat.route.function.PartitionByMod">
            
            <property name="count">2</property>
        </function>
    </mycat:rule>

schema.xml 数据库的url,usename,password按实际情况填写。

<?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="users" primaryKey="id"  dataNode="node_db01" /> 
            <table name="item" primaryKey="id" dataNode="node_db02,node_db03" rule="rule1" /> 
     
        </schema> 
     
         
        <dataNode name="node_db01" dataHost="dataHost01" database="test01" /> 
        <dataNode name="node_db02" dataHost="dataHost01" database="test02" /> 
        <dataNode name="node_db03" dataHost="dataHost01" database="test03" /> 
     
         
        <dataHost name="dataHost01" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native"> 
                <heartbeat>select user()</heartbeat> 
                <writeHost host="server1" url="127.0.0.1:3306" user="root" password="root2019#"/> 
        </dataHost> 
    </mycat:schema>

已经配置完毕，启动测试

在命令行切换到mycat的bin目录下，然后执行如下命令：

![在这里插入图片描述][20191224191137770.png]运行bat文件，启动成功会有提示，如下图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzM3OTI3_size_16_color_FFFFFF_t_70]然后表示我们启动服务成功。

在命令行访问mycat逻辑数据库，采用如下的命令：

mysql -utest -ptest -h127.0.0.1 -P8066 -DTESTDB

现在通过数据库查询数据库和表，发现只有逻辑数据库TESTDB而不是test01, test02, test03；而且表也是统一显示的，而不是分布在不同的实际数据库中,。参考图片如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzM3OTI3_size_16_color_FFFFFF_t_70 1]现在在访问Mycat在数据库中插入数据，看数据能否按照前面配置的路由规则进行分表。

现在执行如下的SQL语句进行数据的插入。

insert into users(name,indate) values(‘kk’,now());  
insert into users(name,indate) values(‘ss’,now());  
insert into item(id,value,indate) values(1,100,now());  
insert into item(id,value,indate) values(2,100,now());

然后在mycat上查看是否插入成功，下图显示插入成功。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzM3OTI3_size_16_color_FFFFFF_t_70 2]可以查看数据库，发现分表操作已经完成，插入的item数据，根据id取模在不同的库当中，查询时候mycat已经完成了合并数据的操作。

参考：https://www.cnblogs.com/mracale/p/8989248.html

[20191224191137770.png]: /images/20210901/8a35716279c544d3ac06b5a664246b13.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzM3OTI3_size_16_color_FFFFFF_t_70]: /images/20210901/6159b8a68c074a8a8b845250addfc4e6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzM3OTI3_size_16_color_FFFFFF_t_70 1]: /images/20210901/83a008a216c24e9cb09c9de182b6de64.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzM3OTI3_size_16_color_FFFFFF_t_70 2]: /images/20210901/aa541e5f147d4eb7a9c8d0bead77bbc5.png