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/mysqldb.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/mysqldb.py')
| -rw-r--r-- | lib/sqlalchemy/dialects/mysql/mysqldb.py | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/lib/sqlalchemy/dialects/mysql/mysqldb.py b/lib/sqlalchemy/dialects/mysql/mysqldb.py index 929317467..67d2f3d1d 100644 --- a/lib/sqlalchemy/dialects/mysql/mysqldb.py +++ b/lib/sqlalchemy/dialects/mysql/mysqldb.py @@ -203,5 +203,17 @@ class MySQLDialect_mysqldb(MySQLDialect): else: return cset_name() + _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_mysqldb, self)._set_isolation_level(connection, + level) + dialect = MySQLDialect_mysqldb |