数据库中间件DBLE学习(二) 学习配置schema.xml「建议收藏」

数据库中间件DBLE学习(二) 学习配置schema.xml「建议收藏」前言 一边有一个经常引诱我让我“娱乐至死”的视频,还有一个不停“鞭策“我让我快点学习的大BOSS。正是有这两种 才让我常常在自信中明白自己努力的方向。嗯,"人间不值得"! SCHE

数据库中间件DBLE学习(二) 学习配置schema.xml

前言

一边有一个经常引诱我让我“娱乐至死”的视频,还有一个不停“鞭策“我让我快点学习的大BOSS。正是有这两种极端的爱才让我常常在自信中明白自己努力的方向。嗯,”人间不值得”!

SCHEMA.XML介绍

上一篇写了:数据库中间件DBLE学习(一) 基本介绍和快速搭建,主要介绍快速安装。在安装的过程中,我们配置了schema.xml文件。schema.xml是一个比较重要的文件。该文件提供了逻辑库逻辑表分片规则数据分片物理数据库等配置。它主要有以下几个标签组成。

  • schema标签,主要是逻辑库逻辑表的配置,其中逻辑表又有多种类型,比如:全局表、分片表、ER分片表、非分片表等。
  • dataNode标签,主要定义了数据分片存放的节点,一个dataNode标签往往就对应着一个数据分片。
  • dataHost标签,主要定义了物理数据库及主从读写分离的配置。

实战SCHEMA.XML配置

接下来我们来实战一下,实战就拿经典PRODUCT表,ORDERS订单表来做实验。前面曾经介绍过逻辑表拆分可以有很多种类型。首先我们先规划一下,假设我们是一家新的电商公司,在电商平台上卖自家公司生产的商品,我们的商品总共就5-6种,但挡不住客户对我们生产的商品的喜爱,款款都是爆款啊,一经发售订单量就惊人。那么我们怎么来拆分库表呢?

  • PRODUCTS产品表,就卖几款爆品,我们要把它做成全局表。也就是每个分片上都有这个PRODUCTS产品表的数据。这样不会有多大的消耗,毕竟这个表数据量小。也比较方便和分片表进行关联。
  • ORDERS订单表,有上千万的订单。这个数据量比较大,我们要把ORDERS表做成分片表。PRODUCTS产品表和ORDERS表存在一对多的关系。我们可以按照order_id来进行取模分片。这样不会有数据过热的问题,并且产品表是小表在每个分片上都有,我们能非常方便的使用产品表和订单表进行关联。

说这么多,不如来张图给大家看一下。
数据库中间件DBLE学习(二) 学习配置schema.xml「建议收藏」

如图所示,应用直接连接数据库中间件,操作逻辑库testdb,逻辑表PRODUCTS和ORDERS。而上述逻辑库逻辑表对应存放在物理数据库主机A和主机B上。MySQL主机A上有分片dn1,MySQL主机B上有分片dn2。dn1上存储了全局表PRODUCTS和按order_id取模的ORDERS表1。dn2上存储了全局表PRODUCTS和按order_id取模的ORDERS表2。

整个脉络理清了,这是我们的配置环境。

服务器 IP地址 描述
DBLE服务器 192.168.56.185 DBLE实例,数据库中间件,负责接收SQL进行路由分发
MySQL A服务器 192.168.56.181 物理实例A,有db_1数据库
MySQL B1服务器主 192.168.56.182 物理实例B,有db_2数据库
MySQL B2服务器从 192.168.56.183 物理实例B的从库

物理MySQL环境配置

安装MySQL服务器A和MySQL服务器B的主从环境。然后在这两套物理数据库上都创建Buddy用户。

create user 'buddy'@'%' identified by '123456';
GRANT ALL PRIVILEGES ON *.* TO 'buddy'@'%' IDENTIFIED BY '123456';

代码100分

配置schema标签

进入dble的conf文件夹下配置schema.xml文件。首先咱们配置schema标签。主要配置内容如下:

代码100分 <schema name="testdb">
        <!--er tables-->
        <table name="orders" primaryKey="order_id" dataNode="dn1,dn2" rule="rule_mod"/>
        <!--global  tables-->
        <table name="products" primaryKey="product_id" type="global" dataNode="dn1,dn2"/>
    </schema>
  • sehama标签

    对逻辑库的定义,name指定了逻辑库的名字。

  • table标签

    对表的定义,name指定了表的名字,dataNode指定这张表涉及的数据节点,这里两张表都指定的是dn1,dn2。rule指定了分片的规则,这里是取模算法。如果是全局表需要在type属性列声明为global。

