MyCat 学习笔记 第十一篇.数据分片 之 分片数据查询 ( select * from table_name limit 100000,100 )

1 环境说明

VM 模拟3台MYSQL 5.6 服务器

　　 VM1 192.168.31.187：3307

　　 VM2 192.168.31.212：3307

　　 VM3 192.168.31.150:  3307

MYCAT 1.5 服务部署在宿主机上

　　MYCAT 192.168.31.207 :8806【SQL执行端口】 / 9066【管理端口】

2 应用场景

2.0 MYCAT配置

schema.xml

<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
　　<table name="t_demo_travel_record" dataNode="dn1,dn2,dn3" rule="auto-sharding-long" />
　　<table name="t_demo_travel_record_child" dataNode="dn1,dn2,dn3" rule="auto-sharding-long" />
</schema>

<dataNode name="dn1" dataHost="vm1" database="test" />
<dataNode name="dn2" dataHost="vm2" database="test" />
<dataNode name="dn3" dataHost="vm3" database="test" />

<dataHost name="vm1" maxCon="1000" minCon="10" balance="0"
　　writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
　　<heartbeat>select user()</heartbeat>
　　<writeHost host="vm1M1" url="192.168.31.187:3307" user="root" password="root123"></writeHost>
</dataHost>

<dataHost name="vm2" maxCon="1000" minCon="10" balance="0"
　　writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
　　<heartbeat>select user()</heartbeat>
　　<writeHost host="vm2M1" url="192.168.31.212:3307" user="root" password="root123"></writeHost>

</dataHost>

<dataHost name="vm3" maxCon="1000" minCon="10" balance="0"
　　writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
　　<heartbeat>select user()</heartbeat>
　　<writeHost host="vm3M1" url="192.168.31.150:3307" user="root" password="root123"></writeHost>

</dataHost>

rule.xml

<tableRule name="auto-sharding-long">
　　<rule>
　　　　<columns>id</columns>
　　　　<algorithm>rang-long</algorithm>
　　</rule>
</tableRule>

<function name="rang-long"
　　class="org.opencloudb.route.function.AutoPartitionByLong">
　　<property name="mapFile">autopartition-long.txt</property>
　　<property name="defaultNode">0</property>
</function>

autopartition-long.txt

# range start-end ,data node index
# K=1000,M=10000.
0-500M=0
500M-1000M=1
1000M-1500M=2

2.1 模拟在3个数据库上保存了200多万条记录，验证下数据库查询的响应。

物理库上数据情况

VM1 192.168.31.187：3307  保存了74.8万条记录

mysql> SELECT min(id),max(id),count(1) FROM test.t_demo_travel_record;

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

| min(id) | max(id) | count(1) |

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

|   10000 | 5000000 |   748002 |

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

1 row in set (0.16 sec)

VM2 192.168.31.212：3307  保存了74.9万条记录

mysql> SELECT min(id),max(id),count(1) FROM test.t_demo_travel_record;

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

| min(id) | max(id)  | count(1) |

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

| 5000001 | 10000000 |   749500 |

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

1 row in set (0.17 sec)

VM3 192.168.31.150:  3307 比VM2少一条记录

mysql> SELECT min(id),max(id),count(1) FROM test.t_demo_travel_record;

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

| min(id)  | max(id)  | count(1) |

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

| 10000001 | 14991498 |   749499 |

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

1 row in set (0.17 sec)

MYCAT 192.168.31.207:  8806  一共224.7万条记录，最大记录从 VM1 结点获取，最大记录从 VM3 结点获取

mysql> SELECT min(id),max(id),count(1) FROM t_demo_travel_record;

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

| MIN0  | MAX1     | COUNT2  |

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

| 10000 | 14991498 | 2247001 |

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

1 row in set (0.31 sec)

在MYCAT中进行不指定排序的分页查询 ，从第100万条记录开始取100，浩时1.5秒，好久~~

mysql> select * from t_demo_travel_record where id between 4999980 and 14999980 limit 1000000,100;

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

| id       | context          |

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

| 13341025 | context_13341025 |

| 13341026 | context_13341026 |

| 13341027 | context_13341027 |

| 13341028 | context_13341028 |

| 13341029 | context_13341029 |

....

|  8320686 | context_8320686  |

|  8320687 | context_8320687  |

