We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents a4b3288 + 8c50eee commit 45a4eabCopy full SHA for 45a4eab
tornado_mysql/pools.py
@@ -110,18 +110,19 @@ def _after_close(self, fut=None):
110
log.debug("Connection closed: %s", self.stat())
111
112
@coroutine
113
- def execute(self, query, params=None):
+ def execute(self, query, params=None, cursor=None):
114
"""Execute query in pool.
115
116
Returns future yielding closed cursor.
117
You can get rows, lastrowid, etc from the cursor.
118
+ :param cursor: cursor class(Cursor, DictCursor. etc.)
119
120
:return: Future of cursor
121
:rtype: Future
122
"""
123
conn = yield self._get_conn()
124
try:
- cur = conn.cursor()
125
+ cur = conn.cursor(cursor)
126
yield cur.execute(query, params)
127
yield cur.close()
128
except:
0 commit comments