Mycat 连接一组数据库

环境准备

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

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

  
  mysql.png

服务器信息

主机名	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"/>

垂直分库的优缺点

缺点

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

优点

• 逻辑简单，分库容易
• 适合微服务，一个团队管理相似的一部分业务