使用MyCat分库实战详解

爱被打了一巴掌 2023-07-11 15:07 82阅读 0赞

***[点此查看全部文字教程、视频教程、源代码][Link 1]***

### 本文目录 ###

*  1. 环境准备
 *  2. 数据库准备
 *  3. 配置真实服务器信息
 *  4. 配置路由规则
 *  5. 配置MyCat服务信息
 *  6. 启动测试
 *  7. 数据插入与查询测试

# 1. 环境准备 #

JDK 1.8，官网下载安装即可。  
MySQL 5.7，官网下载安装即可。  
MyCat1.6.5，下载地址`http://dl.mycat.io/1.6.5/`，此处我们选择windows版本下载即可。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70]  
下载解压后，直接双击bin/startup\_nowrap.bat即可启动MyCat  
![在这里插入图片描述][20200306101809954.png]

# 2. 数据库准备 #

我们来模拟一个博客系统的数据库，规划设计三个库db001、db002、db003，我们先将三个库都放到本地数据库实例中，后续如果是部署到云端的话，更改服务器地址信息即可。

然后我们有两个表用户表user和博客表blog，用户表存储于db001，博客表存储于db001/db002/db003。

所以在db001执行如下语句创建user表

CREATE TABLE `user` (
      `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增序号',
      `name` varchar(255) DEFAULT '' COMMENT '姓名',
      `password` varchar(255) DEFAULT '' COMMENT '密码',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=latin1;

然后再db001/db002/db003执行如下语句创建blog表

CREATE TABLE `blog` (
      `id` int(11) NOT NULL COMMENT '序号',
      `title` varchar(255) DEFAULT '' COMMENT '博客标题',
      `content` varchar(255) DEFAULT '' COMMENT '博客内容',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=latin1;

数据库创建完成后结构如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70 1]

# 3. 配置真实服务器信息 #

通过修改`conf/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="user" dataNode="dn1" />
        
        <table name="blog" dataNode="dn1,dn2,dn3" rule="rule-blog" />
      </schema>
    
      
      <dataNode name="dn1" dataHost="localhost1" database="db001" />
      <dataNode name="dn2" dataHost="localhost1" database="db002" />
      <dataNode name="dn3" dataHost="localhost1" database="db003" />
    
      
      <dataHost name="localhost1" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
        <heartbeat>select user()</heartbeat>
        
        <writeHost host="server1" url="localhost:3316" user="root" password="Easy@0122" />
      </dataHost>
    </mycat:schema>

# 4. 配置路由规则 #

在schema.xml中我们已经制定了blog表存储的节点，且设置了路由规则的名称`rule-blog`，然后我们设置该规则具体的策略。

修改`conf/role.xml`，配置规则如下

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

# 5. 配置MyCat服务信息 #

通过上面两个配置文件，我们已指定了库、表、分表路由规则，下面我们将其通过MyCat暴露出来，让客户端进行访问。

通过修改`conf/server.xml`配置MyCat对外服务信息，主要就是用户名、密码、以及上面指定的抽象数据库名称TESTDB。

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mycat:server SYSTEM "server.dtd">
    <mycat:server xmlns:mycat="http://io.mycat/">
      
      <system>
        <property name="nonePasswordLogin">0</property>    
        <property name="useHandshakeV10">1</property>
        <property name="useSqlStat">0</property>    
        <property name="useGlobleTableCheck">0</property>    
        <property name="sequnceHandlerType">2</property>
        <property name="subqueryRelationshipCheck">false</property>    
        
        <property name="processorBufferPoolType">0</property>
        
        <property name="handleDistributedTransactions">0</property>
        
        <property name="useOffHeapForMerge">1</property>
        
        <property name="memoryPageSize">64k</property>
        
        <property name="spillsFileBufferSize">1k</property>
        <property name="useStreamOutput">0</property>
        
        <property name="systemReserveMemorySize">384m</property>
        
        <property name="useZKSwitch">false</property>
      </system>
      
      <user name="root" defaultAccount="true">
        <property name="password">123456</property>
        
        <property name="schemas">TESTDB</property>
      </user>
    </mycat:server>

# 6. 启动测试 #

双击bin/startup\_nowrap.bat启动MyCat，如图启动成功：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70 2]  
我们使用navicat（其他工具也可以），通过上面配置的MyCat用户名密码连接MyCat，如下图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70 3]  
连接成功后，会发现一个数据库TESTDB，及两张表user/blog，TESTDB即为MyCat抽象出来的数据库，操作TESTDB中的数据会按照当时设定的规则，实际操作会发生在db001/db002/db003中，这个我们不必关心，MyCat会自动为我们实现。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70 4]

# 7. 数据插入与查询测试 #

我们在TESTDB执行6次insert语句。

insert into blog(id,title,content)values(1,"title1","content1")
    insert into blog(id,title,content)values(2,"title2","content2")
    insert into blog(id,title,content)values(3,"title3","content3")
    insert into blog(id,title,content)values(4,"title4","content4")
    insert into blog(id,title,content)values(5,"title5","content5")
    insert into blog(id,title,content)values(6,"title6","content6")

在TESTDB查询有6条数据，说明插入成功。  
而db001有id为3/6的数据。  
db002有id为1/4的数据。  
db003有id为2/5的数据。  
说明MyCat自动为我们取模了。

[Link 1]: https://studyingpanda.blog.csdn.net/article/details/105329926
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200306101517264.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc=,size_16,color_FFFFFF,t_70
[20200306101809954.png]: https://img-blog.csdnimg.cn/20200306101809954.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200306102455727.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200306110006606.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20200306110854158.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20200306111037334.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dvc2hpc2FuZ3Nhbmc=,size_16,color_FFFFFF,t_70