这篇文章主要介绍“MySQL中关于排序order by limit值不稳定分析”,在日常操作中,相信很多人在MySQL中关于排序order by limit值不稳定分析问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”MySQL中关于排序order by limit值不稳定分析”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

一、问题抛出

数据如下:

CREATETABLE`testse`(`id`int(11)NOTNULL,`nu`int(11)DEFAULTNULL,`name`varchar(20)DEFAULTNULL,PRIMARYKEY(`id`),KEY`nu`(`nu`))ENGINE=InnoDBDEFAULTCHARSET=utf8;INSERTINTO`testse`VALUES(-1,14,'gaopeng'),(0,14,'gaopeng'),(1,1,'gaopeng'),(2,99,'gaopeng'),(3,55,'gaopeng'),(4,20,'gaopeng'),(5,24,'gaopeng'),(6,14,'gaopeng'),(7,14,'gaopeng'),(8,13,'gaopeng'),(9,9,'gaopeng'),(10,19,'gaopeng'),(11,20,'gaopeng'),(12,14,'gaopeng'),(13,15,'gaopeng'),(14,16,'gaopeng'),(15,20,'gaopeng'),(100,14,'gaopeng'),(111,14,'gaopeng');

问题如下:

mysql>select*fromtestseorderbynulimit3,1;+-----+------+---------+|id|nu|name|+-----+------+---------+|111|14|gaopeng|+-----+------+---------+1rowinset(2.76sec)mysql>select*fromtestseforceindex(nu)orderbynulimit3,1;+----+------+---------+|id|nu|name|+----+------+---------+|-1|14|gaopeng|+----+------+---------+1rowinset(0.00sec)

问为什么这两个语句得到的数据不一样。

二、问题原因

这里首先给出原因,在MySQL排序的时候可以使用索引来避免排序及不需要使用filesort,其次当使用filesort的时候可能在内存中出现两种情况及堆排序列和快速排序两种方式。所以MySQL内存排序可以使用的途径包含:

直接利用索引避免排序

快速排序

堆排序

具体使用哪一种排序方式是优化器决定的,总的说来如下:

直接利用索引避免排序:用于有索引且回表效率高的情况下

快速排序算法:如果没有索引大量排序的情况下

堆排序算法:如果没有索引排序量不大的情况下

而快速排序和堆排序是不稳定的排序算法,也就是对于重复值是不能保证顺序的。而直接利用索引的话其返回数据是稳定的,因为索引的B+树叶子结点的顺序是唯一且一定的。如上的key nu,其叶子结点包含了nu+id,它是唯一的顺序也是递增的。因此在这种不稳定的算法情况下上面的查询出现了不一样的结果,归根结底就是使用索引避免排序和堆排序对于重复值的处理上是不同的。
也许你会问为什么存在两种排序方式,实际上在大量排序的情况下快速排序是有优势的,而堆排序使用优先队列只完成少量的排序是有优势的,因为它根本不需要排序完成只排序你需要的数据量就可以了。

MySQL认为快速排序的速度是堆排序的3倍如下:

/*HowmuchPriorityQueuesortisslowerthanqsort.Measurements(seeunittest)indicatethatPQisroughly3timesslower.*/constdoublePQ_slowness=3.0;

那么在使用排序算法的时候会根据待排序数据量的大小进行切换具体根据函数check_if_pq_applicable进行判定的。在filesort函数里面有如下代码:

