diff options
Diffstat (limited to 'lib/sqlalchemy/engine/base.py')
| -rw-r--r-- | lib/sqlalchemy/engine/base.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/lib/sqlalchemy/engine/base.py b/lib/sqlalchemy/engine/base.py index cd662ac92..722acd6f0 100644 --- a/lib/sqlalchemy/engine/base.py +++ b/lib/sqlalchemy/engine/base.py @@ -1806,6 +1806,7 @@ class DefaultRunner(schema.SchemaVisitor): def __init__(self, context): self.context = context self.dialect = context.dialect + self.cursor = context.cursor def get_column_default(self, column): if column.default is not None: @@ -1846,8 +1847,8 @@ class DefaultRunner(schema.SchemaVisitor): conn = self.context._connection if isinstance(stmt, unicode) and not self.dialect.supports_unicode_statements: stmt = stmt.encode(self.dialect.encoding) - conn._cursor_execute(self.context.cursor, stmt, params) - return self.context.cursor.fetchone()[0] + conn._cursor_execute(self.cursor, stmt, params) + return self.cursor.fetchone()[0] def visit_column_onupdate(self, onupdate): if isinstance(onupdate.arg, expression.ClauseElement): |