Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit 651b8bc

Browse files
author
Sergey Vasilyev
committed
Use dialect's quoting directly, not via compiler
1 parent 871c201 commit 651b8bc

2 files changed

Lines changed: 7 additions & 10 deletions

File tree

data_diff/queries/ast_classes.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ class Alias(ExprNode):
7474
name: str
7575

7676
def compile(self, c: Compiler) -> str:
77-
return f"{c.compile(self.expr)} AS {c.quote(self.name)}"
77+
return f"{c.compile(self.expr)} AS {c.dialect.quote(self.name)}"
7878

7979
@property
8080
def type(self):
@@ -408,14 +408,14 @@ def compile(self, c: Compiler) -> str:
408408
t for t in c._table_context if isinstance(t, TableAlias) and t.source_table is self.source_table
409409
]
410410
if not aliases:
411-
return c.quote(self.name)
411+
return c.dialect.quote(self.name)
412412
elif len(aliases) > 1:
413413
raise CompileError(f"Too many aliases for column {self.name}")
414414
(alias,) = aliases
415415

416-
return f"{c.quote(alias.name)}.{c.quote(self.name)}"
416+
return f"{c.dialect.quote(alias.name)}.{c.dialect.quote(self.name)}"
417417

418-
return c.quote(self.name)
418+
return c.dialect.quote(self.name)
419419

420420

421421
@dataclass
@@ -429,7 +429,7 @@ def source_table(self) -> Self:
429429

430430
def compile(self, c: Compiler) -> str:
431431
path = self.path # c.database._normalize_table_path(self.name)
432-
return ".".join(map(c.quote, path))
432+
return ".".join(map(c.dialect.quote, path))
433433

434434
# Statement shorthands
435435
def create(self, source_table: ITable = None, *, if_not_exists: bool = False, primary_keys: List[str] = None):
@@ -515,7 +515,7 @@ class TableAlias(ExprNode, ITable):
515515
name: str
516516

517517
def compile(self, c: Compiler) -> str:
518-
return f"{c.compile(self.source_table)} {c.quote(self.name)}"
518+
return f"{c.compile(self.source_table)} {c.dialect.quote(self.name)}"
519519

520520

521521
@dataclass
@@ -989,7 +989,7 @@ def compile(self, c: Compiler) -> str:
989989
else:
990990
expr = c.compile(self.expr)
991991

992-
columns = "(%s)" % ", ".join(map(c.quote, self.columns)) if self.columns is not None else ""
992+
columns = "(%s)" % ", ".join(map(c.dialect.quote, self.columns)) if self.columns is not None else ""
993993

994994
return f"INSERT INTO {c.compile(self.path)}{columns} {expr}"
995995

data_diff/queries/compiler.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,3 @@ def new_unique_table_name(self, prefix="tmp") -> DbPath:
8383

8484
def add_table_context(self, *tables: Sequence, **kw) -> Self:
8585
return self.replace(_table_context=self._table_context + list(tables), **kw)
86-
87-
def quote(self, s: str):
88-
return self.dialect.quote(s)

0 commit comments

Comments
 (0)