python mysql.connector DictCursor？

Question

在Python mysqldb我可以聲明遊標作爲字典光標這樣的：

cursor = db.cursor(MySQLdb.cursors.DictCursor) 

這將使我的名字像這樣的引用在cursor環列：

for row in cursor: # Using the cursor as iterator 
    city = row["city"] 
    state = row["state"] 

是否有可能使用此MySQL連接器創建字典遊標？ http://dev.mysql.com/doc/connector-python/en/connector-python-example-cursor-select.html

他們的例子只返回一個元組。

我想MySQL的創建者最終會爲我們做這件事嗎？

Answer 1

一種可能的解決方案涉及子類MySQLCursor類這樣的：

class MySQLCursorDict(mysql.connector.cursor.MySQLCursor): 
    def _row_to_python(self, rowdata, desc=None): 
     row = super(MySQLCursorDict, self)._row_to_python(rowdata, desc) 
     if row: 
      return dict(zip(self.column_names, row)) 
     return None 

db = mysql.connector.connect(user='root', database='test') 

cursor = db.cursor(cursor_class=MySQLCursorDict) 

現在_row_to_python()方法返回dictionary代替tuple。

我在mysql論壇上發現了這個，我相信它是由mysql開發者自己發佈的。我希望他們有一天將它添加到mysql連接器包中。

我測試了這個，它確實有效。

更新：正如下面由Karl M.W所提到的...這個子類在mysql.connector的v2中不再需要。 mysql.connector已更新，現在可以使用以下選項啓用字典光標。

cursor = db.cursor(dictionary=True) 

Answer 2

根據這篇文章在經過 '字典=真'，將光標構造它是可用： http://dev.mysql.com/doc/connector-python/en/connector-python-api-mysqlcursordict.html

所以我嘗試：

cnx = mysql.connector.connect(database='bananas') 
cursor = cnx.cursor(dictionary=True) 

，並得到： 類型錯誤：cursor（）得到了一個意想不到的關鍵字參數'dictionary'

，我嘗試：

cnx = mysql.connector.connect(database='bananas') 
cursor = cnx.cursor(named_tuple=True) 

，並得到： 類型錯誤：光標（）得到了一個意想不到的關鍵字參數 'named_tuple'

，我嘗試這一個了：cursor = MySQLCursorDict(cnx)

但無濟於事。顯然，我在這裏的版本是錯誤的，我懷疑我們必須耐心等待，因爲文檔http://downloads.mysql.com/docs/connector-python-relnotes-en.a4.pdf表明這些新功能在寫作階段處於alpha階段。

Answer 3

這個例子的工作原理：

cnx = mysql.connector.connect(database='world') 
cursor = cnx.cursor(dictionary=True) 
cursor.execute("SELECT * FROM country WHERE Continent = 'Europe'") 

print("Countries in Europe:") 
for row in cursor: 
    print("* {Name}".format(Name=row['Name'] 

請記住，在這個例子中，'Name'是具體到被引用的數據庫列名。

另外，如果你想使用存儲過程，而是執行此操作：

cursor.callproc(stored_procedure_name, args) 
result = [] 
for recordset in cursor.stored_results(): 
    for row in recordset: 
     result.append(dict(zip(recordset.column_names,row))) 

其中stored_procedure_name是使用存儲過程的名稱和args是對於存儲過程的參數列表（離開這個如果沒有參數傳入，字段爲空，如[]）。

這是從MySQL文檔的例子在這裏找到：http://dev.mysql.com/doc/connector-python/en/connector-python-api-mysqlcursordict.html

Answer 4

使用Python 3.6.2和MySQLdb的版本1.3.10，我得到這個一起工作：

import MySQLdb 
import MySQLdb.cursors 

... 

conn = MySQLdb.connect(host='...', 
         <connection info>, 
         cursorclass=MySQLdb.cursors.DictCursor) 

try: 
    with conn.cursor() as cursor: 
     query = '<SQL>' 
     data = cursor.fetchall() 
     for record in data: 
      ... record['<field name>'] ... 

finally: 
    conn.close() 

我使用PyCharm，並簡單地挖掘MySQLdb模塊connections.py和cursors.py。