From: Mike Bayer Date: Tue, 9 Aug 2005 02:31:45 +0000 (+0000) Subject: (no commit message) X-Git-Tag: rel_0_1_0~837 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=2d33f007d3d3ba8bb28d047f1dfa578bbcabe302;p=thirdparty%2Fsqlalchemy%2Fsqlalchemy.git --- diff --git a/lib/sqlalchemy/engine.py b/lib/sqlalchemy/engine.py index ff9a588b96..22cc034348 100644 --- a/lib/sqlalchemy/engine.py +++ b/lib/sqlalchemy/engine.py @@ -119,22 +119,30 @@ class SQLEngine(schema.SchemaEngine): self.context.transaction.commit() self.context.transaction = None self.context.tcount = None - - def execute(self, statement, parameters, connection = None, echo = None, **params): + + def pre_exec(self, connection, cursor, statement, parameters, echo = None, **kwargs): + pass + + def post_exec(self, connection, cursor, statement, parameters, echo = None, **kwargs): + pass + + def execute(self, statement, parameters, connection = None, echo = None, **kwargs): if parameters is None: parameters = {} - + if echo is True or self._echo: self.log(statement) self.log(repr(parameters)) - + if connection is None: poolconn = self.connection() c = poolconn.cursor() else: c = connection.cursor() - + + self.pre_exec(connection, c, statement, parameters, echo = echo, **kwargs) c.execute(statement, parameters) + self.post_exec(connection, c, statement, parameters, echo = echo, **kwargs) return c def log(self, msg):