dlt.destinations.queries
normalize_query
def normalize_query(sqlglot_schema: SQLGlotSchema, qualified_query: sge.Query,
sql_client: SqlClientBase[Any]) -> sge.Query
Normalizes a qualified query compliant with the dlt schema into the namespace of the source dataset
build_row_counts_expr
def build_row_counts_expr(table_name: str,
quoted_identifiers: bool = True,
dlt_load_id_col: str = None,
load_id: str = None) -> sge.Select
Builds a SQL expression to count rows in a table, optionally filtering by a load ID.
build_select_expr
def build_select_expr(table_name: str,
selected_columns: List[str] = None,
quoted_identifiers: bool = True) -> sge.Select
Builds a SQL expression to select all or selected rows from a table.