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
image.png
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
本篇开胃菜到此结束。
转载请备注原文链接。
网友评论