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

根据这篇文章，它可以通过将 'dictionary=True' 传递给游标构造函数来获得： http://dev.mysql.com/doc/connector-python/en/connector-python-api-mysqlcursordict.html

所以我尝试了：

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

并得到： TypeError: cursor() 得到了一个意外的关键字参数“字典”

我试过了：

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

并得到： TypeError: cursor() 得到了一个意外的关键字参数“named_tuple”

我也试过这个：cursor = MySQLCursorDict(cnx)

但无济于事。显然，我在这里使用了错误的版本，我怀疑我们只需要耐心等待，因为http://downloads.mysql.com/docs/connector-python-relnotes-en.a4.pdf 的文档表明这些新功能在撰写本文时处于 alpha 阶段。

Answer 2

一个可能的解决方案是像这样子类化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 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。