diff options
Diffstat (limited to 'lib/sqlalchemy/engine/base.py')
| -rw-r--r-- | lib/sqlalchemy/engine/base.py | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/lib/sqlalchemy/engine/base.py b/lib/sqlalchemy/engine/base.py index 888a15fee..d3024640b 100644 --- a/lib/sqlalchemy/engine/base.py +++ b/lib/sqlalchemy/engine/base.py @@ -986,8 +986,7 @@ class Connection(Connectable): statement, parameters = \ fn(self, cursor, statement, parameters, context, - context.executemany - if context is not None else False) + False) if self._echo: self.engine.logger.info(statement) @@ -996,14 +995,22 @@ class Connection(Connectable): self.dialect.do_execute( cursor, statement, - parameters) + parameters, + context) except Exception as e: self._handle_dbapi_exception( e, statement, parameters, cursor, - None) + context) + + if self._has_events: + self.dispatch.after_cursor_execute(self, cursor, + statement, + parameters, + context, + False) def _safe_close_cursor(self, cursor): """Close the given cursor, catching exceptions |