配置dataNode标签

<dataNode name="dn1" dataHost="dataHost1" database="db_1"/>
<dataNode name="dn2" dataHost="dataHost2" database="db_2"/>
  • dataNode标签

    name指定的是数据分片节点名称,dataHost指定对应的数据库实例,database对在mysql物理实例中的schema。

配置dataHost标签

代码100分<dataHost name="dataHost1" maxCon="1000" minCon="10" balance="0" switchType="-1" slaveThreshold="100">
    <heartbeat>show slave status</heartbeat>
    <!-- can have multi write hosts -->
    <writeHost host="hostM1" url="192.168.56.181:3306" user="buddy" password="buddy">
    </writeHost>
</dataHost>
<dataHost name="dataHost2" maxCon="1000" minCon="10" balance="0" switchType="-1" slaveThreshold="100">
    <heartbeat>show slave status</heartbeat>
    <!-- can have multi write hosts -->
    <writeHost host="hostM2" url="192.168.56.182:3306" user="buddy" password="buddy">
        <readHost host="hostS2" url="192.168.56.183:3306" user="buddy" password="buddy"/>
    </writeHost>
</dataHost>
  • dataHost标签

    指定了数据库实例,这里name代表数据库实例的名称。maxCon定于了最大连接数,minCon定义了空闲时保有的最小连接数。balance是指读取操作的负载均衡模式,为0则不做均衡。switchType代表了写操作的高可用切换类型。等于-1则表示不自动切换。slaveThreshold指定了指定主从延迟的阀值,为100。该配置主要与读数据时的负载均衡有关,它会先取show slave status中的Seconds_Behind_Master值,如果该值大于slaveThreshold,则读取的时候就会过滤掉这个slave。防止读到旧的数据,影响前台的业务。

  • heartbeat标签

    指定心跳检测,这里心跳检测的语句是show slave status

  • writeHost标签

    指定写入节点。host是写节点的名称。url指定写入节点的ip和端口号。user指定写节点数据库的用户名,password指定写节点数据库的密码。

  • readHost标签

    指定读取节点。host是读节点的名称。url指定读取节点的ip和端口号。user指定读节点数据库的用户名,password指定读节点数据库的密码。

启动dble

上述配置完成之后,我们就可以启动dble了。

[root@mycat bin]# ./dble start
Starting dble-server...
Removed stale pid file: /dble/dble.pid

启动后查看wrapper日志居然报错了。

INFO   | jvm 1    | 2019/12/27 00:34:15 | com.actiontech.dble.config.util.ConfigException: Illegal table conf : table [ orders ] rule function [ func_mod ] partition size : 4 > table datanode size : 2, please make sure table datanode size = function partition size

这里报错很明显,主要是这个取模函数默认设置对4取模,大于了我们的dataNode。需要我们在rule.xml中把func_mod函数的partitionCount给改成2.

<function name="func_mod" class="Hash">
    <property name="partitionCount">2</property>
    <property name="partitionLength">1</property>
</function>

重新启动dble,能够成功启动。

创建分片并验证

使用管理端口登录,进行创建datanode的操作。

[root@mysql5 ~]# mysql -uman1 -p -P9066 -h192.168.56.185 -p654321
mysql> create database @@dataNode='dn$1-2';
Query OK, 1 row affected (0.03 sec)

分别登录MySQL服务器A和MySQL服务器B查看创建分片的情况。可以看到181上创建了db_1,而182上创建了db_2。

[root@mysql5 ~]# mysql -ubuddy -p  -h192.168.56.181 -P3306 -p123456 -e "show databases"
+--------------------+
| Database           |
+--------------------+
| information_schema |
| db_1               |
| mysql              |
| performance_schema |
| sys                |
+--------------------+

[root@mysql5 ~]# mysql -ubuddy -p  -h192.168.56.182 -P3306 -p123456 -e "show databases"
+--------------------+
| Database           |
+--------------------+
| information_schema |
| db_2               |
| mysql              |
| performance_schema |
| sys                |
+--------------------+

创建表并插入数据

使用服务端口登录,进行创建表和插入数据的操作。此时我们操作的就是逻辑库和逻辑表。

