mysql mycat 路由规则_Mycat分库路由规则

Mycat分库路由规则

发布时间：2020-06-15 16:54:10

来源：51CTO

阅读：11651

作者：lzf05303774

一、Mycat分库路由分为连续路由和离散路由。

1、连续路由：

(1)、常用的路由方式：auto-sharding-long、sharding-by-date、sharding-by-month

(2)、优点：扩容无需迁移数据；范围条件查询消耗资源少。

(3)、缺点：存在数据热点的可能性；并发访问能力受限于单一或少量的DataNode

2、离线路由：

(1)、常用的路由方式：sharding-by-intfile、sharding-by-murmur、mod-long(取模)、crc32slot(取模)

(2)、优点：并发访问能力增强。

(3)、缺点：数据扩容比较困难，涉及到数据迁移问题；数据库链接消耗资源多。

二、auto-sharding-long：

1、路由规则：

userid

rang-long-userid

class="io.mycat.route.function.AutoPartitionByLong">

autopartition-long-userid.txt

[root@host01 conf]# more autopartition-long-userid.txt

# range start-end ,data node index

# K=1000,M=10000.

0-1000=0

1001-2000=1

2001-3000=2

3001-4000=3

4001-5000=4

5001-6000=5

2、例子：

CREATE TABLE tb_user_detail_t (

userid bigint not null primary key,

name varchar(64) DEFAULT NULL,

createtime datetime DEFAULT CURRENT_TIMESTAMP,

moditytime datetime DEFAULT CURRENT_TIMESTAMP

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

写入数据

insert into tb_user_detail_t(userid,name) values(999,'name999');

insert into tb_user_detail_t(userid,name) values(1999,'name999');

insert into tb_user_detail_t(userid,name) values(2999,'name999');

insert into tb_user_detail_t(userid,name) values(3999,'name999');

insert into tb_user_detail_t(userid,name) values(4999,'name999');

insert into tb_user_detail_t(userid,name) values(5999,'name999');

三、sharding-by-date：

1、路由规则：

createtime

partbydate

yyyy-MM-dd HH:mm:ss

2016-01-01 00:00:00

2

分片日期从2016-01-01开始,每2天一个分片。

2、例子：

CREATE TABLE `tb_user_partbydate` (

`id` varchar(32) NOT NULL,

`name` varchar(64) DEFAULT NULL,

`createtime` varchar(10)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

insert into tb_user_partbydate (id,name,createtime) values('a0001','name1','2016-01-01 00:01:00');

insert into tb_user_partbydate (id,name,createtime) values('a0002','name1','2016-01-02 00:01:00');

insert into tb_user_partbydate (id,name,createtime) values('a0003','name1','2016-01-03 00:01:00');

insert into tb_user_partbydate (id,name,createtime) values('a0004','name1','2016-01-04 00:01:00');

insert into tb_user_partbydate (id,name,createtime) values('a0005','name1','2016-01-05 00:01:00');

insert into tb_user_partbydate (id,name,createtime) values('a0006','name1','2016-01-06 00:01:00');

insert into tb_user_partbydate (id,name,createtime) values('a0007','name1','2016-01-07 00:01:00');

insert into tb_user_partbydate (id,name,createtime) values('a0005','name1','2016-01-08 00:01:00');

insert into tb_user_partbydate (id,name,createtime) values('a0006','name1','2016-01-09 00:01:00');

insert into tb_user_partbydate (id,name,createtime) values('a0007','name1','2016-01-10 00:01:00');

四、sharding-by-month：

1、路由规则：

createtime

partbymonth

class="io.mycat.route.function.PartitionByMonth">

yyyy-MM-dd HH:mm:ss

2015-01-01 00:00:00

dateFormat为日期格式,sBeginDate为开始日期。

2、例子：

CREATE TABLE ` tb_partbymonth ` (

`id` varchar(32) NOT NULL,

`name` varchar(64) DEFAULT NULL,

`createtime` datetime DEFAULT CURRENT_TIMESTAMP

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

写入数据(注意这里不能使用now函数)

insert into tb_partbymonth(id,name,createtime) values('a0001','name1','2015-01-01 10:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0002','name1','2015-02-02 10:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0003','name1','2015-03-01 00:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0004','name1','2015-04-01 00:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0005','name1','2015-05-01 10:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0006','name1','2015-06-02 10:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0007','name1','2015-07-01 00:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0008','name1','2015-08-01 00:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0009','name1','2015-09-01 10:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0010','name1','2015-10-02 10:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0011','name1','2015-11-01 00:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0012','name1','2015-12-01 00:00:00');

insert into tb_partbymonth(id,name,createtime) values('a0013','name1','2016-01-01 00:00:00');

五、sharding-by-intfile(枚举)：

1、路由规则：

provcode

hash-int-provcode

class="io.mycat.route.function.PartitionByFileMap">

partition-hash-int-provcode.txt

0

type=0代表×××

type=1代表字符串类型

[root@host01 conf]# more partition-hash-int-provcode.txt

1=0

2=1

3=2

4=3

5=4

6=5

7=0

8=1

9=2

10=3

11=4

12=5

DEFAULT_NODE=0 ##找不到省份匹配的情况下,默认放到数据库1

这里是6个库,序号0-5,将不同的省份映射到对应的库。所有的省份和库哦对应关系都要枚举出来。

2、例子：

CREATE TABLE `tb_user_t` (

id bigint auto_increment not null primary key,

`name` varchar(64) DEFAULT NULL,

provcode int ,

`createtime` datetime DEFAULT CURRENT_TIMESTAMP,

`moditytime` datetime DEFAULT CURRENT_TIMESTAMP

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

发现分库情况下定义自动增长的id不管用，因为每个库都有自己的自增长id,通过mycat查询的话会有重复的id.

如下:

mysql> select * from tb_user_t order by id;

+----+----------+----------+---------------------+---------------------+

| id | name     | provcode | createtime          | moditytime          |

+----+----------+----------+---------------------+---------------------+

|  1 | name0005 |        5 | 2017-08-09 10:54:44 | 2017-08-09 10:54:44 |

|  1 | name0001 |        1 | 2017-08-09 10:54:44 | 2017-08-09 10:54:44 |

|  1 | name0004 |        4 | 2017-08-09 10:54:44 | 2017-08-09 10:54:44 |

|  1 | name0002 |        2 | 2017-08-09 10:54:44 | 2017-08-09 10:54:44 |

|  1 | name0003 |        3 | 2017-08-09 10:54:44 | 2017-08-09 10:54:44 |

|  1 | name0006 |        6 | 2017-08-09 10:54:44 | 2017-08-09 10:54:44 |

|  2 | name0011 |       11 | 2017-08-09 10:54:53 | 2017-08-09 10:54:53 |

|  2 | name0007 |        7 | 2017-08-09 10:54:53 | 2017-08-09 10:54:53 |

|  2 | name0010 |       10 | 2017-08-09 10:54:53 | 2017-08-09 10:54:53 |

|  2 | name0008 |        8 | 2017-08-09 10:54:53 | 2017-08-09 10:54:53 |

|  2 | name0009 |        9 | 2017-08-09 10:54:53 | 2017-08-09 10:54:53 |

|  2 | name0012 |       12 | 2017-08-09 10:54:53 | 2017-08-09 10:54:53 |

|  3 | name0013 |       13 | 2017-08-09 11:12:17 | 2017-08-09 11:12:17 |

+----+----------+----------+---------------------+---------------------+

六、sharding-by-murmur：

murmur算法是将字段进行hash后分发到不同的数据库,字段类型支持int和varchar.

1、路由规则：

userid

murmur

class="io.mycat.route.function.PartitionByMurmurHash">

0

6

160

2、例子：

CREATE TABLE `tb_user_murmur_string_t` (

`userid` varchar(32) NOT NULL,

`name` varchar(64) DEFAULT NULL,

`createtime` datetime DEFAULT CURRENT_TIMESTAMP,

`moditytime` datetime DEFAULT CURRENT_TIMESTAMP,

PRIMARY KEY (`userid`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

写入数据

insert into tb_user_murmur_string_t(userid,name) values('user002','name002');

insert into tb_user_murmur_string_t(userid,name) values('user003','name003');

insert into tb_user_murmur_string_t(userid,name) values('user004','name004');

insert into tb_user_murmur_string_t(userid,name) values('user005','name005');

insert into tb_user_murmur_string_t(userid,name) values('user006','name006');

insert into tb_user_murmur_string_t(userid,name) values('user007','name007');

insert into tb_user_murmur_string_t(userid,name) values('user008','name008');

insert into tb_user_murmur_string_t(userid,name) values('user009','name009');

insert into tb_user_murmur_string_t(userid,name) values('user010','name010');

七、crc32slot：

crs32算法,分库字段类型支撑int和varchar.

1、路由规则：

id

crc32slot

6

count=6指定需要分库的个数.

2、例子：

CREATE TABLE `tb_user_crc32slot_t` (

`id` varchar(32) NOT NULL,

`name` varchar(64) DEFAULT NULL,

`createtime` datetime DEFAULT CURRENT_TIMESTAMP,

`moditytime` datetime DEFAULT CURRENT_TIMESTAMP

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

写入数据:

insert into tb_user_crc32slot_t(id,name) values('a0002','name1');

insert into tb_user_crc32slot_t(id,name) values('a0003','name1');

insert into tb_user_crc32slot_t(id,name) values('a0004','name1');

insert into tb_user_crc32slot_t(id,name) values('a0005','name1');

insert into tb_user_crc32slot_t(id,name) values('a0006','name1');

insert into tb_user_crc32slot_t(id,name) values('a0007','name1');

insert into tb_user_crc32slot_t(id,name) values('a0008','name1');

insert into tb_user_crc32slot_t(id,name) values('a0009','name1');

insert into tb_user_crc32slot_t(id,name) values('a0010','name1');

insert into tb_user_crc32slot_t(id,name) values('a0011','name1');

insert into tb_user_crc32slot_t(id,name) values('a0012','name1');

insert into tb_user_crc32slot_t(id,name) values('a0013','name1');

insert into tb_user_crc32slot_t(id,name) values('a0014','name1');

insert into tb_user_crc32slot_t(id,name) values('a0015','name1');

八、mod-long：

1、路由规则：对十进制数进行按照节点取模。

id

mod-long

3

九、mycat分库规则E/R规则 ：

1、路由规则：

E/R规则通过childTable设定之后，父子表相同的Id会落在相同的库，这样的避免关联的时候跨库进行关联.

joinKey="order_id" 是子表的order_id字段

parentKey="id"     是父表的id字段

即子表通过order_id字段跟父表的id字段进行关联

29e252769e4f6771825795ee5c39e180.png

2、例子

(2.1)、创建表语句:

create table orders

(

id int not null,

order_name varchar(64),

createtime datetime DEFAULT CURRENT_TIMESTAMP,

moditytime datetime DEFAULT CURRENT_TIMESTAMP,

PRIMARY KEY (id)

);

create table orders_cargo

(

order_id int not null,

cargo_name varchar(64),

createtime datetime DEFAULT CURRENT_TIMESTAMP,

moditytime datetime DEFAULT CURRENT_TIMESTAMP,

PRIMARY KEY (order_id)

);

(2.2)、客户Custermer和订单Order

每个客户和每个客户的订单最好在同一个库中。

bd1a75b50472f7a936c41563b452fbef.png

3、如果把父表最为全局表也能解决join的效率问题。

73df859060bd51e6262e45a5e0a2073a.png

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/356912.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

孙叫兽CSDN社区云----WebIT已创建，欢迎大家前端全栈小伙伴踊跃加入

孙叫兽CSDN社区云----WebIT已创建，欢迎大家前端全栈小伙伴踊跃加入

目录 社区云是什么？ 创建CSDN社区云WebIT的目的 推荐分享的技术点（如下图所示） 社区成员权益 版主权益 管理员权益 WebIT社区云积分规则 WebIT优质版主及管理员可以申请直播分享前端技术 WebIT社区云将为社区运营者提供： …
阅读更多...
迭代器设计模式示例

迭代器设计模式示例

本文是我们名为“ Java设计模式 ”的学院课程的一部分。 在本课程中，您将深入研究大量的设计模式，并了解如何在Java中实现和利用它们。 您将了解模式如此重要的原因，并了解何时以及如何应用模式中的每一个。 在这里查看 ！ 目录 …
阅读更多...
uibinder表单提交_使用UIBinder的GWT自定义按钮

uibinder表单提交_使用UIBinder的GWT自定义按钮

uibinder表单提交这是一个有关如何在GWT上使用UIBinder创建自定义按钮的示例。 public class GwtUIBinderButton implements EntryPoint {public void onModuleLoad() {Button button new Button();button.setText("Button");button.addClickHandler(new ClickHandl…
阅读更多...
python用import xlwt出现红字_如何用python处理excel

python用import xlwt出现红字_如何用python处理excel

最近看到有很多的python课程是教人怎么用python处理excel,我看了一下价格收费还贼高...这么初级毫无水平的操作我的粉丝们就不要花钱去报课程了..我免费教你们怎么做.首先我们先要安装两个模块,一个叫做xlrd,一个是xlwt.安装如下:打开cmd输入pip install xlrd等待安装成功,成功…
阅读更多...
什么是升职率？

什么是升职率？

我确实相信您熟悉彼得原则 。 一般而言，该原则是一种观察，即晋升可能并且将导致晋升人员不再符合该职位的条件。 对于JVM，存在类似的问题。 太快地提升对象可能会对性能产生重大影响。 在这篇文章中，我们将探讨提升率的概念&…
阅读更多...
mysql自增id用完了_MySQL表自增id用完了该怎么办？

mysql自增id用完了_MySQL表自增id用完了该怎么办？

我们知道MySQL表可以定义一个自增长的id，如果我们的表没有指定主键字段，那MySQL会给我们的表创建一个不可见的，长度为6个自己的row_id，然后不停地往上加步长，虽然生活中自然数是没有上限的，但是在计算机里&…
阅读更多...
jmeter插件监控cpu小节点

jmeter插件监控cpu小节点

JMeter使用plugins插件进行服务器性能监控 性能测试时，我们的关注点有两部分 1 服务本身：并发响应时间 QPS 2 服务器的资源使用情况：cpu memory I/O disk等 JMeter的plugins插件可以实现对"二"的监控，具体操作步骤如下(…
阅读更多...
mysql写入监控_zabbix监控mysql操作

mysql写入监控_zabbix监控mysql操作

说明：配置zabbix自带Mysql模板# 创建目录mkdir /var/lib/zabbix# 创建连接数据库文件touch /var/lib/zabbix/.my.cnf# 写入数据连接信息[client]host 192.168.0.148user rootpassword 123dffsdfs# 创建监控项文件touch /etc/zabbix/zabbix_agentd.conf.d/userpar…
阅读更多...
openshift_云上的播放框架变得简单：Openshift模块

openshift_云上的播放框架变得简单：Openshift模块

openshift仅仅几年前，找到一个负担得起的Java Web应用程序托管解决方案是一项艰巨的任务，而寻找免费的托管解决方案是一项不可能的任务。 更不用说考虑自动缩放，单命令部署，持续集成等问题了，这简直就是科幻小说。 去年…
阅读更多...
xclock 不出来界面_macOS 使用 XQuartz 支持 X11 实现 Linux 图形化界面显示

xclock 不出来界面_macOS 使用 XQuartz 支持 X11 实现 Linux 图形化界面显示

更多奇技淫巧欢迎订阅博客：https://fuckcloudnative.io前言在 Windows 中相信大家已经很熟悉使用 Xmanager(Xshell), MobaXterm, SecureCRT 通过 X11 实现 Linux 图形化界面显示，我的需求是在 macOS 下使用 iTerm2 作为 Terminal 实现 X11 图形化界面显示…
阅读更多...
命令设计模式示例

命令设计模式示例

本文是我们名为“ Java设计模式 ”的学院课程的一部分。 在本课程中，您将深入研究大量的设计模式，并了解如何在Java中实现和利用它们。 您将了解模式如此重要的原因，并了解何时以及如何应用模式中的每一个。 在这里查看 ！ 目录 …
阅读更多...
ArcGIS API for Silverlight 调用GP服务准备---GP模型建立、发布、测试

ArcGIS API for Silverlight 调用GP服务准备---GP模型建立、发布、测试

ArcGIS API for Silverlight 调用GP服务准备---GP模型建立、发布、测试 原文:ArcGIS API for Silverlight 调用GP服务准备---GP模型建立、发布、测试第一篇、GP降雨量等值线建模、发布及测试在水利、气象等行业中，要在WebGIS中实现空间分析功能，如绘制等…
阅读更多...
win10企业版更新和安全中没有 “恢复”这个选项_通知:微软已强制对Windows 10更新升级...

win10企业版更新和安全中没有 “恢复”这个选项_通知:微软已强制对Windows 10更新升级...

最近，微软发布了Windows10的强制升级。从本月开始，如果您的个人电脑、笔记本电脑和其他设备没有手动升级，微软将强制部分用户升级到Windows10 1909或2004版本。原因很简单。微软已经停止支持Windows10 1903版（包括家庭版和专业版&…
阅读更多...
docker 多个mysql_mysql8.0 利用docker容器安装配置多主多从集群

docker 多个mysql_mysql8.0 利用docker容器安装配置多主多从集群

1. 在/user/local/share/下创建mysql文件夹，在mysql文件夹目录下创建4个文件夹分别是:master1, master2, slave1, slave2分别在每个目录下建立data, conf, logs用于数据持久化创建后如下2.创建容器：1)创建一个名为master1的mysql容器(主 mysql)docker ru…
阅读更多...
JavaFX 2.0和Scala，例如牛奶和饼干

JavaFX 2.0和Scala，例如牛奶和饼干

JavaFX 2.0和Scala都是很好的技术，但是一起使用时效果会更好。 JavaFX 2.0是一种功能强大的富客户端技术，具有先进的图形，动画和媒体功能。 Scala是一种简单但功能强大的语言，具有用于编写特定于域的语言（DSL&#xff…
阅读更多...
thinkphp+mysql+join+where_thinkphp5.0 多join时where无法between

thinkphp+mysql+join+where_thinkphp5.0 多join时where无法between

情况类似于这个链接,这帖子的老哥没有答案,现在遇到一样的问题了,下面贴上代码$map [products.insurance_status>1];//是否计算下线的产品if( input(get.times) && input(get.times) < 7 ){$time return_times(input(get.times));//此处有bug$map[order.pay_ti…
阅读更多...
访客设计模式示例

访客设计模式示例

本文是我们名为“ Java设计模式 ”的学院课程的一部分。 在本课程中&#xff0c;您将深入研究大量的设计模式&#xff0c;并了解如何在Java中实现和利用它们。 您将了解模式如此重要的原因&#xff0c;并了解何时以及如何应用模式中的每一个。 在这里查看 &#xff01; 目录 …
阅读更多...
报名照片审核处理工具_太浦军考|2020年文职人员报名照片审核程序，照片处理工具应该如何使用？...

报名照片审核处理工具_太浦军考|2020年文职人员报名照片审核程序，照片处理工具应该如何使用？...

考文职 找太浦 最靠谱照片处理工具使用说明01注意&#xff1a;一、本工具是报名照片审核处理工具&#xff0c;只有通过该审核工具审核通过的照片才能在注册时正常上传。照片将应用在准考证和合格证书中。二、源文件必须是标准证件数字照片&#xff0c;JPG或JPEG格式&#xff0c…
阅读更多...
python 比赛成绩预测_Python预测NBA比赛结果

python 比赛成绩预测_Python预测NBA比赛结果

下载W3Cschool手机App&#xff0c;0基础随时随地学编程导语利用Python简单地预测一下NBA比赛结果。。。这大概就叫蹭热度吧。。。毕竟貌似今天朋友圈都在刷NBA相关的内容。。。虽然我并不能看懂。。。但这并不妨碍我瞎预测一波。。。So,以下内容纯属瞎玩&#xff0c;如有雷同&a…
阅读更多...
适配器设计模式示例

适配器设计模式示例

本文是我们名为“ Java设计模式 ”的学院课程的一部分。 在本课程中&#xff0c;您将深入研究大量的设计模式&#xff0c;并了解如何在Java中实现和利用它们。 您将了解模式如此重要的原因&#xff0c;并了解何时以及如何应用模式中的每一个。 在这里查看 &#xff01; 目录 …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023