diff options
Diffstat (limited to 'lib/sqlalchemy/engine.py')
-rw-r--r-- | lib/sqlalchemy/engine.py | 11 |
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.""" |