MyCat系列--安装与基本使用（mycat下载）

MyCat系列--安装与基本使用

1. 简介

MyCat是流行的分布式数据库中间插件，是一个开源的分布式数据库系统，是一个实现了MySQL协议的服务器，前端用户可以把它看作是一个数据库代理，用MySQL客户端工具和命令行访问，而其后端可以用MySQL原生协议与多个MySQL服务器通信，也可以用JDBC协议与大多数主流数据库服务器通信，其核心功能是分表分库，即将一个大表水平分割为N个小表，存储在后端MySQL服务器里或者其他数据库里。

发展到目前，它的后端可以支持MySQL、SQL Server、Oracle、DB2、PostgreSQL等主流数据库，也支持MongoDB等NoSQL。

以下是其1.6版本的架构，图片来自其官方网站。

1. 安装

前提条件：JDK

运行startup_nowrap.bat

如出现以下类似的问题：

解决方法：

编辑startup_nowrap.bat

修改

"%JAVA_CMD%" -server -Xms1G -Xmx2G -XX:+AggressiveOpts -XX:MaxDirectMemorySize=1G -DMYCAT_HOME=%MYCAT_HOME% -cp "..\conf;..\lib\*" io.mycat.MycatStartup

为

"%JAVA_CMD%" -server -Xms1G -Xmx1G -XX:+AggressiveOpts -XX:MaxDirectMemorySize=1G -DMYCAT_HOME=%MYCAT_HOME% -cp "..\conf;..\lib\*" io.mycat.MycatStartup

再次运行startup_nowrap.bat：

注意：因为以上并未做任何配置，所以，服务是连接不上数据库的，具体错误信息，可以从日志mycat.log中看到。

1. 配置

接下来，以一个相对比较完整的配置示例来解释如何进行配置。

示例需求：针对同一台MySQL服务器上的一个表进行分库分表，且按照【省份】进行分类存储，存储规则如下：

MySQL中存储结构如下所示：

表定义如下：

CREATE TABLE `t_vote` (

`id` varchar(10) DEFAULT NULL,

`province` varchar(10) DEFAULT NULL

)

为了实现以上需求，需要依次做如下配置：

3.1 配置server.xml

<user name="root" defaultAccount="true">

<property name="password">123456</property>

<property name="schemas">TESTDB</property>

<property name="defaultSchema">TESTDB</property>

<!-- 表级 DML 权限设置 -->

<!--

<privileges check="false">

<schema name="TESTDB" dml="1111" >

</schema>

</privileges>

-->

</user>

<user name="user">

<property name="password">user</property>

<property name="schemas">TESTDB</property>

<property name="readOnly">true</property>

<property name="defaultSchema">TESTDB</property>

</user>

这里配置了两个可以来连接的用户

用户1 ：root 密码：123456

用户2 ：user 密码：user 给予了此用户TESTDB数据库的只读权限

注意：这里的testdb不一定是数据库上的真实库名，可以任意指定，只要和schema.xml的配置文件中的库名统一即可。

3.2 配置rule.xml

增加如下信息：

<tableRule name="sharding_by_intfile_test">

<rule>

<columns>province</columns>

<algorithm>sharding_int_test</algorithm>

</rule>

</tableRule>

<function name="sharding_int_test"

class="io.mycat.route.function.PartitionByFileMap">

<property name="mapFile">partition-hash-int-test.txt</property>

<property name="type">1</property>

<property name="defaultNode">0</property>

</function>

备注：

Rule名：sharding_by_intfile_test

列名：表t_vote的列province

分片函数名：sharding_int_test

分片配置文件名：
partition-hash-int-test.txt

3.3 配置
partition-hash-int-test.txt

在conf目录下，新建
partition-hash-int-test.txt，并输入以下文本：

hubei=0

tianjin=1

guangdong=2

代表：

hubei分发到第一个节点

tianjin分发到第二个节点

guangdong分发到第三个节点

3.4 配置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" randomDataNode="dn1">

<table name="t_vote" dataNode="dn1,dn2,dn3" rule="sharding_by_intfile_test">

</table>

</schema>

<dataNode name="dn1" dataHost="localhost" database="db_user_1" />

<dataNode name="dn2" dataHost="localhost" database="db_user_2" />

<dataNode name="dn3" dataHost="localhost" database="db_user_3" />

<dataHost name="localhost" maxCon="1000" minCon="10" balance="0"

writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">

<heartbeat>select user()</heartbeat>

<writeHost host="localhost" url="localhost:3306" user="root"

password="123456">

</writeHost>

</dataHost>

</mycat:schema>

dataNode：数据节点，配置了dn1,dn2,dn3，分别指向不同的服务器及其数据库，这里也就是数据分片的配置。本示例为了简单，配置到同一台服务器的不同数据库上。

1. 验证

在完成上述示例的所有配置后，运行startup_nowrap.bat，可查看日志文件mycat.log内容，可以看到如下信息：

MyCat服务正在监听8066端口。

接下来，我们使用server.xml中的用户连接mycat。

连接成功后，显示如下：

这里看到的TESTDB就是前面配置中的逻辑库名。

执行如下脚本，插入数据：

insert into t_vote(id,province) values ('tj','tianjin');

insert into t_vote(id,province) values ('hb','hubei');

insert into t_vote(id,province) values ('gd','guangdong');

insert into t_vote(id,province) values ('hn','hunan');

然后，我们查询数据：

数据虽然正确插入，但从以上我们还无法确定数据是否按照需求分片存储，所以，接下来，我们连接到MySQL服务器进行查询验证：

查询验证得知，已经按照需求进行了正确的存储。

注：在插入数据的时候，必须明确指定列，否则会报告错误：

1064 - partition table, insert must provide ColumnList

1. 注册服务

当然，也可以将MyCat注册为Windows服务：

方便执行服务的启动：

如果启动异常，可以查看日志文件wrapper.log的详细信息，查找原因。