DBLE 三分片的数据拆分场景
1、准备后端 MySQL 节点
DBLE 的架构其实很好理解，DBLE 是代理中间件，DBLE 后面是物理数据库。对于应用来说，访问的都是 DBLE，不会接触到后端的数据库。
部署架构表如下图：
2、修改 sharding.xml 配置文件
<?xml version="1.0"?><!DOCTYPE dble:sharding SYSTEM "sharding.dtd"><dble:sharding xmlns:dble="http://dble.cloud/" version="4.0"><schema name="testdb" sqlMaxLimit="-1"><shardingTable name="account" shardingNode="dn_01,dn_02,dn_03" sqlMaxLimit="-1" shardingColumn="id" function="sharding-by-hash"></shardingTable></schema><shardingNode name="dn_01" dbGroup="dh-mysql-dble" database="dh_dn_01"></shardingNode><shardingNode name="dn_03" dbGroup="dh-mysql-dble" database="dh_dn_03"></shardingNode><shardingNode name="dn_02" dbGroup="dh-mysql-dble" database="dh_dn_02"></shardingNode><function name="sharding-by-hash" class="Hash"><property name="partitionCount">3</property><property name="partitionLength">100</property></function><function name="default_mod_two" class="Hash"><property name="partitionCount">2</property><property name="partitionLength">1</property></function></dble:sharding>
参数说明
schema逻辑数据库信息，此数据库为逻辑数据库schema name逻辑库名，程序连接的库名；name 与 user.xml 中 schemas 对应；shardingTable name表名，物理数据库中表名程序连接的表名；shardingNode表存储到哪些节点，多个节点用逗号分隔；shardingColumn分片字段；function分片规则，引⽤ function 节中的拆分规则名称那个；shardingNode分片节点shardingNode name分片节点名称dbGroupshardingNode 对应的数据库组，参考 db.xml 中的 dbGroup 名称,可以配置单个或多个使⽤,例如"dh,dh$0-5"databaseshardingNode 对应的存在于 mysql 物理实例中的 schema, 可以配置单个或多个使⽤，例如"db,db$0-5"function拆分算法定义name定义分区算法名，在分区规则定义中被引⽤class拆分算法，指定分区算法实现类⽬前，已⽀持的分区算法有: hash, stringhash, enum, numberrange, patternrange, date，jumpstringhashpropertyname部分⽤于指定相应分区算法的参数，partitionCount指定分区的区间数，partitionLength指定各区间⻓度3、修改 db.xml 配置文件
<?xml version="1.0"?><!DOCTYPE dble:db SYSTEM "db.dtd"><dble:db xmlns:dble="http://dble.cloud/" version="4.0"><dbGroup name="dh-mysql-dble" rwSplitMode="0" delayThreshold="-1"><heartbeat timeout="0" errorRetryCount="0">show slave status</heartbeat><dbInstance name="10.186.65.71-1111-dh-1" url="10.186.65.71:1111" user="dble" password="dble" maxCon="100" minCon="10" primary="true" readWeight="0"></dbInstance><dbInstance name="10.186.65.72-1111-dh-2" url="10.186.65.72:1111" user="dble" password="dble" maxCon="100" minCon="10" primary="false" readWeight="0"></dbInstance></dbGroup></dble:db>
参数说明
包含具体的数据库组和实例配置,可以配置多组，每组可以配置多个实例
dbGroup数据库组name数据库组名rwSplitMode在进⾏读负载均衡的时候会根据这个配置 进⾏0：不做均衡，直接分发到主实例，从实 例将被忽略,不会尝试建⽴连接池，但会有 ⼼跳连接 1：读操作在所有从实例中均衡，当所有 从实例都不可⽤时，下发语句会报错。 2：读操作在所有实例中均衡。 3：读操作在所有从实例中均衡，当所有 从实例都不可⽤时，将语句发往主实例。delayThreshold指定主从延迟阀值，默认-1，表⽰不会进⾏延迟检测heartbeat该配置会⽤于进⾏ mysql 实例状态的判断timeout⼼跳超时阈值，默认0秒errorRetryCount⼼跳失败后的尝试次数dbInstance后端 mysql 实例连接信息 name 写节点名称，url 写节点地址ip:port，user 写节点⽤⼾，password 写节点⽤⼾密码，minCon 空闲时保有最⼩连接数，maxCon 最⼤连接数，primary 主实例需要配置成true，readWeight 节点权重(负载均衡时候使⽤)，disabled 标记该实例不可⽤
4、修改 user.xml 配置文件
<dble:user xmlns:dble="http://dble.cloud/" version="4.0"><managerUser name="man1" password="654321" maxCon="100"/><shardingUser name="app" password="app" schemas="testdb" readOnly="false" maxCon="0"/></dble:user>
参数说明
managerUser(管理⽤⼾)shardingUser(分库⽤⼾)rwSplitUser(读写⽤⼾)5、建库
在DBLE管理端口上，创建后端物理库
[root@study01 logs]# mysql -uman1 -p -h127.0.0.1 -P9066Enter password: MySQL [(none)]> create database @@shardingnode='dn_0$1-3';Query OK, 1 row affected (0.03 sec)
5、建表
在DBLE服务端口上，创建表；
mysql -uroot -p -h127.0.0.1 -P8066use testdb;create table account(id int, addr varchar(20));
6、导入数据
[root@study01 tmp]# cat acc.txt 5,shanghai155,beijing255,shenzhen355,guanzhou455,tianjin555,kunming655,wuhanmysql> load data local infile '/tmp/acc.txt' into table account fields terminated by ',';
7、登录后端服务器查看结果
mysql> select * from dh_dn_01.account;+------+----------+| id | name|+------+----------+| 5 | shanghai || 355 | guanzhou || 655 | wuhan |+------+----------+mysql> select * from dh_dn_02.account;+------+---------+| id | name |+------+---------+| 155 | beijing || 455 | tianjin |+------+---------+mysql> select * from dh_dn_03.account;+------+----------+| id | name|+------+----------+| 255 | shenzhen || 555 | kunming |+------+----------+
