dlt.destinations.queries

make_expand_table_name

def make_expand_table_name(
    sql_client: SqlClientBase[Any],
    logical_to_physical: Optional[Dict[str, str]] = None
) -> Callable[[str, Optional[str]], List[str]]

View source on GitHub

Create a bind_query table name expander bound to sql_client.

Arguments:

• sql_client SqlClientBase[Any] - Client whose dataset name and identifier rules build the qualified path.
• logical_to_physical Optional[Dict[str, str]] - Maps a logical dataset qualifier to the physical dataset name in the database.

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

View source on GitHub

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

View source on GitHub

Builds a SQL expression to select all or selected rows from a table.