destinations.sql_client

SqlClientBase Objects

class SqlClientBase(ABC, Generic[TNativeConn])

[view_source]

execute_fragments

def execute_fragments(fragments: Sequence[AnyStr], *args: Any,
                      **kwargs: Any) -> Optional[Sequence[Sequence[Any]]]

[view_source]

Executes several SQL fragments as efficiently as possible to prevent data copying. Default implementation just joins the strings and executes them together.

execute_many

def execute_many(statements: Sequence[str], *args: Any,
                 **kwargs: Any) -> Optional[Sequence[Sequence[Any]]]

[view_source]

Executes multiple SQL statements as efficiently as possible. When client supports multiple statements in a single query they are executed together in as few database calls as possible.

with_alternative_dataset_name

@contextmanager
def with_alternative_dataset_name(
        dataset_name: str) -> Iterator["SqlClientBase[TNativeConn]"]

[view_source]

Sets the dataset_name as the default dataset during the lifetime of the context. Does not modify any search paths in the existing connection.

DBApiCursorImpl Objects

class DBApiCursorImpl(DBApiCursor)

[view_source]

A DBApi Cursor wrapper with dataframes reading functionality