summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/engine.py
diff options
context:
space:
mode:
Diffstat (limited to 'lib/sqlalchemy/engine.py')
-rw-r--r--lib/sqlalchemy/engine.py11
1 files changed, 11 insertions, 0 deletions
diff --git a/lib/sqlalchemy/engine.py b/lib/sqlalchemy/engine.py
index 0f6b65909..7d158cb7e 100644
--- a/lib/sqlalchemy/engine.py
+++ b/lib/sqlalchemy/engine.py
@@ -596,6 +596,17 @@ class SQLEngine(schema.SchemaEngine):
def _executemany(self, c, statement, parameters):
c.executemany(statement, parameters)
self.context.rowcount = c.rowcount
+
+ def proxy(self, statement=None, parameters=None):
+ executemany = parameters is not None and isinstance(parameters, list)
+
+ if self.positional:
+ if executemany:
+ parameters = [p.values() for p in parameters]
+ else:
+ parameters = parameters.values()
+
+ return self.execute(statement, parameters)
def log(self, msg):
"""logs a message using this SQLEngine's logger stream."""