|  8320688 | context_8320688  |

|  8320689 | context_8320689  |

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

100 rows in set (1.50 sec)

看下日志，MYCAT是把 limit 1000000,100 改为 limit 0 , 1000100 往物理库中发送，速度一个字：不慢才怪。

02/02 23:41:47.958  DEBUG [$_NIOREACTOR-2-RW] (ServerQueryHandler.java:56) -ServerConnection [id=12, schema=TESTDB, host=192.168.31.207, user=test,txIsolation=3, autocommit=true, schema=TESTDB]select * from t_demo_travel_record where id between 4999980 and 14999980 limit 1000000,100

02/02 23:41:47.958  DEBUG [$_NIOREACTOR-2-RW] (EnchachePool.java:70) -SQLRouteCache hit cache ,key:TESTDBselect * from t_demo_travel_record where id between 4999980 and 14999980 limit 1000000,100

02/02 23:41:47.958  DEBUG [$_NIOREACTOR-2-RW] (NonBlockingSession.java:113) -ServerConnection [id=12, schema=TESTDB, host=192.168.31.207, user=test,txIsolation=3, autocommit=true, schema=TESTDB]select * from t_demo_travel_record where id between 4999980 and 14999980 limit 1000000,100, route={

1 -> dn1{SELECT *

FROM t_demo_travel_record

WHERE id BETWEEN 4999980 AND 14999980

LIMIT 0, 1000100}

2 -> dn2{SELECT *

FROM t_demo_travel_record

WHERE id BETWEEN 4999980 AND 14999980

LIMIT 0, 1000100}

3 -> dn3{SELECT *

FROM t_demo_travel_record

WHERE id BETWEEN 4999980 AND 14999980

LIMIT 0, 1000100}

} rrs

02/02 23:41:47.958  DEBUG [$_NIOREACTOR-2-RW] (MultiNodeQueryHandler.java:82) -execute mutinode query select * from t_demo_travel_record where id between 4999980 and 14999980 limit 1000000,100

02/02 23:41:47.958  DEBUG [$_NIOREACTOR-2-RW] (MultiNodeQueryHandler.java:97) -has data merge logic

02/02 23:41:47.961  DEBUG [$_NIOREACTOR-3-RW] (MultiNodeQueryHandler.java:241) -on row end reseponse MySQLConnection [id=19, lastTime=1454427707947, user=root, schema=test, old shema=test, borrowed=true, fromSlaveDB=false, threadId=36, charset=utf8, txIsolation=3, autocommit=true, attachment=dn1{SELECT *

FROM t_demo_travel_record

WHERE id BETWEEN 4999980 AND 14999980

LIMIT 0, 1000100}, res[email protected]24e67429, host=192.168.31.187, port=3307, statusSync=null, writeQueue=0, modifiedSQLExecuted=false]

这里进行数据合并，好在使用了auto-sharding-long模式，如果是sharding-by-mod模式的话，数据是非连续离散在不同数据结点中，那合并起来就更慢了。

在大数据量分片分页查询时，MYCAT 可能会存在效率与内存占用问题。

02/02 23:41:49.392  DEBUG [BusinessExecutor6] (DataMergeService.java:296) -prepare mpp merge result for select * from t_demo_travel_record where id between 4999980 and 14999980 limit 1000000,100

02/02 23:41:49.393  DEBUG [BusinessExecutor6] (MultiNodeQueryHandler.java:324) -last packet id:105

时间： 2024-10-12 15:06:53

MyCat 学习笔记 第十一篇.数据分片 之 分片数据查询 ( select * from table_name limit 100000,100 )的相关文章

MyCat 学习笔记 第十一篇.数据分片 之 分片事务处理

1 环境说明 VM 模拟3台MYSQL 5.6 服务器 VM1 192.168.31.187:3307 VM2 192.168.31.212:3307 VM3 192.168.31.150:  3307 MYCAT 1.5 服务部署在宿主机上 MYCAT 192.168.31.207 :8806[SQL执行端口] / 9066[管理端口] 2 应用场景 2.0 MYCAT配置 schema.xml <schema name="TESTDB" checkSQLschema=&quo

《Mycat学习笔记》 第二篇. MySql 读写分离与日志分析——主从多结点

