dlt.destinations.dataset.relation

BaseReadableDBAPIRelation Objects

class BaseReadableDBAPIRelation(SupportsReadableRelation, WithSqlClient)

[view_source]

__init__

def __init__(
    *, readable_dataset: "ReadableDBAPIDataset[SupportsReadableRelation]"
) -> None

[view_source]

Create a lazy evaluated relation to for the dataset of a destination

cursor

@contextmanager
def cursor() -> Generator[SupportsReadableRelation, Any, Any]

[view_source]

Gets a DBApiCursor for the current relation

ReadableDBAPIRelation Objects

class ReadableDBAPIRelation(BaseReadableDBAPIRelation)

[view_source]

__init__

def __init__(
        *,
        readable_dataset: "ReadableDBAPIDataset[SupportsReadableRelation]",
        provided_query: Any = None,
        table_name: str = None,
        limit: int = None,
        selected_columns: Sequence[str] = None) -> None

[view_source]

Create a lazy evaluated relation to for the dataset of a destination

query

def query() -> Any

[view_source]

build the query

compute_columns_schema

def compute_columns_schema() -> TTableSchemaColumns

[view_source]

provide schema columns for the cursor, may be filtered by selected columns