diff options
Diffstat (limited to 'lib/sqlalchemy/engine/base.py')
| -rw-r--r-- | lib/sqlalchemy/engine/base.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/sqlalchemy/engine/base.py b/lib/sqlalchemy/engine/base.py index 3e89c44dd..2d82e3342 100644 --- a/lib/sqlalchemy/engine/base.py +++ b/lib/sqlalchemy/engine/base.py @@ -619,7 +619,6 @@ class Connection(Connectable): self.__engine.dialect.do_rollback(self.connection) except Exception, e: raise exceptions.SQLError(None, None, e) - self.__connection.close_open_cursors() self.__transaction = None def _commit_impl(self): @@ -770,6 +769,7 @@ class Connection(Connectable): if self.dialect.is_disconnect(e): self.__connection.invalidate(e=e) self.engine.dispose() + context.cursor.close() self._autorollback() if self.__close_with_result: self.close() @@ -782,6 +782,7 @@ class Connection(Connectable): if self.dialect.is_disconnect(e): self.__connection.invalidate(e=e) self.engine.dispose() + context.cursor.close() self._autorollback() if self.__close_with_result: self.close() |