if(check_if_pq_applicable(trace,&param,&table_sort,table,num_rows,memory_available,subselect!=NULL)){DBUG_PRINT("info",("filesortPQisapplicable"));//使用堆排序/*ForPQqueries(withlimit)weknowexactlyhowmanypointers/recordswehaveinthebuffer,sotosimplifythings,weinitializeallpointershere.(Wecannotpackfieldsanyways,sothereisnopointindoinglazyinitialization).*/table_sort.init_record_pointers();.....filesort->using_pq=true;param.using_pq=true;}else//使用快速排序{DBUG_PRINT("info",("filesortPQisnotapplicable"));filesort->using_pq=false;param.using_pq=false;.....}三、如何确定是使用的那种方法返回排序的结果。

对于直接利用索引避免排序,这个直接看执行计划就好了,不会出现filesort字样。但是对于到底使用额快速排序还是堆排序则不好判断因为执行计划是一样的,我想到的只能是在调试的时候做断点,不知道还有其他办法没有。因此我在上面代码的if分支里面做了2个断点,其中一个断点在堆排序算法里面,一个断点在快速排序算法里面如下:

3breakpointkeepy0x0000000000f50e62infilesort(THD*,Filesort*,bool,ha_rows*,ha_rows*,ha_rows*)at/root/mysql5.7.14/percona-server-5.7.14-7/sql/filesort.cc:359breakpointalreadyhit3times4breakpointkeepy0x0000000000f50d41infilesort(THD*,Filesort*,bool,ha_rows*,ha_rows*,ha_rows*)at/root/mysql5.7.14/percona-server-5.7.14-7/sql/filesort.cc:333breakpointalreadyhit1time

其中断点3代表快速排序命中,断点4代表堆排序命中。

四、额外的测试

如上所述我们可以将结果的返回定义为三种方式,我们将在这里测试这三种方式的得到数据不同。

使用索引避免排序的结果

语句:
select * from testse force index(nu) order by nu;

mysql>descselect*fromtestseforceindex(nu)orderbynu;+----+-------------+--------+------------+-------+---------------+------+---------+------+------+----------+-------+|id|select_type|table|partitions|type|possible_keys|key|key_len|ref|rows|filtered|Extra|+----+-------------+--------+------------+-------+---------------+------+---------+------+------+----------+-------+|1|SIMPLE|testse|NULL|index|NULL|nu|5|NULL|19|100.00|NULL|+----+-------------+--------+------------+-------+---------------+------+---------+------+------+----------+-------+1rowinset,1warning(0.00sec)mysql>select*fromtestseforceindex(nu)orderbynu;+-----+------+---------+|id|nu|name|+-----+------+---------+|1|1|gaopeng||9|9|gaopeng||8|13|gaopeng||-1|14|gaopeng||0|14|gaopeng||6|14|gaopeng||7|14|gaopeng||12|14|gaopeng||100|14|gaopeng||111|14|gaopeng||13|15|gaopeng||14|16|gaopeng||10|19|gaopeng||4|20|gaopeng||11|20|gaopeng||15|20|gaopeng||5|24|gaopeng||3|55|gaopeng||2|99|gaopeng|+-----+------+---------+19rowsinset(0.01sec)

使用快速排序的结果

语句:
select * from testse order by nu;

因为我前面设置了断点,其断点命中如下:

Breakpoint3,filesort(thd=0x7fff300128c0,filesort=0x7fff30963e90,sort_positions=false,examined_rows=0x7ffff01158a0,found_rows=0x7ffff0115898,returned_rows=0x7ffff0115890)at/root/mysql5.7.14/percona-server-5.7.14-7/sql/filesort.cc:359359DBUG_PRINT("info",("filesortPQisnotapplicable"));

可以看到PQ 没有开启,也就是堆排序没有使用使用的优先队列堆排序方式。那么它的结果是

mysql>descselect*fromtestseorderbynu;+----+-------------+--------+------------+------+---------------+------+---------+------+------+----------+----------------+|id|select_type|table|partitions|type|possible_keys|key|key_len|ref|rows|filtered|Extra|+----+-------------+--------+------------+------+---------------+------+---------+------+------+----------+----------------+|1|SIMPLE|testse|NULL|ALL|NULL|NULL|NULL|NULL|19|100.00|Usingfilesort|+----+-------------+--------+------------+------+---------------+------+---------+------+------+----------+----------------+1rowinset,1warning(0.00sec)mysql>select*fromtestseorderbynu;+-----+------+---------+|id|nu|name|+-----+------+---------+|1|1|gaopeng||9|9|gaopeng||8|13|gaopeng||111|14|gaopeng||100|14|gaopeng||12|14|gaopeng||7|14|gaopeng||6|14|gaopeng||0|14|gaopeng||-1|14|gaopeng||13|15|gaopeng||14|16|gaopeng||10|19|gaopeng||4|20|gaopeng||11|20|gaopeng||15|20|gaopeng||5|24|gaopeng||3|55|gaopeng||2|99|gaopeng|+-----+------+---------+19rowsinset(1.74sec)

使用堆排序

语句:
select * from testse order by nu limit 8;

其断点命中

Breakpoint4,filesort(thd=0x7fff300128c0,filesort=0x7fff3095ecc8,sort_positions=false,examined_rows=0x7ffff01158a0,found_rows=0x7ffff0115898,returned_rows=0x7ffff0115890)at/root/mysql5.7.14/percona-server-5.7.14-7/sql/filesort.cc:333333DBUG_PRINT("info",("filesortPQisapplicable"));

可以看到PQ 开启了,也就是堆排序。

mysql>descselect*fromtestseorderbynulimit8;+----+-------------+--------+------------+------+---------------+------+---------+------+------+----------+----------------+|id|select_type|table|partitions|type|possible_keys|key|key_len|ref|rows|filtered|Extra|+----+-------------+--------+------------+------+---------------+------+---------+------+------+----------+----------------+|1|SIMPLE|testse|NULL|ALL|NULL|NULL|NULL|NULL|19|100.00|Usingfilesort|+----+-------------+--------+------------+------+---------------+------+---------+------+------+----------+----------------+1rowinset,1warning(0.00sec)mysql>select*fromtestseorderbynulimit8;+-----+------+---------+|id|nu|name|+-----+------+---------+|1|1|gaopeng||9|9|gaopeng||8|13|gaopeng||-1|14|gaopeng||0|14|gaopeng||12|14|gaopeng||111|14|gaopeng||6|14|gaopeng|+-----+------+---------+8rowsinset(2.20sec)

可以看到从前面8行来看,每种方法返回的数据是不一样的:

使用索引避免排序:+-----+------+---------+|id|nu|name|+-----+------+---------+|1|1|gaopeng||9|9|gaopeng||8|13|gaopeng||-1|14|gaopeng||0|14|gaopeng||6|14|gaopeng||7|14|gaopeng||12|14|gaopeng|使用快速排序:+-----+------+---------+|id|nu|name|+-----+------+---------+|1|1|gaopeng||9|9|gaopeng||8|13|gaopeng||111|14|gaopeng||100|14|gaopeng||12|14|gaopeng||7|14|gaopeng||6|14|gaopeng|使用堆排序:+-----+------+---------+|id|nu|name|+-----+------+---------+|1|1|gaopeng||9|9|gaopeng||8|13|gaopeng||-1|14|gaopeng||0|14|gaopeng||12|14|gaopeng||111|14|gaopeng||6|14|gaopeng|+-----+------+---------+五、总结

可以看到在不同的获取数据的方式得到的数据是一样的,但是这只是重复数据排序的部分,这是排序算法的不稳定性决定的。快速排序适合大数据量排序,堆排序在少量排序上有优势,因此当order by limit n,n到了一个数量级的时候会切换排序算法,这个在执行计划是看不到的,具体使用那种算法是优化器通过函数check_if_pq_applicable进行判定的。
其次这只是一种造成排序数据不一致的情况还有一种情况是由于参数 max_length_for_sort_data的参数影响的一次排序和二次排序,这个有机会在研究一下代码。一般默认1024个字节还是很少会超过的。

六、堆排序算法简单说明

最后我还是想简单描述一下堆排序算法,也当复习一下。具体可以参考算法导论等书籍,我们以大顶堆为例,实际上任何一个待排序的数组都可以看成一棵完全二叉树,用算法导论的截图如下:

image.png

这棵树是满足大顶堆定义的,在大顶堆中有如下特性:

必须满足完全二叉树

很方便的根据父节点的位置计算出两个叶子结点的位置
如果父节点的位置为i/2,左子节点为 i,右子节点为i+1这是完全二叉树的特性决定

所有子节点都可以看做一个子堆那么所有结点都有
父节点>左子节点 && 父节点>右节点

很明显的可以找到最大的元素,就是整个堆的根结点

在这个算法中,最重要也是最主要的就是堆的维护,堆的构建。

维护:
维护:采用的是自上而下的维护,可以用递归完成。
这里电子版有点不清晰,黑色结点就是值4

image.png

对应我最后的代码 bigheapad函数

构建
构建:是采用自下而上的构建,构建就是不断循环的对各个父结点做维护,以达到对任何一个无序数组满足大顶堆的条件。因为下层的子树满足了大顶堆条件那么上层就一定满足大顶堆的条件。

image.png

image.png

对应我最后的代码bigheapbulid函数

排序

实际上排序就是将数组中的第一个数字也就是最大的数字和最后一个数字交换,然后再次做一次维护做好大顶堆结构即可,如果反复不断做这个操作那么整个素组都会排序完成。

image.png

image.png

我的函数参考biglimitn和bigheapsort函数。对于MySQL的源码中堆排序的代码存在于priority_queue.h文件中,其中可以看到一些方法如:

维护 heapify函数

构建 build_heap函数

排序 sort函数
当然源码的实现复杂得多,有兴趣的朋友可以深入。栈帧备查:

#0Priority_queue<uchar*,std::vector<uchar*,Malloc_allocator<uchar*>>,<unnamed>::Mem_compare>::heapify(size_t,size_t)(this=0x7ffff0115650,i=0,last=8)at/root/mysql5.7.14/percona-server-5.7.14-7/include/priority_queue.h:124#10x0000000000f5807ainPriority_queue<uchar*,std::vector<uchar*,Malloc_allocator<uchar*>>,<unnamed>::Mem_compare>::heapify(size_t)(this=0x7ffff0115650,i=0)at/root/mysql5.7.14/percona-server-5.7.14-7/include/priority_queue.h:147#20x0000000000f57d1einPriority_queue<uchar*,std::vector<uchar*,Malloc_allocator<uchar*>>,<unnamed>::Mem_compare>::update_top(void)(this=0x7ffff0115650)at/root/mysql5.7.14/percona-server-5.7.14-7/include/priority_queue.h:354#30x0000000000f57814inBounded_queue<uchar*,uchar*,Sort_param,<unnamed>::Mem_compare>::push(uchar*)(this=0x7ffff0115650,element=0x7fff309166a0"o")at/root/mysql5.7.14/percona-server-5.7.14-7/sql/bounded_queue.h:106#40x0000000000f52da7infind_all_keys(Sort_param*,QEP_TAB*,Filesort_info*,IO_CACHE*,IO_CACHE*,Bounded_queue<uchar*,uchar*,Sort_param,<unnamed>::Mem_compare>*,ha_rows*)(param=0x7ffff01154c0,qep_tab=0x7fff309268e8,fs_info=0x7ffff0115550,chunk_file=0x7ffff0115200,tempfile=0x7ffff0115360,pq=0x7ffff0115650,found_rows=0x7ffff0115898)at/root/mysql5.7.14/percona-server-5.7.14-7/sql/filesort.cc:1013#50x0000000000f51165infilesort(thd=0x7fff30000bc0,filesort=0x7fff30926bd8,sort_positions=false,examined_rows=0x7ffff01158a0,found_rows=0x7ffff0115898,returned_rows=0x7ffff0115890)at/root/mysql5.7.14/percona-server-5.7.14-7/sql/filesort.cc:425

下面是一个我以前参考算法导论第六章堆排序写的一个实现,其中包含了大顶堆和小顶堆,供大家参考:

/*************************************************************************>FileName:heapsort.c>Author:gaopengQQ:22389860allrightreserved>Mail:gaopp_200217@163.com>CreatedTime:Sun08Jan201711:22:14PMCST************************************************************************/#include<stdio.h>#include<stdlib.h>#defineLEFT(i)i<<1#defineRIGTH(i)(i<<1)+1//堆排序的性能不及快速排序但是在某些情况下非常有用//数据库的orderbylimit使用了优先队列,基于堆排序intswap(intk[],inti,intj){inttemp;temp=k[i];k[i]=k[j];k[j]=temp;return0;}intbigheapad(intk[],ints,intn)//s=5,n=10自上而下的维护{/**one:inti;inttemp=k[s];//temp=9=k[4]父节点值保存到tempfor(i=2*s;i<=n;i=i*2)//i=8{if(i<n&&k[i]<k[i+1])//如果左子节点小于右子节点{i++;//右节点}if(temp>=k[i]){break;}k[s]=k[i];s=i;}k[s]=temp;*///two:参考算法导论P155页,整个方法更容易理解其原理,调整使用逐层下降的方法进行调整intl;//s左节点编号intr;//s右节点编号intlargest;l=LEFT(s);//左节点编号10r=RIGTH(s);//右节点编号11if(s<=n/2)//n/2为最小节点编号的父亲节点如果s大于这个值说明这个节点不会有任何子节点不需要进行调整!!,这是整个算法的核心中的核心。搞了我老半天{if(l<=n&&k[l]>k[s]){largest=l;//10}else{largest=s;}if(r<=n&&k[r]>k[largest])//11<=10不成立直接不运行{largest=r;}if(largest!=s)//如果较大的数字在孩子节点则交换父节点和孩子节点的值,否则不动{swap(k,largest,s);//这里做孩子节点和父节点的交换bigheapad(k,largest,n);//这里做递归下层操作,需要做到本次操作不会破坏堆的特性}}return0;}intbigheapbulid(intk[],intn)//bigheapbulid(a,10);{inti;for(i=n/2;i>0;i--)//采用自底向上的方法构建算法导论P156EXP1:i=n/2p:4l:8r:92:i=p:3l:6r:7n/2刚好是最后一个节点的父亲节点所以自下而上{//eg10i=54321bigheapad(k,i,n);//i=5n=10}return0;}intbigheapsort(intk[],intn)//sort的过程就是将最大元素放到最后,然后逐层下降的方法进行调整{inti;for(i=n;i>1;i--){swap(k,1,i);//这里k[1]就是最大值了,我们将他交换到最后面bigheapad(k,1,i-1);//重新构建大顶堆}return0;}intbiglimitn(intk[],intn,intlimitn)//limit也是我关心的这里明显可以看到他的优势实际它不需要对整个数组排序,你要多少我排多少给你就好,也是最大元素放到最后,然后逐层下降的方法进行调整的原理{inti;for(i=n;i>n-limitn;i--){swap(k,1,i);bigheapad(k,1,i-1);}return0;}intsmallheapad(intk[],ints,intn)//s=4,n=9{intl;//s左节点编号intr;//s右节点编号intsmallest;l=LEFT(s);//左节点编号r=RIGTH(s);//右节点编号if(s<=n/2)//n/2为最小节点编号的父亲节点如果s大于这个值说明这个节点不会有任何子节点不需要进行调整!!{if(l<=n&&k[l]<k[s]){smallest=l;}else{smallest=s;}if(r<=n&&k[r]<k[smallest]){smallest=r;}if(smallest!=s){swap(k,smallest,s);smallheapad(k,smallest,n);//对数据调整后可能的子节点树继续进行调整直到达到递归退出条件}}return0;}intsmallheapbulid(intk[],intn){inti;for(i=n/2;i>0;i--){smallheapad(k,i,n);}return0;}intsmallheapsort(intk[],intn){inti;for(i=n;i>1;i--){swap(k,1,i);smallheapad(k,1,i-1);}return0;}intsmalllimitn(intk[],intn,intlimitn){inti;for(i=n;i>n-limitn;i--){swap(k,1,i);smallheapad(k,1,i-1);}return0;}intmain(){inti,a[11]={0,999,3,2,9,34,5,102,90,2222,1};//测试数据a[0]不使用intb[11]={0,999,3,2,9,999,888888,102,90,2222,111};//测试数据b[0]不使用bigheapbulid(a,10);biglimitn(a,10,3);printf("大顶堆:\n");printf("orderbydescaarraylimit3result:");for(i=10;i>10-3;i--){printf("%d",a[i]);}printf("\n");bigheapbulid(b,10);printf("maxvaluesbarrayreulst:");printf("%d\n",b[1]);smallheapbulid(a,10);smalllimitn(a,10,3);printf("小顶堆:\n");printf("orderbyascaarraylimit3result:");for(i=10;i>10-3;i--){printf("%d",a[i]);}printf("\n");smallheapbulid(b,10);printf("minvaluesbarrayreulst:");printf("%d\n",b[1]);return0;}

到此,关于“MySQL中关于排序order by limit值不稳定分析”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!