1、下载
从如下地址下载 mycat 的安装包:
http://www.mycat.io/
2、解压
解压下载的安装包
3、安装
安装 mycat 前需要先安装 jdk 和 mysql。mycat1.6 版本建议使用的 jdk 是 1.7 以上版本,mysql 建议使用 5.6 版本。安装玩 jdk 和 mysql 后,进入 mycat 解压目录下的 bin 目录,如本文的路径如下:
D:\Program Files (x86)\mycat\bin
安装 shift 键,点击鼠标右键,选择"在此处打开命令窗口"打开命令行窗口(注意需要管理员账户登录,如果不是请使用管理员身份运行 cmd 打开命令行窗口)。在打开的命令行窗口中执行如下命令安装 mycat:
mycat.bat install
4、启动和停止
可以使用如下命令启动 mycat 服务
mycat.bat start
启动后可以通过如下命令查看mycat的运行状态:
mycat.bat status
可以使用如下命令停止mycat服务
mycat.bat stop
复制代码
5、测试
5.1、修改 mycat 与 mysql 的链接信息
我们打开 mycat 安装目录,并进入 conf 目录,打开 schema.xml 配置文件,schema.xml 配置文件是 mycat 中重要的配置文件之一,它涵盖了 mycat 的逻辑库、表、分片规则、分批按节点及数据源。这里我们对默认的 schema.xml 进行简单的修改配置(注意备份一个原始的配置文件),主要配置本机的 mysql 链接信息。找到 dataHost 节点,按照当前自己 mysql 的配置信息来修改配置。如下为我修改后的该部分配置:
<dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"
writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
<heartbeat>select user()</heartbeat>
<!-- can have multi write hosts -->
<writeHost host="hostM1" url="localhost:3306" user="root"
password="root">
<!-- can have multi read hosts -->
<!--<readHost host="hostS2" url="192.168.1.200:3306" user="root" password="xxx" />-->
</writeHost>
<!--
<writeHost host="hostS1" url="localhost:3316" user="root"
password="123456" />
-->
<!-- <writeHost host="hostM2" url="localhost:3316" user="root" password="123456"/> -->
</dataHost>
复制代码
我主要修改了 hostM1 的链接密码,同时注释了名称为 hostS2 的只读标签和名称为 hostM2 的写标签。
5.2、创建数据库
按照 schema.xml 配置中的示例,我们需要建立分别名为 db1、db2、db3 的数据库。链接 mysql,建立相关的数据库:
mysql -uroot -proot;
create database db1 character set utf8;
create database db2 character set utf8;
create database db3 character set utf8;
复制代码
5.3、链接数据库
使用数据库链接工具或命令。本文使用 navicat 链接数据库。使用 navicat 链接数据库时的主要参数配置如下:
端口号:8066
用户名和密码可以查看 mycat conf 目录中的 server.xml 中的定义,本文使用的是默认的 root,123456 来连接,连接成功后只能操作名为 TESTDB 的数据库;
5.4、全局表的测试
使用 navicat 打开命令列界面。输入如下命令创建数据表:
USE TESTDB;
create table company(id int not null primary key,name varchar(100),sharding_id int not null);
复制代码
之后使用如下命令查看创建表命令的执行状态:
explain create table company(id int not null primary key,name varchar(100),sharding_id int not null);
复制代码
因为 company 在 schema.xml 中北定义为了全局表,所以正常情况下可以看到如下类似结果:
+-----------+----------------------------------------------------------------------------------------------+
| DATA_NODE | SQL |
+-----------+----------------------------------------------------------------------------------------------+
| dn1 | create table company(id int not null primary key,name varchar(100),sharding_id int not null) |
| dn2 | create table company(id int not null primary key,name varchar(100),sharding_id int not null) |
| dn3 | create table company(id int not null primary key,name varchar(100),sharding_id int not null) |
+-----------+----------------------------------------------------------------------------------------------+
3 rows in set
复制代码
紧接着我们尝试执行如下命令执行一条插入数据的操作:
insert into company(id,name,sharding_id) values(1,'leader us',10000);
复制代码
然后类似执行 explain 命令查看 insert 命令的执行状态:
explain insert into company(id,name,sharding_id) values(1,'leader us',10000);
复制代码
正常情况下我们会看到如下结果:
+-----------+----------------------------------------------------------------------+
| DATA_NODE | SQL |
+-----------+----------------------------------------------------------------------+
| dn1 | insert into company(id,name,sharding_id) values(1,'leader us',10000) |
| dn2 | insert into company(id,name,sharding_id) values(1,'leader us',10000) |
| dn3 | insert into company(id,name,sharding_id) values(1,'leader us',10000) |
+-----------+----------------------------------------------------------------------+
3 rows in set
复制代码
之后我们直接登录到 mysql 服务器分别查看 db1、db2、db3 三个数据库,可以看到数据库中都创建了名为 company 的数据表,同时表中都插入了名为 leader us 的数据。
5.5、水平分表测试
如 5.4 中的操作。我们在 navicat 的命令列窗口中执行如下命令创建 travelrecord 表:
create table travelrecord(id int not null primary key,name varchar(100));
复制代码
之后使用 explain 查看:
explain create table travelrecord(id int not null primary key,name varchar(100));
复制代码
结果如下:
+-----------+--------------------------------------------------------------------------+
| DATA_NODE | SQL |
+-----------+--------------------------------------------------------------------------+
| dn1 | create table travelrecord(id int not null primary key,name varchar(100)) |
| dn2 | create table travelrecord(id int not null primary key,name varchar(100)) |
| dn3 | create table travelrecord(id int not null primary key,name varchar(100)) |
+-----------+--------------------------------------------------------------------------+
3 rows in set
复制代码
然后执行如下命令插入一条数据:
insert into travelrecord(id,name) values(1,'hp');
复制代码
执行 explain 查看执行结果:
explain insert into travelrecord(id,name) values(1,'hp');
复制代码
结果如下:
+-----------+--------------------------------------------------+
| DATA_NODE | SQL |
+-----------+--------------------------------------------------+
| dn1 | insert into travelrecord(id,name) values(1,'hp') |
+-----------+--------------------------------------------------+
1 row in set
复制代码
可以登录到数据库分别查看,三个数据库中都创建了 travelrecord 的数据表,但是仅 db1(dn1 对应的数据库)中插入了数据。
评论