sources.sql_database.helpers
SQL database source helpers
unwrap_json_connector_x
def unwrap_json_connector_x(field: str) -> TDataItem
Creates a transform function to be added with add_map
that will unwrap JSON columns
ingested via connectorx. Such columns are additionally quoted and translate SQL NULL to json "null"
remove_nullability_adapter
def remove_nullability_adapter(table: Table) -> Table
A table adapter that removes nullability from columns.
SqlTableResourceConfiguration Objects
@configspec
class SqlTableResourceConfiguration(BaseConfiguration)
incremental
type: ignore[type-arg]