summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/databases/mysql.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2006-08-10 19:17:45 +0000
committerMike Bayer <mike_mp@zzzcomputing.com>2006-08-10 19:17:45 +0000
commit66b7de5fdbe9bc07a798c359e8a45114e3293039 (patch)
tree1cf7a4346b668631ef053aae2cc9af1f604c7e23 /lib/sqlalchemy/databases/mysql.py
parentb84796d095b83092f51c2995a4858cb390eefb19 (diff)
downloadsqlalchemy-66b7de5fdbe9bc07a798c359e8a45114e3293039.tar.gz
moved rollback catch to mysql module...
Diffstat (limited to 'lib/sqlalchemy/databases/mysql.py')
-rw-r--r--lib/sqlalchemy/databases/mysql.py7
1 files changed, 7 insertions, 0 deletions
diff --git a/lib/sqlalchemy/databases/mysql.py b/lib/sqlalchemy/databases/mysql.py
index 7e337b9a3..2ce7e9825 100644
--- a/lib/sqlalchemy/databases/mysql.py
+++ b/lib/sqlalchemy/databases/mysql.py
@@ -297,6 +297,13 @@ class MySQLDialect(ansisql.ANSIDialect):
def schemadropper(self, *args, **kwargs):
return MySQLSchemaDropper(*args, **kwargs)
+ def do_rollback(self, connection):
+ # some versions of MySQL just dont support rollback() at all....
+ try:
+ connection.rollback()
+ except:
+ pass
+
def get_default_schema_name(self):
if not hasattr(self, '_default_schema_name'):
self._default_schema_name = text("select database()", self).scalar()