diff options
| author | Roman Podoliaka <rpodolyaka@mirantis.com> | 2015-01-31 13:50:20 +0200 |
|---|---|---|
| committer | Roman Podoliaka <rpodolyaka@mirantis.com> | 2015-02-24 19:50:54 +0200 |
| commit | a87b3c2101114d82f999c23d113ad2018629ed48 (patch) | |
| tree | 201be7e111e1f1d4f7ccaf19f0f8c234dae545a6 /lib/sqlalchemy/dialects/mysql/mysqlconnector.py | |
| parent | 305ea84004fe604f461cd3c9438fbc84e3d790b2 (diff) | |
| download | sqlalchemy-pr/157.tar.gz | |
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.
Diffstat (limited to 'lib/sqlalchemy/dialects/mysql/mysqlconnector.py')
| -rw-r--r-- | lib/sqlalchemy/dialects/mysql/mysqlconnector.py | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/lib/sqlalchemy/dialects/mysql/mysqlconnector.py b/lib/sqlalchemy/dialects/mysql/mysqlconnector.py index 417e1ad6f..4dc803d2c 100644 --- a/lib/sqlalchemy/dialects/mysql/mysqlconnector.py +++ b/lib/sqlalchemy/dialects/mysql/mysqlconnector.py @@ -167,4 +167,17 @@ class MySQLDialect_mysqlconnector(MySQLDialect): def _compat_fetchone(self, rp, charset=None): return rp.fetchone() + _isolation_lookup = set(['SERIALIZABLE', 'READ UNCOMMITTED', + 'READ COMMITTED', 'REPEATABLE READ', + 'AUTOCOMMIT']) + + def _set_isolation_level(self, connection, level): + if level == 'AUTOCOMMIT': + connection.autocommit = True + else: + connection.autocommit = False + super(MySQLDialect_mysqlconnector, self)._set_isolation_level( + connection, level) + + dialect = MySQLDialect_mysqlconnector |