{{ item.name }}
{{ item.name }}

{{ it.name }}

{{ it.text }}

{{ it.name }}

{{ innerIt.name }}

{{ innerIt.text }}

{{news.time}}
{{news.title}}
MySQL里fetchone和fetchall有区别吗
2020-05-22发布 1,303浏览

导读:

今天开发问了我一个问题,大概问题是php程序执行了一条SQL,然后fetchone去取跟fetchall去取有什么区别吗?

  • 首先,他认为mysql执行一条SQL,并且把结果都存储在了MySQL的内存某个区域中了。

  • 其次,他认为去fetch的时候是从MySQL这个内存区域中去获取数据,无非就是fetchone是单条单条去获取,fetchall是将数据全部过去到。

实验:

这个问题我之前也疑惑过,因为之前也写了很多的python脚本用来获取MySQL数据,但是基本上都是按套路写下来,也没有去深究这个数据获取是怎么操作的。那带着这个问题,我首先看了pymysql里面的cursor类,关于execute、fetchone和fetchall定义如下:

#调用self._query方法进行查询def execute(self, query, args=None):    """Execute a query    :param str query: Query to execute.    :param args: parameters used with query. (optional)    :type args: tuple, list or dict    :return: Number of affected rows    :rtype: int    If args is a list or tuple, %s can be used as a placeholder in the query.    If args is a dict, %(name)s can be used as a placeholder in the query.    """    while self.nextset():        pass    query = self.mogrify(query, args)    result = self._query(query)    self._executed = query    return result#调用_do_get_result获取查询结果def _query(self, q):    conn = self._get_db()    self._last_executed = q    self._clear_result()    conn.query(q)    self._do_get_result()    return self.rowcount#这里获取结果def _do_get_result(self):    conn = self._get_db()    self._result = result = conn._result    self.rowcount = result.affected_rows    self.description = result.description    self.lastrowid = result.insert_id    self._rows = result.rows    self._warnings_handled = False    if not self._defer_warnings:        self._show_warnings()

其实看到这里代码逻辑已经很清楚了,在调用cursor.execute执行SQL的时候,就将MySQL查询的结果放到result这个变量里了,也就是说结果集放到了客户端的内存变量里,那么获取数据的方式也就是从这个内存变量里去获取数据,只是获取的行为有所不同而已了。

def fetchone(self):    """Fetch the next row"""    self._check_executed()    if self._rows is None or self.rownumber >= len(self._rows):        return None    result = self._rows[self.rownumber]    self.rownumber += 1    return resultdef fetchmany(self, size=None):    """Fetch several rows"""    self._check_executed()    if self._rows is None:        return ()    end = self.rownumber + (size or self.arraysize)    result = self._rows[self.rownumber:end]    self.rownumber = min(end, len(self._rows))    return resultdef fetchall(self):    """Fetch all the rows"""    self._check_executed()    if self._rows is None:        return ()    if self.rownumber:        result = self._rows[self.rownumber:]        else:            result = self._rows            self.rownumber = len(self._rows)            return result

口说无凭,我们直接通过Wireshark抓包来证明一下,首先我在本地执行脚本如下,然后我监听本地的网卡流量

import pymysqlconn = pymysql.connect(host='xxx', port=3306,                       user='xucl', password='xuclxucl', database='xucl')cursor = conn.cursor()cursor.execute("select * from t")

注意,我这里并没有执行fetch操作,如果监听到的包里面包含了结果,那么就证明我们前面的分析是正确的,话不多说开始实验,Wireshark抓包如下:

MySQL里fetchone和fetchall有区别吗-爱可生


MySQL里fetchone和fetchall有区别吗-爱可生


果然跟我们之前的预测是一致的,即使没有进行fetch操作,MySQL也将结果集发送到客户端了。另外关于结果集发送,可以参考我另外一篇文章:《由一个抓瞎的SQL引申出去》

结论:

  • 客户端执行SQL的时候,MySQL一次性将结果集发送给了客户端

  • 客户端接受到结果集以后存储本地内存变量中

  • fetch结果只是从这个本地变量中获取,fetchone/fetchmany/fetchall只是获取行为的不同,因此对于MySQL来说并没有什么不同

上一篇
给大家介绍一下percona QAN
400-820-6580 13916131869
marketing@actionsky.com
上海市闵行区万源路2138号泓茂中心2号楼
产品详情
关系型数据库
AI数据库
数据库智能管理平台
数据库生态产品
行业案例
金融行业
新零售行业
制造业
通信行业
更多
公司动态
最新新闻
国产化信息
技术分享
关于我们
公司简介
公司分布
国家专利
资质认证
扫码关注公众号
© Copyright 2017, All rights reserved by: 上海爱可生信息技术股份有限公司 沪ICP备12003970号-1 | 法律声明 | 网站地图
沪公网安备 31010402003331号