Add 'native' autocommit support for mysql driverspr/157

Sometimes it might be useful to have 'native' autocommit support
provided by a DB API driver rather than rely on SQLAlchemy autocommit
emulation.

1 files changed, 8 insertions, 0 deletions

diff --git a/lib/sqlalchemy/dialects/mysql/base.py b/lib/sqlalchemy/dialects/mysql/base.py
index 0d2c36189..c45f8c3ee 100644
--- a/lib/sqlalchemy/dialects/mysql/base.py
+++ b/lib/sqlalchemy/dialects/mysql/base.py
@@ -2387,6 +2387,14 @@ class MySQLDialect(default.DefaultDialect):
 
     def set_isolation_level(self, connection, level):
         level = level.replace('_', ' ')
+
+        # adjust for ConnectionFairy being present
+        if hasattr(connection, 'connection'):
+            connection = connection.connection
+
+        self._set_isolation_level(connection, level)
+
+    def _set_isolation_level(self, connection, level):
         if level not in self._isolation_lookup:
             raise exc.ArgumentError(
                 "Invalid value '%s' for isolation_level. "