iis服务器助手广告广告
返回顶部
首页 > 资讯 > 数据库 >MyCat分库分表--实战01--垂直分库
  • 839
分享到

MyCat分库分表--实战01--垂直分库

2024-04-02 19:04:59 839人浏览 八月长安
摘要

项目环境: 192.168.8.30  mycat 192.168.8.31  node1 192.168.8.32  node2 192.16

项目环境:

192.168.8.30  mycat

192.168.8.31  node1

192.168.8.32  node2

192.168.8.33  node3

三个节点Mysql均为单实例

一、创建测试数据

node1


create database testdb1;
create table testdb1.t01(name1 varchar(40),name2 varchar(40),name3 varchar(40));
insert into testdb1.t01 values(@@hostname,@@hostname,@@hostname);
create database testdb2;
create table testdb2.t02(name1 varchar(40),name2 varchar(40),name3 varchar(40));
insert into testdb2.t02 values(@@hostname,@@hostname,@@hostname);
create database testdb3;
create table testdb3.t03(name1 varchar(40),name2 varchar(40),name3 varchar(40));
insert into testdb3.t03 values(@@hostname,@@hostname,@@hostname);

node2


create database testdb4;
create table testdb4.t04(name1 varchar(40),name2 varchar(40),name3 varchar(40));
insert into testdb4.t04 values(@@hostname,@@hostname,@@hostname);
create database testdb5;
create table testdb5.t05(name1 varchar(40),name2 varchar(40),name3 varchar(40));
insert into testdb5.t05 values(@@hostname,@@hostname,@@hostname);
create database testdb6;
create table testdb6.t06(name1 varchar(40),name2 varchar(40),name3 varchar(40));
insert into testdb6.t06 values(@@hostname,@@hostname,@@hostname);

node3


create database testdb7;
create table testdb7.t07(name1 varchar(40),name2 varchar(40),name3 varchar(40));
insert into testdb7.t07 values(@@hostname,@@hostname,@@hostname);
create database testdb8;
create table testdb8.t08(name1 varchar(40),name2 varchar(40),name3 varchar(40));
insert into testdb8.t08 values(@@hostname,@@hostname,@@hostname);
create database testdb9;
create table testdb9.t09(name1 varchar(40),name2 varchar(40),name3 varchar(40));
insert into testdb9.t09 values(@@hostname,@@hostname,@@hostname);

二、配置schema.xml


<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="Http://io.mycat/">
        <schema name="mycatdb1" checksqlschema="true" sqlMaxLimit="100" dataNode="dn1"></schema>
        <schema name="mycatdb2" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn2"></schema>
        <schema name="mycatdb3" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn3"></schema>
        <schema name="mycatdb4" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn4"></schema>
        <schema name="mycatdb5" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn5"></schema>
        <schema name="mycatdb6" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn6"></schema>
        <schema name="mycatdb7" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn7"></schema>
        <schema name="mycatdb8" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn8"></schema>
        <schema name="mycatdb9" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn9"></schema>
	<!-- <dataNode name="dn1$0-743" dataHost="localhost1" database="db$0-743"
		/> -->
        <dataNode name="dn1" dataHost="node1" database="testdb1" />
        <dataNode name="dn2" dataHost="node1" database="testdb2" />
        <dataNode name="dn3" dataHost="node1" database="testdb3" />
        <dataNode name="dn4" dataHost="node2" database="testdb4" />
        <dataNode name="dn5" dataHost="node2" database="testdb5" />
        <dataNode name="dn6" dataHost="node2" database="testdb6" />
        <dataNode name="dn7" dataHost="node3" database="testdb7" />
        <dataNode name="dn8" dataHost="node3" database="testdb8" />
        <dataNode name="dn9" dataHost="node3" database="testdb9" />	
        <!--<dataNode name="dn4" dataHost="sequoiadb1" database="SAMPLE" />
	 <dataNode name="jdbc_dn1" dataHost="jdbchost" database="db1" />
	<dataNode	name="jdbc_dn2" dataHost="jdbchost" database="db2" />
	<dataNode name="jdbc_dn3" 	dataHost="jdbchost" database="db3" /> -->
	<dataHost name="node1" maxCon="1000" minCon="10" balance="1"
                          writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
                <heartbeat>select user()</heartbeat>
                <!-- can have multi write hosts -->
                <writeHost host="192.168.8.31" url="192.168.8.31:3306" user="root"  passWord="mysql"></writeHost>
        </dataHost>
        <dataHost name="node2" maxCon="1000" minCon="10" balance="1"
                          writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
                <heartbeat>select user()</heartbeat>
                <!-- can have multi write hosts -->
                <writeHost host="192.168.8.32" url="192.168.8.32:3306" user="root"  password="mysql"></writeHost>
        </dataHost>
        <dataHost name="node3" maxCon="1000" minCon="10" balance="1"
                          writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
                <heartbeat>select user()</heartbeat>
                <!-- can have multi write hosts -->
                <writeHost host="192.168.8.33" url="192.168.8.33:3306" user="root"  password="mysql"></writeHost>
        </dataHost>
