summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/dialects/maxdb/base.py
diff options
context:
space:
mode:
Diffstat (limited to 'lib/sqlalchemy/dialects/maxdb/base.py')
-rw-r--r--lib/sqlalchemy/dialects/maxdb/base.py15
1 files changed, 6 insertions, 9 deletions
diff --git a/lib/sqlalchemy/dialects/maxdb/base.py b/lib/sqlalchemy/dialects/maxdb/base.py
index b116d6df6..c02a9e204 100644
--- a/lib/sqlalchemy/dialects/maxdb/base.py
+++ b/lib/sqlalchemy/dialects/maxdb/base.py
@@ -401,6 +401,12 @@ class MaxDBExecutionContext(default.DefaultExecutionContext):
else:
return self.cursor.rowcount
+ def fire_sequence(self, seq):
+ if seq.optional:
+ return None
+ return self._execute_scalar("SELECT %s.NEXTVAL FROM DUAL" % (
+ self.dialect.identifier_preparer.format_sequence(seq)))
+
class MaxDBCachedColumnRow(engine_base.RowProxy):
"""A RowProxy that only runs result_processors once per column."""
@@ -610,14 +616,6 @@ class MaxDBCompiler(compiler.SQLCompiler):
')'))
-class MaxDBDefaultRunner(engine_base.DefaultRunner):
- def visit_sequence(self, seq):
- if seq.optional:
- return None
- return self.execute_string("SELECT %s.NEXTVAL FROM DUAL" % (
- self.dialect.identifier_preparer.format_sequence(seq)))
-
-
class MaxDBIdentifierPreparer(compiler.IdentifierPreparer):
reserved_words = set([
'abs', 'absolute', 'acos', 'adddate', 'addtime', 'all', 'alpha',
@@ -805,7 +803,6 @@ class MaxDBDialect(default.DefaultDialect):
preparer = MaxDBIdentifierPreparer
statement_compiler = MaxDBCompiler
ddl_compiler = MaxDBDDLCompiler
- defaultrunner = MaxDBDefaultRunner
execution_ctx_cls = MaxDBExecutionContext
colspecs = colspecs