Housekeeping.

2 files changed, 6 insertions, 6 deletions

diff --git a/lib/sqlalchemy/engine/base.py b/lib/sqlalchemy/engine/base.py
index 958cb7480..d3d96a711 100644
--- a/lib/sqlalchemy/engine/base.py
+++ b/lib/sqlalchemy/engine/base.py
@@ -247,12 +247,12 @@ class Dialect(object):
 
         raise NotImplementedError()
 
-    def do_executemany(self, cursor, statement, parameters):
+    def do_executemany(self, cursor, statement, parameters, context=None):
         """Provide an implementation of *cursor.executemany(statement, parameters)*."""
 
         raise NotImplementedError()
 
-    def do_execute(self, cursor, statement, parameters):
+    def do_execute(self, cursor, statement, parameters, context=None):
         """Provide an implementation of *cursor.execute(statement, parameters)*."""
 
         raise NotImplementedError()
diff --git a/lib/sqlalchemy/engine/default.py b/lib/sqlalchemy/engine/default.py
index 0ab0eb82b..3322753bb 100644
--- a/lib/sqlalchemy/engine/default.py
+++ b/lib/sqlalchemy/engine/default.py
@@ -52,8 +52,8 @@ class DefaultDialect(base.Dialect):
         
         return {}
     
-    def create_execution_context(self, **kwargs):
-        return DefaultExecutionContext(self, **kwargs)
+    def create_execution_context(self, connection, **kwargs):
+        return DefaultExecutionContext(self, connection, **kwargs)
 
     def type_descriptor(self, typeobj):
         """Provide a database-specific ``TypeEngine`` object, given
@@ -108,10 +108,10 @@ class DefaultDialect(base.Dialect):
     def do_release_savepoint(self, connection, name):
         connection.execute(expression.ReleaseSavepointClause(name))
 
-    def do_executemany(self, cursor, statement, parameters, **kwargs):
+    def do_executemany(self, cursor, statement, parameters, context=None):
         cursor.executemany(statement, parameters)
 
-    def do_execute(self, cursor, statement, parameters, **kwargs):
+    def do_execute(self, cursor, statement, parameters, context=None):
         cursor.execute(statement, parameters)
 
     def is_disconnect(self, e):