]> git.ipfire.org Git - thirdparty/sqlalchemy/sqlalchemy.git/commitdiff
(no commit message)
authorMike Bayer <mike_mp@zzzcomputing.com>
Tue, 9 Aug 2005 02:31:45 +0000 (02:31 +0000)
committerMike Bayer <mike_mp@zzzcomputing.com>
Tue, 9 Aug 2005 02:31:45 +0000 (02:31 +0000)
lib/sqlalchemy/engine.py

index ff9a588b96e80b37ce6e4fb656b5c174c9a2e597..22cc0343488545cd1722ded0aca9b4ac8c76f9aa 100644 (file)
@@ -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):