diff options
| author | Jason Kirtland <jek@discorporate.us> | 2007-10-23 01:16:27 +0000 |
|---|---|---|
| committer | Jason Kirtland <jek@discorporate.us> | 2007-10-23 01:16:27 +0000 |
| commit | 8dfff3888f4ab28487a573cc5617c818c3975c2d (patch) | |
| tree | ebf648d33f183f7adf061fae29024cfefcf0f328 /lib/sqlalchemy/engine/base.py | |
| parent | d433ec4f0d27297236ebb265a4d311308e070573 (diff) | |
| download | sqlalchemy-8dfff3888f4ab28487a573cc5617c818c3975c2d.tar.gz | |
- The post_exec() hook now gets invoked before autocommit fires.
Diffstat (limited to 'lib/sqlalchemy/engine/base.py')
| -rw-r--r-- | lib/sqlalchemy/engine/base.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/lib/sqlalchemy/engine/base.py b/lib/sqlalchemy/engine/base.py index 656384ba6..5f3975684 100644 --- a/lib/sqlalchemy/engine/base.py +++ b/lib/sqlalchemy/engine/base.py @@ -787,6 +787,7 @@ class Connection(Connectable): parameters = self.__distill_params(multiparams, params) context = self.__create_execution_context(statement=statement, parameters=parameters) self.__execute_raw(context) + self._autocommit(context) return context.result() def __distill_params(self, multiparams, params): @@ -840,6 +841,7 @@ class Connection(Connectable): context.pre_execution() self.__execute_raw(context) context.post_execution() + self._autocommit(context) return context.result() def __create_execution_context(self, **kwargs): @@ -850,8 +852,7 @@ class Connection(Connectable): self._cursor_executemany(context.cursor, context.statement, context.parameters, context=context) else: self._cursor_execute(context.cursor, context.statement, context.parameters[0], context=context) - self._autocommit(context) - + def _cursor_execute(self, cursor, statement, parameters, context=None): if self.__engine._should_log_info: self.__engine.logger.info(statement) |