summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/dialects
diff options
context:
space:
mode:
authormike bayer <mike_mp@zzzcomputing.com>2022-12-17 02:02:33 +0000
committerGerrit Code Review <gerrit@ci3.zzzcomputing.com>2022-12-17 02:02:33 +0000
commite7e51af5b61c49d5198e31dfd0ef04e8941551eb (patch)
treea47665bbcda2a450aec8c3a8ff30a5d7873f5988 /lib/sqlalchemy/dialects
parente84cc158c469f17c90f2e058ed72595bc3be5cdb (diff)
parentf8fd9ce23350c1f8fad13ff78506b100670a5896 (diff)
downloadsqlalchemy-e7e51af5b61c49d5198e31dfd0ef04e8941551eb.tar.gz
Merge "ensure all visit methods accept **kw" into main
Diffstat (limited to 'lib/sqlalchemy/dialects')
-rw-r--r--lib/sqlalchemy/dialects/mssql/base.py24
-rw-r--r--lib/sqlalchemy/dialects/mysql/base.py14
-rw-r--r--lib/sqlalchemy/dialects/oracle/base.py8
-rw-r--r--lib/sqlalchemy/dialects/postgresql/base.py20
-rw-r--r--lib/sqlalchemy/dialects/sqlite/base.py16
5 files changed, 41 insertions, 41 deletions
diff --git a/lib/sqlalchemy/dialects/mssql/base.py b/lib/sqlalchemy/dialects/mssql/base.py
index aa640727f..08b76206a 100644
--- a/lib/sqlalchemy/dialects/mssql/base.py
+++ b/lib/sqlalchemy/dialects/mssql/base.py
@@ -2237,12 +2237,12 @@ class MSSQLCompiler(compiler.SQLCompiler):
field = self.extract_map.get(extract.field, extract.field)
return "DATEPART(%s, %s)" % (field, self.process(extract.expr, **kw))
- def visit_savepoint(self, savepoint_stmt):
+ def visit_savepoint(self, savepoint_stmt, **kw):
return "SAVE TRANSACTION %s" % self.preparer.format_savepoint(
savepoint_stmt
)
- def visit_rollback_to_savepoint(self, savepoint_stmt):
+ def visit_rollback_to_savepoint(self, savepoint_stmt, **kw):
return "ROLLBACK TRANSACTION %s" % self.preparer.format_savepoint(
savepoint_stmt
)
@@ -2393,7 +2393,7 @@ class MSSQLCompiler(compiler.SQLCompiler):
for t in [from_table] + extra_froms
)
- def visit_empty_set_expr(self, type_):
+ def visit_empty_set_expr(self, type_, **kw):
return "SELECT 1 WHERE 1!=1"
def visit_is_distinct_from_binary(self, binary, operator, **kw):
@@ -2581,7 +2581,7 @@ class MSDDLCompiler(compiler.DDLCompiler):
return colspec
- def visit_create_index(self, create, include_schema=False):
+ def visit_create_index(self, create, include_schema=False, **kw):
index = create.element
self._verify_index_table(index)
preparer = self.preparer
@@ -2633,13 +2633,13 @@ class MSDDLCompiler(compiler.DDLCompiler):
return text
- def visit_drop_index(self, drop):
+ def visit_drop_index(self, drop, **kw):
return "\nDROP INDEX %s ON %s" % (
self._prepared_index_name(drop.element, include_schema=False),
self.preparer.format_table(drop.element.table),
)
- def visit_primary_key_constraint(self, constraint):
+ def visit_primary_key_constraint(self, constraint, **kw):
if len(constraint) == 0:
return ""
text = ""
@@ -2662,7 +2662,7 @@ class MSDDLCompiler(compiler.DDLCompiler):
text += self.define_constraint_deferrability(constraint)
return text
- def visit_unique_constraint(self, constraint):
+ def visit_unique_constraint(self, constraint, **kw):
if len(constraint) == 0:
return ""
text = ""
@@ -2685,7 +2685,7 @@ class MSDDLCompiler(compiler.DDLCompiler):
text += self.define_constraint_deferrability(constraint)
return text
- def visit_computed_column(self, generated):
+ def visit_computed_column(self, generated, **kw):
text = "AS (%s)" % self.sql_compiler.process(
generated.sqltext, include_table=False, literal_binds=True
)
@@ -2694,7 +2694,7 @@ class MSDDLCompiler(compiler.DDLCompiler):
text += " PERSISTED"
return text
- def visit_set_table_comment(self, create):
+ def visit_set_table_comment(self, create, **kw):
schema = self.preparer.schema_for_object(create.element)
schema_name = schema if schema else self.dialect.default_schema_name
return (
@@ -2708,7 +2708,7 @@ class MSDDLCompiler(compiler.DDLCompiler):
)
)
- def visit_drop_table_comment(self, drop):
+ def visit_drop_table_comment(self, drop, **kw):
schema = self.preparer.schema_for_object(drop.element)
schema_name = schema if schema else self.dialect.default_schema_name
return (
@@ -2719,7 +2719,7 @@ class MSDDLCompiler(compiler.DDLCompiler):
)
)
- def visit_set_column_comment(self, create):
+ def visit_set_column_comment(self, create, **kw):
schema = self.preparer.schema_for_object(create.element.table)
schema_name = schema if schema else self.dialect.default_schema_name
return (
@@ -2736,7 +2736,7 @@ class MSDDLCompiler(compiler.DDLCompiler):
)
)
- def visit_drop_column_comment(self, drop):
+ def visit_drop_column_comment(self, drop, **kw):
schema = self.preparer.schema_for_object(drop.element.table)
schema_name = schema if schema else self.dialect.default_schema_name
return (
diff --git a/lib/sqlalchemy/dialects/mysql/base.py b/lib/sqlalchemy/dialects/mysql/base.py
index 2525c6c32..f965eac15 100644
--- a/lib/sqlalchemy/dialects/mysql/base.py
+++ b/lib/sqlalchemy/dialects/mysql/base.py
@@ -1663,7 +1663,7 @@ class MySQLCompiler(compiler.SQLCompiler):
for t in [from_table] + extra_froms
)
- def visit_empty_set_expr(self, element_types):
+ def visit_empty_set_expr(self, element_types, **kw):
return (
"SELECT %(outer)s FROM (SELECT %(inner)s) "
"as _empty_set WHERE 1!=1"
@@ -1962,14 +1962,14 @@ class MySQLDDLCompiler(compiler.DDLCompiler):
return text
- def visit_primary_key_constraint(self, constraint):
+ def visit_primary_key_constraint(self, constraint, **kw):
text = super().visit_primary_key_constraint(constraint)
using = constraint.dialect_options["mysql"]["using"]
if using:
text += " USING %s" % (self.preparer.quote(using))
return text
- def visit_drop_index(self, drop):
+ def visit_drop_index(self, drop, **kw):
index = drop.element
text = "\nDROP INDEX "
if drop.if_exists:
@@ -1980,7 +1980,7 @@ class MySQLDDLCompiler(compiler.DDLCompiler):
self.preparer.format_table(index.table),
)
- def visit_drop_constraint(self, drop):
+ def visit_drop_constraint(self, drop, **kw):
constraint = drop.element
if isinstance(constraint, sa_schema.ForeignKeyConstraint):
qual = "FOREIGN KEY "
@@ -2014,7 +2014,7 @@ class MySQLDDLCompiler(compiler.DDLCompiler):
)
return ""
- def visit_set_table_comment(self, create):
+ def visit_set_table_comment(self, create, **kw):
return "ALTER TABLE %s COMMENT %s" % (
self.preparer.format_table(create.element),
self.sql_compiler.render_literal_value(
@@ -2022,12 +2022,12 @@ class MySQLDDLCompiler(compiler.DDLCompiler):
),
)
- def visit_drop_table_comment(self, create):
+ def visit_drop_table_comment(self, create, **kw):
return "ALTER TABLE %s COMMENT ''" % (
self.preparer.format_table(create.element)
)
- def visit_set_column_comment(self, create):
+ def visit_set_column_comment(self, create, **kw):
return "ALTER TABLE %s CHANGE %s %s" % (
self.preparer.format_table(create.element.table),
self.preparer.format_column(create.element),
diff --git a/lib/sqlalchemy/dialects/oracle/base.py b/lib/sqlalchemy/dialects/oracle/base.py
index dc2b011af..d6f65e5ed 100644
--- a/lib/sqlalchemy/dialects/oracle/base.py
+++ b/lib/sqlalchemy/dialects/oracle/base.py
@@ -1189,7 +1189,7 @@ class OracleCompiler(compiler.SQLCompiler):
def limit_clause(self, select, **kw):
return ""
- def visit_empty_set_expr(self, type_):
+ def visit_empty_set_expr(self, type_, **kw):
return "SELECT 1 FROM DUAL WHERE 1!=1"
def for_update_clause(self, select, **kw):
@@ -1279,12 +1279,12 @@ class OracleDDLCompiler(compiler.DDLCompiler):
return text
- def visit_drop_table_comment(self, drop):
+ def visit_drop_table_comment(self, drop, **kw):
return "COMMENT ON TABLE %s IS ''" % self.preparer.format_table(
drop.element
)
- def visit_create_index(self, create):
+ def visit_create_index(self, create, **kw):
index = create.element
self._verify_index_table(index)
preparer = self.preparer
@@ -1336,7 +1336,7 @@ class OracleDDLCompiler(compiler.DDLCompiler):
text = text.replace("NO ORDER", "NOORDER")
return text
- def visit_computed_column(self, generated):
+ def visit_computed_column(self, generated, **kw):
text = "GENERATED ALWAYS AS (%s)" % self.sql_compiler.process(
generated.sqltext, include_table=False, literal_binds=True
)
diff --git a/lib/sqlalchemy/dialects/postgresql/base.py b/lib/sqlalchemy/dialects/postgresql/base.py
index 8287e828a..3fb29812b 100644
--- a/lib/sqlalchemy/dialects/postgresql/base.py
+++ b/lib/sqlalchemy/dialects/postgresql/base.py
@@ -1836,7 +1836,7 @@ class PGCompiler(compiler.SQLCompiler):
self.process(flags, **kw),
)
- def visit_empty_set_expr(self, element_types):
+ def visit_empty_set_expr(self, element_types, **kw):
# cast the empty set to the type we are comparing against. if
# we are comparing against the null type, pick an arbitrary
# datatype for the empty set
@@ -2144,7 +2144,7 @@ class PGDDLCompiler(compiler.DDLCompiler):
not_valid = constraint.dialect_options["postgresql"]["not_valid"]
return " NOT VALID" if not_valid else ""
- def visit_check_constraint(self, constraint):
+ def visit_check_constraint(self, constraint, **kw):
if constraint._type_bound:
typ = list(constraint.columns)[0].type
if (
@@ -2162,12 +2162,12 @@ class PGDDLCompiler(compiler.DDLCompiler):
text += self._define_constraint_validity(constraint)
return text
- def visit_foreign_key_constraint(self, constraint):
+ def visit_foreign_key_constraint(self, constraint, **kw):
text = super().visit_foreign_key_constraint(constraint)
text += self._define_constraint_validity(constraint)
return text
- def visit_create_enum_type(self, create):
+ def visit_create_enum_type(self, create, **kw):
type_ = create.element
return "CREATE TYPE %s AS ENUM (%s)" % (
@@ -2178,12 +2178,12 @@ class PGDDLCompiler(compiler.DDLCompiler):
),
)
- def visit_drop_enum_type(self, drop):
+ def visit_drop_enum_type(self, drop, **kw):
type_ = drop.element
return "DROP TYPE %s" % (self.preparer.format_type(type_))
- def visit_create_domain_type(self, create):
+ def visit_create_domain_type(self, create, **kw):
domain: DOMAIN = create.element
options = []
@@ -2211,11 +2211,11 @@ class PGDDLCompiler(compiler.DDLCompiler):
f"{' '.join(options)}"
)
- def visit_drop_domain_type(self, drop):
+ def visit_drop_domain_type(self, drop, **kw):
domain = drop.element
return f"DROP DOMAIN {self.preparer.format_type(domain)}"
- def visit_create_index(self, create):
+ def visit_create_index(self, create, **kw):
preparer = self.preparer
index = create.element
self._verify_index_table(index)
@@ -2303,7 +2303,7 @@ class PGDDLCompiler(compiler.DDLCompiler):
return text
- def visit_drop_index(self, drop):
+ def visit_drop_index(self, drop, **kw):
index = drop.element
text = "\nDROP INDEX "
@@ -2382,7 +2382,7 @@ class PGDDLCompiler(compiler.DDLCompiler):
return "".join(table_opts)
- def visit_computed_column(self, generated):
+ def visit_computed_column(self, generated, **kw):
if generated.persisted is False:
raise exc.CompileError(
"PostrgreSQL computed columns do not support 'virtual' "
diff --git a/lib/sqlalchemy/dialects/sqlite/base.py b/lib/sqlalchemy/dialects/sqlite/base.py
index 5d8b3fbad..5a0761e5f 100644
--- a/lib/sqlalchemy/dialects/sqlite/base.py
+++ b/lib/sqlalchemy/dialects/sqlite/base.py
@@ -1423,12 +1423,12 @@ class SQLiteCompiler(compiler.SQLCompiler):
self.process(binary.right, **kw),
)
- def visit_empty_set_op_expr(self, type_, expand_op):
+ def visit_empty_set_op_expr(self, type_, expand_op, **kw):
# slightly old SQLite versions don't seem to be able to handle
# the empty set impl
return self.visit_empty_set_expr(type_)
- def visit_empty_set_expr(self, element_types):
+ def visit_empty_set_expr(self, element_types, **kw):
return "SELECT %s FROM (SELECT %s) WHERE 1!=1" % (
", ".join("1" for type_ in element_types or [INTEGER()]),
", ".join("1" for type_ in element_types or [INTEGER()]),
@@ -1595,7 +1595,7 @@ class SQLiteDDLCompiler(compiler.DDLCompiler):
return colspec
- def visit_primary_key_constraint(self, constraint):
+ def visit_primary_key_constraint(self, constraint, **kw):
# for columns with sqlite_autoincrement=True,
# the PRIMARY KEY constraint can only be inline
# with the column itself.
@@ -1624,7 +1624,7 @@ class SQLiteDDLCompiler(compiler.DDLCompiler):
return text
- def visit_unique_constraint(self, constraint):
+ def visit_unique_constraint(self, constraint, **kw):
text = super().visit_unique_constraint(constraint)
on_conflict_clause = constraint.dialect_options["sqlite"][
@@ -1642,7 +1642,7 @@ class SQLiteDDLCompiler(compiler.DDLCompiler):
return text
- def visit_check_constraint(self, constraint):
+ def visit_check_constraint(self, constraint, **kw):
text = super().visit_check_constraint(constraint)
on_conflict_clause = constraint.dialect_options["sqlite"][
@@ -1654,7 +1654,7 @@ class SQLiteDDLCompiler(compiler.DDLCompiler):
return text
- def visit_column_check_constraint(self, constraint):
+ def visit_column_check_constraint(self, constraint, **kw):
text = super().visit_column_check_constraint(constraint)
if constraint.dialect_options["sqlite"]["on_conflict"] is not None:
@@ -1665,7 +1665,7 @@ class SQLiteDDLCompiler(compiler.DDLCompiler):
return text
- def visit_foreign_key_constraint(self, constraint):
+ def visit_foreign_key_constraint(self, constraint, **kw):
local_table = constraint.elements[0].parent.table
remote_table = constraint.elements[0].column.table
@@ -1681,7 +1681,7 @@ class SQLiteDDLCompiler(compiler.DDLCompiler):
return preparer.format_table(table, use_schema=False)
def visit_create_index(
- self, create, include_schema=False, include_table_schema=True
+ self, create, include_schema=False, include_table_schema=True, **kw
):
index = create.element
self._verify_index_table(index)