mirror of
https://github.com/PyMySQL/mysqlclient.git
synced 2026-03-13 08:00:02 +08:00
Version 0.9.2c3, see CHANGELOG
This commit is contained in:
@@ -20,7 +20,7 @@ version_info = (
|
||||
9,
|
||||
2,
|
||||
"gamma",
|
||||
2)
|
||||
3)
|
||||
if version_info[3] == "final": __version__ = "%d.%d.%d" % version_info[:3]
|
||||
else: __version__ = "%d.%d.%d%1.1s%d" % version_info[:5]
|
||||
|
||||
@@ -37,9 +37,9 @@ apilevel = "2.0"
|
||||
paramstyle = "format"
|
||||
|
||||
from _mysql import *
|
||||
from sets import DBAPISet, Set
|
||||
from constants import FIELD_TYPE
|
||||
from times import Date, Time, Timestamp, \
|
||||
from MySQLdb.sets import DBAPISet, Set
|
||||
from MySQLdb.constants import FIELD_TYPE
|
||||
from MySQLdb.times import Date, Time, Timestamp, \
|
||||
DateFromTicks, TimeFromTicks, TimestampFromTicks
|
||||
|
||||
|
||||
|
||||
@@ -91,9 +91,12 @@ class BaseCursor:
|
||||
Returns long integer rows affected, if any
|
||||
|
||||
"""
|
||||
del self.messages[:]
|
||||
return self._execute(query, args)
|
||||
|
||||
def _execute(self, query, args):
|
||||
from types import ListType, TupleType
|
||||
from sys import exc_info
|
||||
del self.messages[:]
|
||||
try:
|
||||
r = self._query(query % self.connection.literal(args))
|
||||
except TypeError, m:
|
||||
@@ -103,8 +106,9 @@ class BaseCursor:
|
||||
else:
|
||||
self.errorhandler(self, TypeError, m)
|
||||
except:
|
||||
e = exc_info()
|
||||
self.errorhandler(self, e[0], e[1])
|
||||
exc, value, tb = exc_info()
|
||||
del tb
|
||||
self.errorhandler(self, exc, value)
|
||||
self._executed = query
|
||||
return r
|
||||
|
||||
@@ -134,7 +138,7 @@ class BaseCursor:
|
||||
if not m:
|
||||
r = 0
|
||||
for a in args:
|
||||
r = r + self.execute(query, a)
|
||||
r = r + self._execute(query, a)
|
||||
return r
|
||||
p = m.start(1)
|
||||
qv = query[p:]
|
||||
@@ -149,8 +153,9 @@ class BaseCursor:
|
||||
else:
|
||||
self.errorhandler(self, TypeError, msg)
|
||||
except:
|
||||
e = exc_info()
|
||||
self.errorhandler(self, e[0], e[1])
|
||||
exc, value, tb = exc_info()
|
||||
del tb
|
||||
self.errorhandler(self, exc, value)
|
||||
r = self._query(join(q,',\n'))
|
||||
self._executed = query
|
||||
return r
|
||||
|
||||
Reference in New Issue
Block a user