python資料庫結果集_python如何訪問資料庫

A. 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來說並沒有什麼不通的。

B. python如何訪問資料庫

1.背景：

python提供了很多資料庫介面，常用的資料庫有 MS SQL Server /mysql /oracle 等。

打開鏈接 https://wiki.python.org/moin/DatabaseInterfaces

是python 關於資料庫介面的一個總結，可以看到python支持的訪問的資料庫系統。

2.模塊：

python 主要是通過模塊和資料庫連接的。

2.1 安裝模塊：

如果使用anconda，本身就會集合很多模塊，不需要手動安裝。如果用pycharm就要手動安裝模塊。

安裝模塊流程：

下載模塊擴展包放到路徑下——>cmd找到相應路徑——> pip install +擴展包名字

下面列舉一些常用連接資料庫的模塊：pymssql / sqlite3/ PyMySQL/pyodbc/odbc/adodbapi

不同模塊連接的資料庫不同，支持的版本系統有的也不一樣。但是大體用法都是相近的，因為有DB-API

導航:首頁 > 編程語言 > python資料庫結果集

python資料庫結果集

與python資料庫結果集相關的資料