From 2d33f007d3d3ba8bb28d047f1dfa578bbcabe302 Mon Sep 17 00:00:00 2001 From: Mike Bayer Date: Tue, 9 Aug 2005 02:31:45 +0000 Subject: [PATCH] --- lib/sqlalchemy/engine.py | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 deletions(-) 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): -- 2.47.2