</mycat:schema>

三、配置server.xml


<user name="root" defaultAccount="true">
		<property name="password">mysql</property>
		<property name="schemas">mycatdb1,mycatdb2,mycatdb3,mycatdb4,mycatdb5,mycatdb6,mycatdb7,mycatdb8,mycatdb9</property>
		
		<!-- 表级 DML 权限设置 -->
		<!-- 		
		<privileges check="false">
			<schema name="TESTDB" dml="0110" >
				<table name="tb01" dml="0000"></table>
				<table name="tb02" dml="1111"></table>
			</schema>
		</privileges>		
		 -->
	</user>

四、启动mycat


/usr/local/mycat/bin/mycat start

查看mycat日志


STATUS | wrapper  | 2018/11/21 17:07:24 | --> Wrapper Started as Daemon
STATUS | wrapper  | 2018/11/21 17:07:24 | Launching a JVM...
INFO   | jvm 1    | 2018/11/21 17:07:24 | Openjdk 64-Bit Server VM warning: ignoring option MaxPermSize=64M; support was removed in 8.0
INFO   | jvm 1    | 2018/11/21 17:07:26 | Wrapper (Version 3.2.3) http://wrapper.tanukisoftware.org
INFO   | jvm 1    | 2018/11/21 17:07:26 |   Copyright 1999-2006 Tanuki Software, Inc.  All Rights Reserved.
INFO   | jvm 1    | 2018/11/21 17:07:26 | 
INFO   | jvm 1    | 2018/11/21 17:07:30 | MyCAT Server startup successfully. see logs in logs/mycat.log

五、访问8066端口查看数据


[root@mycat conf]# mysql -uroot -pmysql -P8066 -h292.168.8.30 -e "select * from mycatdb1.t01"
mysql: [Warning] Using a password on the command line interface can be insecure.
+-------+-------+-------+
| name1 | name2 | name3 |
+-------+-------+-------+
| node1 | node1 | node1 |
+-------+-------+-------+
[root@mycat conf]# mysql -uroot -pmysql -P8066 -h292.168.8.30 -e "select * from mycatdb2.t02"
mysql: [Warning] Using a password on the command line interface can be insecure.
+-------+-------+-------+
| name1 | name2 | name3 |
+-------+-------+-------+
| node1 | node1 | node1 |
+-------+-------+-------+
[root@mycat conf]# mysql -uroot -pmysql -P8066 -h292.168.8.30 -e "select * from mycatdb3.t03"
mysql: [Warning] Using a password on the command line interface can be insecure.
+-------+-------+-------+
| name1 | name2 | name3 |
+-------+-------+-------+
| node1 | node1 | node1 |
+-------+-------+-------+
[root@mycat conf]# mysql -uroot -pmysql -P8066 -h292.168.8.30 -e "select * from mycatdb4.t04"
mysql: [Warning] Using a password on the command line interface can be insecure.
+-------+-------+-------+
| name1 | name2 | name3 |
+-------+-------+-------+
| node2 | node2 | node2 |
+-------+-------+-------+
[root@mycat conf]# mysql -uroot -pmysql -P8066 -h292.168.8.30 -e "select * from mycatdb5.t05"
mysql: [Warning] Using a password on the command line interface can be insecure.
+-------+-------+-------+
| name1 | name2 | name3 |
+-------+-------+-------+
| node2 | node2 | node2 |
+-------+-------+-------+
[root@mycat conf]# mysql -uroot -pmysql -P8066 -h292.168.8.30 -e "select * from mycatdb6.t06"
mysql: [Warning] Using a password on the command line interface can be insecure.
+-------+-------+-------+
| name1 | name2 | name3 |
+-------+-------+-------+
| node2 | node2 | node2 |
+-------+-------+-------+
[root@mycat conf]# mysql -uroot -pmysql -P8066 -h292.168.8.30 -e "select * from mycatdb7.t07"
mysql: [Warning] Using a password on the command line interface can be insecure.
+-------+-------+-------+
| name1 | name2 | name3 |
+-------+-------+-------+
| node3 | node3 | node3 |
+-------+-------+-------+
[root@mycat conf]# mysql -uroot -pmysql -P8066 -h292.168.8.30 -e "select * from mycatdb8.t08"
mysql: [Warning] Using a password on the command line interface can be insecure.
+-------+-------+-------+
| name1 | name2 | name3 |
+-------+-------+-------+
| node3 | node3 | node3 |
+-------+-------+-------+
[root@mycat conf]# mysql -uroot -pmysql -P8066 -h292.168.8.30 -e "select * from mycatdb9.t09"
mysql: [Warning] Using a password on the command line interface can be insecure.
+-------+-------+-------+
| name1 | name2 | name3 |
+-------+-------+-------+
| node3 | node3 | node3 |
+-------+-------+-------+