[root@mysql5 ~]# mysql -uroot -h192.168.56.185 -P8066 -p123456
mysql> show databases;
+----------+
| DATABASE |
+----------+
| testdb   |
+----------+
1 row in set (0.00 sec)

mysql> use testdb;
Database changed
mysql> show tables;
Empty set (0.00 sec)

mysql> create table if not exists products (
    ->   product_id int not null,
    ->   product_name varchar(250),
    ->   expire_time date,
    ->   primary key(product_id)
    -> )engine=innodb charset=utf8;
Query OK, 0 rows affected, 1 warning (0.08 sec)

mysql> create table if not exists orders (
    ->   order_id int not null,
    ->   product_id int not null,
    ->   effective_time date,
    ->   cust_name varchar(20),
    ->   cust_address varchar(200),
    ->   primary key(order_id)
    -> )engine=innodb charset=utf8;
Query OK, 0 rows affected (0.04 sec)

insert into products values(1,'Package A','2015-12-31')
insert into products values(2,'Package B','2022-07-31');
insert into products values(3,'Package C','2025-12-31');
insert into products values(4,'Package D','2028-05-31');

insert into orders values(1,1,'2019-12-25','caocao','gz');
insert into orders values(1,1,'2019-12-25','caocao','gz');
insert into orders values(2,1,'2019-12-25','liubei','sz');
insert into orders values(3,2,'2019-12-25','sunquan','sh');
insert into orders values(4,2,'2019-12-25','zhugeliang','nj');
insert into orders values(5,3,'2019-12-25','simayi','hz');
insert into orders values(6,4,'2019-12-25','caopi','wh');
insert into orders values(7,1,'2019-12-25','guanyu','cd');
insert into orders values(8,1,'2019-12-25','zhengfei','bj');
insert into orders values(9,3,'2019-12-25','zhaoyun','cd');
insert into orders values(10,1,'2019-12-25','weiyan','cq');
insert into orders values(11,4,'2019-12-25','machao','cs');
insert into orders values(12,1,'2019-12-25','lvbu','cd');
insert into orders values(13,1,'2019-12-25','diaochan','sh');
insert into orders values(14,2,'2019-12-25','huangzhong','hz');

mysql> insert into orders values(1,1,'2019-12-25','caocao','gz');
ERROR 1064 (HY000): bad insert sql, sharding column/joinKey:ID not provided,INSERT INTO orders

在插入orders表的时候再次报错,报错很明显,说分片键id没提供。这是因为我们在rule.xml中columns字段不是指定的分片字段order_id。在rule.xml配置一下columns字段为order_id就可以了。

<tableRule name="rule_mod">
    <rule>
        <columns>order_id</columns>
        <algorithm>func_mod</algorithm>
    </rule>
</tableRule>

验证分片数据否正确

验证db_1分片上的数据。

[root@mysql5 ~]# mysql -ubuddy  -h192.168.56.181 -P3306 -p123456 -D db_1 -e "select * from products" 
+------------+--------------+-------------+
| product_id | product_name | expire_time |
+------------+--------------+-------------+
|          1 | Package A    | 2015-12-31  |
|          1 | Package B    | 2022-07-31  |
|          1 | Package C    | 2025-12-31  |
|          1 | Package D    | 2028-05-31  |
+------------+--------------+-------------+

[root@mysql5 ~]# mysql -ubuddy  -h192.168.56.181 -P3306 -p123456 -D db_1 -e "select * from orders"  
+----------+------------+----------------+------------+--------------+
| order_id | product_id | effective_time | cust_name  | cust_address |
+----------+------------+----------------+------------+--------------+
|        2 |          1 | 2019-12-25     | liubei     | sz           |
|        4 |          2 | 2019-12-25     | zhugeliang | nj           |
|        6 |          4 | 2019-12-25     | caopi      | wh           |
|        8 |          1 | 2019-12-25     | zhengfei   | bj           |
|       10 |          1 | 2019-12-25     | weiyan     | cq           |
|       12 |          1 | 2019-12-25     | lvbu       | cd           |
|       14 |          2 | 2019-12-25     | huangzhong | hz           |
+----------+------------+----------------+------------+--------------+

验证db_2分片上的数据。

[root@mysql5 ~]# mysql -ubuddy  -h192.168.56.182 -P3306 -p123456 -D db_2 -e "select * from products"  
mysql: [Warning] Using a password on the command line interface can be insecure.
+------------+--------------+-------------+
| product_id | product_name | expire_time |
+------------+--------------+-------------+
|          1 | Package A    | 2015-12-31  |
|          1 | Package B    | 2022-07-31  |
|          1 | Package C    | 2025-12-31  |
|          1 | Package D    | 2028-05-31  |
+------------+--------------+-------------+

