Skip to content

Commit

Permalink
refactor: Added a class method to instantiate JSONSchemaToSQL from …
Browse files Browse the repository at this point in the history
…the tap configuration
  • Loading branch information
edgarrmondragon committed Nov 28, 2024
1 parent 3ad4615 commit bc026c7
Show file tree
Hide file tree
Showing 2 changed files with 41 additions and 4 deletions.
4 changes: 2 additions & 2 deletions docs/guides/sql-target.md
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ def custom_array_to_sql(jsonschema: dict) -> VectorType | sa.types.VARCHAR:
class MyConnector(SQLConnector):
@functools.cached_property
def jsonschema_to_sql(self):
to_sql = JSONSchemaToSQL()
to_sql = JSONSchemaToSQL.from_config(self.config)
to_sql.register_type_handler("array", custom_array_to_sql)
return to_sql
```
Expand All @@ -46,7 +46,7 @@ from my_sqlalchemy_dialect import URI
class MyConnector(SQLConnector):
@functools.cached_property
def jsonschema_to_sql(self):
to_sql = JSONSchemaToSQL()
to_sql = JSONSchemaToSQL.from_config(self.config)
to_sql.register_format_handler("uri", URI)
return to_sql
```
41 changes: 39 additions & 2 deletions singer_sdk/connectors/sql.py
Original file line number Diff line number Diff line change
Expand Up @@ -240,7 +240,7 @@ class JSONSchemaToSQL:
.. versionadded:: 0.42.0
"""

def __init__(self, *, max_varchar_length: int | None = None) -> None:
def __init__(self, *, max_varchar_length: int | None) -> None:

Check warning on line 243 in singer_sdk/connectors/sql.py

View workflow job for this annotation

GitHub Actions / Check API Changes

JSONSchemaToSQL.__init__(max_varchar_length)

Parameter is now required: `` -> ``
"""Initialize the mapper with default type mappings.
Args:
Expand Down Expand Up @@ -276,6 +276,35 @@ def __init__(self, *, max_varchar_length: int | None = None) -> None:

self._fallback_type: type[sa.types.TypeEngine] = sa.types.VARCHAR

@classmethod
def from_config(
cls: type[JSONSchemaToSQL],
config: dict, # noqa: ARG003
*,
max_varchar_length: int | None,
) -> JSONSchemaToSQL:
"""Create a new instance from a configuration dictionary.
Override this to instantiate this converter with values from the target's
configuration dictionary.
.. code-block:: python
class CustomJSONSchemaToSQL(JSONSchemaToSQL):
@classmethod
def from_config(cls, config, **kwargs):
return cls(max_varchar_length=config.get("max_varchar_length"))
Args:
config: The configuration dictionary.
max_varchar_length: The absolute maximum length for VARCHAR columns that
the database supports.
Returns:
A new instance of the class.
"""
return cls(max_varchar_length=max_varchar_length)

def _invoke_handler( # noqa: PLR6301
self,
handler: JSONtoSQLHandler,
Expand Down Expand Up @@ -487,6 +516,11 @@ class SQLConnector: # noqa: PLR0904
#: a custom mapping for your SQL dialect.
sql_to_jsonschema_converter: type[SQLToJSONSchema] = SQLToJSONSchema

#: The JSON-to-SQL type mapper class for this SQL connector. Override this property
#: with a subclass of :class:`~singer_sdk.connectors.sql.JSONSchemaToSQL` to provide
#: a custom mapping for your SQL dialect.
jsonschema_to_sql_converter: type[JSONSchemaToSQL] = JSONSchemaToSQL

def __init__(
self,
config: dict | None = None,
Expand Down Expand Up @@ -537,7 +571,10 @@ def jsonschema_to_sql(self) -> JSONSchemaToSQL:
.. versionadded:: 0.42.0
"""
return JSONSchemaToSQL(max_varchar_length=self.max_varchar_length)
return self.jsonschema_to_sql_converter.from_config(
self.config,
max_varchar_length=self.max_varchar_length,
)

@contextmanager
def _connect(self) -> t.Iterator[sa.engine.Connection]:
Expand Down

0 comments on commit bc026c7

Please sign in to comment.