数据查看正常,9个库分布在三个机器。



您可能感兴趣的文档:

--结束END--

本文标题: MyCat分库分表--实战01--垂直分库

本文链接: https://www.lsjlt.com/news/48618.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑,方便收藏和打印~

下载Word文档
猜你喜欢
  • sql怎么查看表的索引
    通过查询系统表,可以获取表的索引信息,包括索引名称、是否唯一、索引类型、索引列和行数。常用系统表有:mysql 的 information_schema.statistics、postg...
    99+
    2024-05-14
    mysql oracle
  • sql怎么查看索引
    您可以使用 sql 通过以下方法查看索引:show indexes 语句:显示表中定义的索引列表及其信息。explain 语句:显示查询计划,其中包含用于执行查询的索引。informat...
    99+
    2024-05-14
  • sql怎么查看存储过程
    如何查看 sql 存储过程的源代码:使用 show create procedure 语句直接获取创建脚本。查询 information_schema.routines 表的 routi...
    99+
    2024-05-14
  • sql怎么查看视图表
    要查看视图表,可以使用以下步骤:使用 select 语句获取视图中的数据。使用 desc 语句查看视图的架构。使用 explain 语句分析视图的执行计划。使用 dbms 提供...
    99+
    2024-05-14
    oracle python
  • sql怎么查看创建的视图
    可以通过sql查询查看已创建的视图,具体步骤包括:连接到数据库并执行查询select * from information_schema.views;查询结果将显示视图的名称、...
    99+
    2024-05-14
    mysql
  • sql怎么用循环语句实现查询
    可以通过 do 和 while 语句创建循环,并在循环内执行查询,详细步骤包括:定义循环变量设置循环初始值循环执行查询更新循环变量执行查询循环退出条件 SQL 中使用循环语句实现查询 ...
    99+
    2024-05-14
  • sql怎么用代码修改表中数据
    通过 sql 代码修改表中数据的方法包括:修改单个记录:使用 update 语句设置列值并指定条件。修改多条记录:在 update 语句中指定多个条件来修改满足条件的所有记录。增加新列:...
    99+
    2024-05-14
  • sql怎么用命令创建数据库
    在 sql 中使用 create database 命令创建新数据库,其语法包含以下步骤:指定数据库名称。指定数据库文件和日志文件的位置(可选)。指定数据库大小、最大大小和文件增长(可选...
    99+
    2024-05-14
  • sql怎么用身份证提取年龄
    sql 中提取身份证号码中的年龄的方法:提取出生日期部分(身份证号码中第 7-14 位);使用 to_date 函数转换为日期格式;使用 extract 函数计算与当前日期之间的年差。 ...
    99+
    2024-05-14
  • sql怎么看字段长度
    有两种方法可查看 sql 中的字段长度:使用 information_schema 架构,其中包含元数据信息,可用于查询字段长度。使用内建函数,如 length(),其适用于字符串数据类...
    99+
    2024-05-14
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作