[root@mysql5 ~]# mysql -ubuddy  -h192.168.56.182 -P3306 -p123456 -D db_2 -e "select * from orders" 
+----------+------------+----------------+-----------+--------------+
| order_id | product_id | effective_time | cust_name | cust_address |
+----------+------------+----------------+-----------+--------------+
|        1 |          1 | 2019-12-25     | caocao    | gz           |
|        3 |          2 | 2019-12-25     | sunquan   | sh           |
|        5 |          3 | 2019-12-25     | simayi    | hz           |
|        7 |          1 | 2019-12-25     | guanyu    | cd           |
|        9 |          3 | 2019-12-25     | zhaoyun   | cd           |
|       11 |          4 | 2019-12-25     | machao    | cs           |
|       13 |          1 | 2019-12-25     | diaochan  | sh           |
+----------+------------+----------------+-----------+--------------+

总结

这篇我们学习了基本的schema.xml的配置方法,目前还是比较皮毛的。下一篇我们来介绍分片的一些算法。

参考文档

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
转载请注明出处: https://daima100.com/10359.html

(0)
上一篇 2022-12-29
下一篇 2022-12-29

相关推荐

  • sql语句注入风险是什么_数据库防止sql注入

    sql语句注入风险是什么_数据库防止sql注入啥是 SQL 注入风险? 数据库要执行 SQL 访问数据,数据库是个执行机构,它只会检查传来的 SQL 是不是合乎语法,而并不会关心这个语句是否会造成伤害(数据泄露或破坏)。正因为只要符合语法规则就…

    2023-03-17
    145
  • 用pip安装OpenCV

    用pip安装OpenCVOpenCV是一个基于BSD协议开源发行的跨平台计算机视觉库,它是专门用于图像处理和计算机视觉方面的开源库。随着计算机视觉的热度不断升温,OpenCV也变得越来越重要。本文将详细介绍如何使用pip来安装OpenCV。

    2024-08-20
    30
  • MySQL总结(三)DDL数据定义语言-详解

    MySQL总结(三)DDL数据定义语言-详解1.DDL操作数据库 1.1 创建数据库 1.1.1 多种方式创建数据库 语句 说明 CREATE DATABASE 数据库名称; 创建数据库 CREATE DATABASE IF NOT EXIS…

    2023-03-01
    132
  • Python字典数据类型:快速查找和映射实现

    Python字典数据类型:快速查找和映射实现a href=”https://www.python100.com/a/sm.html”font color=”red”免责声明/font/a a href=”https://beian.miit.gov.cn/”苏ICP备2023018380号-1/a Copyright www.python100.com .Some Rights Reserved.

    2024-01-17
    119
  • 面向过程式的数据库连接「终于解决」

    面向过程式的数据库连接「终于解决」1、mysql系列函数 –连接mysql的老函数,性能不佳,已经被mysqli替代 2、mysqli系列函数 –mysql系列的增强版,如果直接连接mysql数据库,性能最好 3、pdo抽象层 …

    2023-02-10
    140
  • 兔子ip是免费的吗_兔子静态ip手机

    兔子ip是免费的吗_兔子静态ip手机兔子IP adsl动态IP拨号, 单地区全国混拨IP,兔子IP作用 1.改变IP地址   网络推广 网络营销 观看国内在线视频 下载试听音乐MP3 访问国内网站和国内游戏等等,这些场景都可以用到IP…

    2023-02-26
    162
  • 使用Python编程写入CSV文件

    使用Python编程写入CSV文件CSV(Comma Separated Values)文件是一种以文本形式存储表格数据的文件格式,数据之间使用逗号分隔。在日常工作中,我们常常需要将表格数据以CSV格式进行保存和导出,因此,学习如何使用Python编程将数据写入CSV文件是一项必备技能。

    2024-08-24
    26
  • Python安装路径

    Python安装路径 Python是广泛应用于各行各业的高级编程语言,因为被设计成容易阅读、易于维护、具有可扩展性和易于学习等优点而受到了广泛的青睐。Python安装路径是指Python安装在电脑上的具体路径。在进行Python编程时,需要了解Python安装路径,才能对Python进行调用和使用。

    2024-07-03
    42

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注