使用MyCat单库分表实战详解

曾经终败给现在 2023-07-11 15:23 95阅读 0赞

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

### 本文目录 ###

*  1. 场景
 *  2. 实现
 *  3. 配置真实服务器信息
 *  4. 配置路由规则
 *  5. 配置MyCat服务信息
 *  6. 启动测试

# 1. 场景 #

比如一个大型集团公司，有一张表record保存了交易记录信息。该表数据量很大，但是查询、更新时基本都是按子公司来操作。

那么可以按子公司编号进行分表。例如子公司编号1的交易记录存储到record\_1表，同理子公司编号为2的交易记录保存到record\_2中…

# 2. 实现 #

在mysql中新建数据库实例dbcompany，并新建record0-record3，共4张表，代码如下

CREATE TABLE `record_0` (
      `id` int(11) NOT NULL,
      `companyid` int(11) DEFAULT NULL COMMENT '子公司编号',
      `info` varchar(255) DEFAULT NULL COMMENT '业务信息',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    
    CREATE TABLE `record_1` (
      `id` int(11) NOT NULL,
      `companyid` int(11) DEFAULT NULL COMMENT '子公司编号',
      `info` varchar(255) DEFAULT NULL COMMENT '业务信息',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    
    CREATE TABLE `record_2` (
      `id` int(11) NOT NULL,
      `companyid` int(11) DEFAULT NULL COMMENT '子公司编号',
      `info` varchar(255) DEFAULT NULL COMMENT '业务信息',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    
    CREATE TABLE `record_3` (
      `id` int(11) NOT NULL,
      `companyid` int(11) DEFAULT NULL COMMENT '子公司编号',
      `info` varchar(255) DEFAULT NULL COMMENT '业务信息',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

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

通过修改conf/schema.xml，来配置真实服务器的信息，并为数据库划分节点，指定数据表所在的节点。

注意关键信息为`subTables="record_$0-3"`和`rule="rule-record"`，通过规则分片后，数据会落入record\_0至record\_3中。

<?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="record" subTables="record_$0-3" dataNode="dn1" rule="rule-record" />
      </schema>
      
      <dataNode name="dn1" dataHost="localhost1" database="dbcompany" />
      
      <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="hostM1" url="127.0.0.1:3306" user="root" password="Easy@0122"/>
      </dataHost>
    </mycat:schema>

# 4. 配置路由规则 #

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

修改conf/role.xml，配置规则如下，注意我们是按`companyid列`来进行规则应用的。

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mycat:rule SYSTEM "rule.dtd">
    <mycat:rule xmlns:mycat="http://io.mycat/">
      
      <tableRule name="rule-record">
        <rule>
          
          <columns>companyid</columns>
          <algorithm>mod-long</algorithm>
        </rule>
      </tableRule>
      <function name="mod-long" class="io.mycat.route.function.PartitionByMod">
        
        <property name="count">4</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，然后使用Navicat或其他工具连接MyCat虚拟的数据库即可。

我们执行如下8条sql语句

insert into record (id,companyid,info)values(1,1,'test');
    insert into record (id,companyid,info)values(4,2,'test');
    insert into record (id,companyid,info)values(2,3,'test');
    insert into record (id,companyid,info)values(3,4,'test');
    insert into record (id,companyid,info)values(5,5,'test');
    insert into record (id,companyid,info)values(7,6,'test');
    insert into record (id,companyid,info)values(6,7,'test');
    insert into record (id,companyid,info)values(8,8,'test');

执行完之后，我们看下真实物理数据库中的数据：  
record\_0数据如下，说明是按companyid取模匹配的，我们的策略生效了！  
![在这里插入图片描述][20200306154402331.png]  
其他三个库也是按此规则运作的，即数据落入`record_[companyid%4]`表。

[Link 1]: https://studyingpanda.blog.csdn.net/article/details/105329926
[20200306154402331.png]: https://img-blog.csdnimg.cn/20200306154402331.png