MyCAT（一）快速上手-初体验

16年的时候因为工作原因，曾经花了一番功夫去了解阿里开源的分库分表的中间件Corbar的源码实现。
原本想基于Corbar的实现来写一个关于数据库分库分表的系列博客，后来了解到脱胎于Corbar，由一些社区大牛开发出了更加强大的MyCAT，不仅解决了Cobar生产环境中出现的一些严重的问题，更加入了很多优秀的实现。

本系列文章将由浅入深的学习强大的数据库分库分表中间件MyCAT。
GitHub: https://github.com/MyCATApache/Mycat-Server
版本：1.6-Release
Mycat权威指南官方下载: https://github.com/MyCATApache/Mycat-Server/blob/4135f25df8239d52d220529cbf7cb697ede40e12/mycat-definitive-guide.pdf

本篇我们先按步骤来个初体验。

1、clone 项目到本地，Checkout Tag 1.6-Release

2、按如下配置schema.xml、server.xml、rule.xml，跟Corbar配置基本一致。节点属性含义请查阅mycat-definitive-guide.pdf，在此不做赘述。
schema.xml

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
    <schema name="TESTDB" checkSQLschema="true" sqlMaxLimit="100">
        <table name="travelrecord" dataNode="dn1,dn2,dn3" rule="auto-sharding-long" />
        <table name="company" primaryKey="ID" type="global" dataNode="dn1,dn2,dn3" />
        <table name="hotnews" primaryKey="ID" autoIncrement="true" dataNode="dn1,dn2,dn3"  rule="mod-long" />
    </schema>

    <dataNode name="dn1" dataHost="localhost1" database="db1" />
    <dataNode name="dn2" dataHost="localhost1" database="db2" />
    <dataNode name="dn3" dataHost="localhost1" database="db3" />
    <dataHost name="localhost1" maxCon="20" 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="xxxx">
        </writeHost>
    </dataHost>
</mycat:schema>

server.xml和rule.xml由于本篇只做简单体验，不做配置。

3、按schema.xml配置在本地mysql数据库中建立相应的数据库表，如下：

image.png

便于各位玩家快速体验，直接贴出建表语句：

CREATE TABLE `company` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `name` varchar(64) DEFAULT '',
  `market_value` bigint(20) DEFAULT '0',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4;

CREATE TABLE `hotnews` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `title` varchar(64) DEFAULT '',
  `content` varchar(512) DEFAULT '0',
  `time` varchar(8) DEFAULT '',
  `cat_name` varchar(10) DEFAULT '',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `travelrecord` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `city` varchar(32) DEFAULT '',
  `time` varchar(8) DEFAULT '',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

4、运行MycatStartup.java，运行成功控制台打印如下：

image.png

5、因为MyCAT作为数据库中间代理层统一管理所有的数据源，后端数据库集群对前端应用程序透明。基本支持各种客户端直连。本篇我们代理的是MySQL数据源，直接用Navicat for MySQL连接MyCAT服务：

image.png

展开逻辑数据库TESTDB:

image.png

6、针对各个数据表写几条插入语句，看看执行结果
表travelrecord相关配置：

<table name="travelrecord" dataNode="dn1,dn2,dn3" rule="auto-sharding-long" />
    <tableRule name="auto-sharding-long">
        <rule>
            <columns>id</columns>
            <algorithm>rang-long</algorithm>
        </rule>
    </tableRule>
    <function name="rang-long"
        class="io.mycat.route.function.AutoPartitionByLong">
        <property name="mapFile">autopartition-long.txt</property>
    </function>

测试语句1：

insert into travelrecord(`city`, `time`) values('NANJING', '20180906');

未指定分片列id，直接报错：

image.png

测试语句2：

insert into travelrecord(`id`, `city`, `time`) values(1, 'NANJING', '20180906');

执行成功，数据落入db1.travelrecord

表company相关配置：

<table name="company" primaryKey="ID" type="global" dataNode="dn1,dn2,dn3" />

测试语句3：

insert into company(`name`, `market_value`) values('yunmanman', 130);

执行成功，数据落入db1.travelrecord、db2.travelrecord、db3.travelrecord。
type="global"为全局表，数据冗余到各个分片，避免跨分片join。

表hotnews相关配置：

        <table name="hotnews" primaryKey="ID" autoIncrement="true" dataNode="dn1,dn2,dn3"
               rule="mod-long" />
    <tableRule name="mod-long">
        <rule>
            <columns>id</columns>
            <algorithm>mod-long</algorithm>
        </rule>
    </tableRule>
    <function name="mod-long" class="io.mycat.route.function.PartitionByMod">
        <!-- how many data nodes -->
        <property name="count">3</property>
    </function>

测试语句4：

insert into hotnews(`title`, `content`) values('波音飞机', '波音埃塞俄比亚坠机');

执行成功，数据落入db1.hotnews。
对比测试语句1发现，同样是未指定分片列id，加入属性autoIncrement="true"后，主键自增对应用透明。

image.png

本篇开胃菜到此结束。