destinations.dataset.relation

BaseReadableDBAPIRelation Objects

class BaseReadableDBAPIRelation(SupportsReadableRelation)

[view_source]

__init__

def __init__(*, readable_dataset: "ReadableDBAPIDataset") -> 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",
             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

@property
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