From: Jason Kirtland Date: Tue, 23 Oct 2007 01:16:27 +0000 (+0000) Subject: - The post_exec() hook now gets invoked before autocommit fires. X-Git-Tag: rel_0_4_1~119 X-Git-Url: http://git.ipfire.org/gitweb.cgi?a=commitdiff_plain;h=8dfff3888f4ab28487a573cc5617c818c3975c2d;p=thirdparty%2Fsqlalchemy%2Fsqlalchemy.git - The post_exec() hook now gets invoked before autocommit fires. --- diff --git a/lib/sqlalchemy/engine/base.py b/lib/sqlalchemy/engine/base.py index 656384ba65..5f39756849 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)