vlambda博客
学习文章列表

Mycat 连接一组数据库

环境准备

  • mycat 统一连接一组垂直数据库 

  • 为了突出mycat配置,简化业务逻辑,每个节点只建立一张业务表和一张全局表

服务器信息

主机名 IP 角色 数据库
node1 192.168.114.129 Mycat school_db(逻辑库)
node2 192.168.114.133 Mysql teacher_db
node3 192.168.114.136 Mysql student_db
node4 192.168.114.137 Mysql cource_db

创建表

#node2
create database teacher_db default charset utf8;
use teacher_db;
CREATE TABLE `teacher` (
`id` varchar(32) NOT NULL,
`name` varchar(32) NOT NULL COMMENT '教师名称',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='教师表';

#node3
create database student_db default charset utf8;
use student_db;
CREATE TABLE `student` (
`id` varchar(32) NOT NULL,
`name` varchar(32) NOT NULL COMMENT '学生姓名',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='学生表';

#node4
create database cource_db default charset utf8;
use cource_db;
CREATE TABLE `source` (
`id` varchar(32) NOT NULL,
`name` varchar(32) NOT NULL COMMENT '课程名称',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='课程表';

#node 2 node3 node4
CREATE TABLE `dic_data` (
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '字典数据id',
`name` varchar(20) NOT NULL DEFAULT '' COMMENT '名称',
`code` varchar(50) NOT NULL COMMENT '编码',
`remarks` varchar(50) DEFAULT NULL COMMENT '备注',
`status` tinyint(2) DEFAULT '10' COMMENT '状态 10有效 20无效',
`ct` bigint(20) NOT NULL COMMENT '生成时间',
`ut` bigint(20) DEFAULT NULL COMMENT '修改时间',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 comment '字典表';

#node2 node3 node4 创建连接账号
create user 'mycat_connect'@'192.168.114.%' identified by '123456';
grant select,insert,update,delete on *.* to 'mycat_connect'@'192.168.114.%';

Mycat 配置

mycatl 各种详细配置请查看 

schema.xml 配置

	<schema name="school_db" checkSQLschema="false" sqlMaxLimit="100">
<table name="teacher" primaryKey="id" dataNode="teacher_db"/>
<table name="student" primaryKey="id" dataNode="student_db"/>

<table name="cource_db" primaryKey="id" dataNode="cource_db"/>
<table name="dic_data" primaryKey="id" dataNode="teacher_db,student_db,cource_db" type="global"/>

</schema>

<dataNode name="teacher_db" dataHost="mysql133" database="teacher_db" />
<dataNode name="student_db" dataHost="mysql136" database="student_db" />
<dataNode name="cource_db" dataHost="mysql137" database="cource_db" />

<dataHost name="mysql133" maxCon="1000" minCon="10" balance="3" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="192.168.114.133" url="192.168.114.133:3306" user="mycat_connect" password="123456" />
</dataHost>
<dataHost name="mysql136" maxCon="1000" minCon="10" balance="3" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="192.168.114.136" url="192.168.114.136:3306" user="mycat_connect" password="123456" />
</dataHost>
<dataHost name="mysql137" maxCon="1000" minCon="10" balance="3" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="192.168.114.137" url="192.168.114.137:3306" user="mycat_connect" password="123456" />
</dataHost>

server.xml 配置

    <system>
<property name="nonePasswordLogin">0</property> <!-- 0为需要密码登陆、1为不需要密码登陆 ,默认为0,设置为1则需要指定默认账户-->
<property name="useSqlStat">0</property> <!-- 1为开启实时统计、0为关闭 -->
<property name="useGlobleTableCheck">0</property> <!-- 1为开启全加班一致性检测、0为关闭 -->
<property name="sequnceHandlerType">2</property>
<property name="serverPort">8066</property>
<property name="managerPort">9066</property>
<property name="idleTimeout">300000</property>
<property name="bindIp">0.0.0.0</property>
<property name="frontWriteQueueSize">4096</property>
<property name="processors">4</property>
<property name="charset">utf8</property>
<property name="txIsolation">2</property>
<property name="sqlExecuteTimeout">300</property>
<property name="defaultMaxLimit">100</property>
<property name="maxPacketSize">104857600</property>
</system>


<user name="mycat_connect" defaultAccount="true">
<property name="password">123456</property>
<property name="schemas">school_db</property>
</user>

mycat 统一连接查看

必须连接到我们定义的mycat端口 8066 上 (server.xml 中定义的 serverPort)

mysql -umycat_connect -P8066 -h192.168.114.129 -p
mysql> show databases;
mysql> use school_db;
mysql> show tables;

全局表

  • 全局表在每个节点都有,并且数据结构和数据完全一致的表。这种表适合定义数量小,并且查询比较频繁的一类数据。

  • 全局表必须使用mycat进行管理,已保证各个节点数据的一致性

#配置全局表
<table name="dic_data" primaryKey="id" dataNode="teacher_db,student_db,cource_db" type="global"/>

垂直分库的优缺点

缺点
  • 有些表不能联查

  • 有些大表依然存在性能问题

优点
  • 逻辑简单,分库容易

  • 适合微服务,一个团队管理相似的一部分业务