pythondefexecute(self,operation,parameters=none,async=false):的簡單介紹

本文目錄一覽：

• 1、python fetchone 取出的數據是什麼類型
• 2、python 的函數前面帶個杠是什麼意思?例如def _ExecuteCmd(self, cmd)
• 3、python async=False錯誤如何修改
• 4、SyntaxError:invalid syntax,def write(self,date,async=False):,srcapy爬蟲框架

python fetchone 取出的數據是什麼類型

舉例，首先看了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 result

def 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 result

def 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 pymysql

conn = pymysql.connect(host=’xxx’, port=3306,

user=’xucl’, password=’xuclxucl’, database=’xucl’)

cursor = conn.cursor()

cursor.execute(“select * from t”)

注意，我這裡並沒有執行fetch操作，如果監聽到的包裏面包含了結果，那麼就證明我們前面的分析是正確的，話不多說開始實驗，Wireshark抓包如下：

果然跟我們之前的預測是一致的，即使沒有進行fetch操作，MySQL也將結果集發送到客戶端了。另外關於結果集發送，可以參考我另外一篇文章：《由一個抓瞎的SQL引申出去》

結論：

客戶端執行SQL的時候，MySQL一次性將結果集發送給了客戶端

客戶端接收到結果集以後存儲本地內存變量中

fetch結果只是從這個本地變量中獲取，fetchone/fetchmany/fetchall只是獲取行為的不通，因此對於MySQL來說並沒有什麼不通的。

python 的函數前面帶個杠是什麼意思?例如def _ExecuteCmd(self, cmd)

上面這個例子就是說在一個類中，只有__a這個函數是內部函數，其他都可以在外部調，在python中至少大家習慣的寫法而已，無實際作用

python async=False錯誤如何修改

你使用的是Python3，而async是Python3中加入的關鍵字，關鍵字是不可以作為變量名的。所以拋出了一個語法錯誤（SyntaxError）。

這種情況常見做法是加一個下劃線，如:

async_ = False

這樣它就是一個普通的變量名而不是關鍵字了。

或者給這個變量換個名字。

PS: 實際上加下劃線也就是換名字。。

SyntaxError:invalid syntax,def write(self,date,async=False):,srcapy爬蟲框架

invalid syntax 是無效的標示符，說明你的函數或者變量定義出錯，你查一下就知道，你的函數名寫錯了。

a1=triangle(3,8) 改為 a1=triangle_area(3,8)