equal
deleted
inserted
replaced
287 |
287 |
288 def _connect(self, ci): |
288 def _connect(self, ci): |
289 conn = oursql.connect(default_cursor=Cursor, **ci.parameters) |
289 conn = oursql.connect(default_cursor=Cursor, **ci.parameters) |
290 if not ci.isolation_level is None: |
290 if not ci.isolation_level is None: |
291 if ci.isolation_level == 'AUTOCOMMIT': |
291 if ci.isolation_level == 'AUTOCOMMIT': |
292 conn.autocommit(True) |
292 # This is default in MySQL, but to be sure... |
|
293 curs = conn.cursor() |
|
294 curs.execute('SET autocommit = 1;') |
|
295 curs.close() |
293 else: |
296 else: |
294 curs = conn.cursor() |
297 curs = conn.cursor() |
295 curs.execute('SET SESSION TRANSACTION ISOLATION LEVEL ' + ci.isolation_level) |
298 curs.execute('SET SESSION TRANSACTION ISOLATION LEVEL ' + ci.isolation_level) |
296 curs.close() |
299 curs.close() |
297 if ci.init_statement: |
300 if ci.init_statement: |