Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Fixed #69 -- Implemented dictfetchone(), dictfetchmany() and dictfetc…

…hall() for mysql DB backend. Thanks, Manuzhai!

git-svn-id: http://code.djangoproject.com/svn/django/trunk@190 bcc190cf-cafb-0310-a4f2-bffc1f526a37
  • Loading branch information...
commit 8f4fa5a4e7435876a99383bffafb7a09ba6667e1 1 parent 00f54d6
@adrianholovaty adrianholovaty authored
Showing with 12 additions and 3 deletions.
  1. +12 −3 django/core/db/backends/mysql.py
View
15 django/core/db/backends/mysql.py
@@ -46,17 +46,26 @@ def close(self):
self.connection.close()
self.connection = None
+def _dict_helper(desc, row):
+ "Returns a dictionary for the given cursor.description and result row."
+ return dict([(desc[col[0]][0], col[1]) for col in enumerate(row)])
+
def dictfetchone(cursor):
"Returns a row from the cursor as a dict"
- raise NotImplementedError
+ row = cursor.fetchone()
+ if not row:
+ return None
+ return _dict_helper(cursor.description, row)
def dictfetchmany(cursor, number):
"Returns a certain number of rows from a cursor as a dict"
- raise NotImplementedError
+ desc = cursor.description
+ return [_dict_helper(desc, row) for row in cursor.fetchmany(number)]
def dictfetchall(cursor):
"Returns all rows from a cursor as a dict"
- raise NotImplementedError
+ desc = cursor.description
+ return [_dict_helper(desc, row) for row in cursor.fetchall()]
def get_last_insert_id(cursor, table_name, pk_name):
cursor.execute("SELECT LAST_INSERT_ID()")
Please sign in to comment.
Something went wrong with that request. Please try again.