1    环境说明 接上篇环境   <Mycat学习笔记> 第一篇. MySql 读写分离与日志分析——主从单结点 http://www.cnblogs.com/kaye0110/p/5134588.html 增加一套 mysql 实例,端口为3308 ,通过Binlog方式同步主机情况 localhost : 3306 主机,    在mycat 中配置为 writehost 1 localhost : 3307 从机 a ,在mycat 中配置为 readhost localhost :

MyCat 学习笔记 第十篇.数据分片 之 ER分片

1 应用场景 这篇来说下mycat中自带的er关系分片,所谓er关系分片即可以理解为有关联关系表之间数据分片.类似于订单主表与订单详情表间的分片存储规则. 本文所说的er分片分为两种: a. 依据主键进行数据分片,验证发现主表数据保存在第1个datanode中,子表数据根据分片规则存储. b. 依据分片关键字段进行分片,验证发现主表与子表根据分片规则存储,且保存在相同的分片内. 接下来,可以下实际配置与数据验证 2 环境说明 参考  <MyCat 学习笔记>第六篇.数据分片 之 按月数据分片 

MyCat 学习笔记 第十三篇.数据分片 之 通过HINT执行存储过程

1 环境说明 VM 模拟3台MYSQL 5.6 服务器 VM1 192.168.31.187:3307 VM2 192.168.31.212:3307 VM3 192.168.31.150:  3307 MYCAT 1.5 服务部署在宿主机上 MYCAT 192.168.31.207 :8806[SQL执行端口] / 9066[管理端口] 2 应用场景 2.0 MYCAT配置 schema.xml <schema name="TESTDB" checkSQLschema=&quo

《Mycat学习笔记》 第三篇. MySql 主从同步异常后，主从切换

1)系统环境说明 MySql 5.5 主从节点 127.0.0.1:3306   主结点,为验证主从切换效果,手动停止服务 127.0.0.1: 3307    从结点 1 127.0.0.1:338     从结点 2 ,为验证主从切换效果,在主结点停止后,新增两个记录. MyCat 1.5 schema.xml 配置 具体配置说明,参考上篇: <Mycat学习笔记> 第二篇. MySql 读写分离与日志分析——主从多结点 <dataHost name="localhost1

《MyCat 学习笔记》第八篇.数据分片 之 求摸运算分片

1 应用场景 Mycat 自带了多套数据分片的机制,其实根据数值取摸应该是最简单的一种. 优点:数据离散概率较为平均,可以有效的提高应用的数据吞吐. 缺点:比较明显,后期数据运维与迁移比较困难.好在Mycat有对应的解决方案,具体后期验证或可直接参考Mycat权威指南相应章节. 2 环境说明 参考  <MyCat 学习笔记>第六篇.数据分片 之 按月数据分片  http://www.cnblogs.com/kaye0110/p/5160826.html 3 参数配置 3.1 server.xm

Android学习笔记（十一）——从意图返回结果

从意图返回结果 startActivity()方法调用另一个活动,但并没有返回结果给当前活动.此时如想从一个活动中回传数据,就要使用startActivityForResult()方法. 点此获取完整代码~                                                                  1.使用上一篇中创建的项目,在secondactivity.xml文件中添加文本框和按钮,代码如下: <TextView android:layout_width

嵌入式学习笔记008-裸奔篇之串口

串口是个好东西,前几篇裸奔程序由于没有串口,自己调试都是有led等来表示的,比较"苦逼",终于可以用串口了~~~,这里主要采用上一篇博文(嵌入式学习笔记007-裸奔篇之定时器),也就是串口也是用中断实现的,而且也只是在前一篇博文增加串口的初始化uart0_init(),以及在中断处理函数增加对串口的处理.只要稍微改造前一篇博文就是一个通用的中断处理程序! 这里主要实现在串口输入一个字符,接受后+2再发送到串口,所以在串口输入a 会返回c---. 由于code都有相应的注释,读者自行查看

Java快速教程--vamei 学习笔记（基础篇）

链接:http://www.cnblogs.com/vamei/archive/2013/03/31/2991531.html java快速教程第1课 从HelloWorld到面向对象 学习网址:http://www.cnblogs.com/vamei/archive/2013/03/14/2958654.html java快速教程第2课 方法与数据成员 学习网址:http://www.cnblogs.com/vamei/archive/2013/03/25/2964430.html java快