Remove unneeded "bound" nodes & tables

Author: Sergey Vasilyev

data_diff/bound_exprs.py

@@ -59,7 +59,6 @@
     AbstractMixin_NormalizeValue,
     AbstractMixin_OptimizerHints,
 )
-from data_diff.bound_exprs import BoundNode, bound_table
 
 logger = logging.getLogger("database")
 cv_params = contextvars.ContextVar("params")
@@ -275,8 +274,6 @@ def render_compilable(self, c: Compiler, elem: Compilable) -> str:
             return self.render_inserttotable(c, elem)
         elif isinstance(elem, Code):
             return self.render_code(c, elem)
-        elif isinstance(elem, BoundNode):
-            return self.render_boundnode(c, elem)
         elif isinstance(elem, _ResolveColumn):
             return self.render__resolvecolumn(c, elem)
 
@@ -424,10 +421,6 @@ def render_tableop(self, parent_c: Compiler, elem: TableOp) -> str:
             table_expr = f"({table_expr})"
         return table_expr
 
-    def render_boundnode(self, c: Compiler, elem: BoundNode) -> str:
-        assert self is elem.database.dialect
-        return self.compile(c, elem.node)
-
     def render__resolvecolumn(self, c: Compiler, elem: _ResolveColumn) -> str:
         return self.compile(c, elem._get_resolved())
 
@@ -970,9 +963,6 @@ def close(self):
     def list_tables(self, tables_like, schema=None):
         return self.query(self.dialect.list_tables(schema or self.default_schema, tables_like))
 
-    def table(self, *path, **kw):
-        return bound_table(self, path, **kw)
-
 
 class ThreadedDatabase(Database):
     """Access the database through singleton threads.

data_diff/databases/base.py

@@ -8,6 +8,7 @@
 from data_diff import databases as dbs
 from data_diff.queries.api import table, current_timestamp
 from data_diff.queries.extras import NormalizeAsString
+from data_diff.schema import create_schema
 from tests.common import TEST_MYSQL_CONN_STRING, test_each_database_in_list, get_conn, str_to_checksum, random_table_suffix
 from data_diff.abcs.database_types import TimestampTZ
 
@@ -123,7 +124,11 @@ def test_correct_timezone(self):
         db.query(table(name).insert_row(1, now, now))
         db.query(db.dialect.set_timezone_to_utc())
 
-        t = db.table(name).query_schema()
+        t = table(name)
+        raw_schema = db.query_table_schema(t.path)
+        schema = db._process_table_schema(t.path, raw_schema)
+        schema = create_schema(self.database, t, schema, case_sensitive=True)
+        t = t.replace(schema=schema)
         t.schema["created_at"] = t.schema["created_at"].replace(precision=t.schema["created_at"].precision)
 
         tbl = table(name, schema=t.schema)