diff options
| author | Mike Bayer <mike_mp@zzzcomputing.com> | 2017-08-29 14:31:43 -0400 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2017-08-29 14:32:35 -0400 |
| commit | 56950a78db62d880a2f2c240c8c5873af86310c2 (patch) | |
| tree | f04e099dada18965e03c59ad6151cc144a392823 /lib/sqlalchemy/connectors/pyodbc.py | |
| parent | ec4f567f31856a92bd91144112cd29df356a8ca8 (diff) | |
| download | sqlalchemy-56950a78db62d880a2f2c240c8c5873af86310c2.tar.gz | |
Implement AUTOCOMMIT for pyodbc, pymssql
In prep for CI coverage for SQL Server, allow AUTOCOMMIT
isolation level to work
Change-Id: I850b977e75f53385986f2c181be4e4412dd3b3f4
Diffstat (limited to 'lib/sqlalchemy/connectors/pyodbc.py')
| -rw-r--r-- | lib/sqlalchemy/connectors/pyodbc.py | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/lib/sqlalchemy/connectors/pyodbc.py b/lib/sqlalchemy/connectors/pyodbc.py index ee8445dae..65fe37212 100644 --- a/lib/sqlalchemy/connectors/pyodbc.py +++ b/lib/sqlalchemy/connectors/pyodbc.py @@ -194,3 +194,17 @@ class PyODBCConnector(Connector): except ValueError: version.append(n) return tuple(version) + + def set_isolation_level(self, connection, level): + # adjust for ConnectionFairy being present + # allows attribute set e.g. "connection.autocommit = True" + # to work properly + if hasattr(connection, 'connection'): + connection = connection.connection + + if level == 'AUTOCOMMIT': + connection.autocommit = True + else: + connection.autocommit = False + super(PyODBCConnector, self).set_isolation_level(connection, + level) |