Fix miscellaneous issues

Author: hunyadi

pyproject.toml

@@ -33,8 +33,8 @@ classifiers = [
  "Typing :: Typed"
 ]
 dependencies = [
- "json_strong_typing >= 0.4.1",
- "certifi >= 2025.10.5; python_version<'3.10'",
+ "json_strong_typing >= 0.4.2",
+ "certifi >= 2025.11.12; python_version<'3.10'",
  "truststore >= 0.10; python_version>='3.10'",
  "typing_extensions >= 4.15; python_version < '3.12'"
 ]

pysqlsync/base.py

@@ -28,6 +28,7 @@
 from .model.data_types import SqlJsonType, SqlVariableCharacterType
 from .model.id_types import LocalId, QualifiedId, SupportsQualifiedId
 from .python_types import dataclass_to_code, module_to_code
+from .util.typing import override
 
 D = TypeVar("D", bound=DataclassInstance)
 E = TypeVar("E", bound=enum.Enum)
@@ -515,6 +516,12 @@ async def close(self) -> None: ...
 
 
 class RecordTransformer:
+ @abc.abstractmethod
+ def is_identity(self) -> bool:
+ "True if the transformer does nothing."
+
+ ...
+
  @abc.abstractmethod
  async def get(self, records: Iterable[RecordType]) -> Optional[Callable[[Any], Any]]:
  """
@@ -537,6 +544,10 @@ def __init__(
  ) -> None:
  self.fn = fn
 
+ @override
+ def is_identity(self) -> bool:
+ return self.fn is None
+
  async def get(self, records: Iterable[RecordType]) -> Optional[Callable[[Any], Any]]:
  return self.fn
 
@@ -559,6 +570,10 @@ def __init__(
  self.generator = generator
  self.index = index
 
+ @override
+ def is_identity(self) -> bool:
+ return False
+
  async def _merge_lookup_table(self, values: set[str]) -> dict[str, int]:
  "Merges new values into a lookup table and returns the entire updated table."
 
@@ -747,7 +762,7 @@ def to_data_source(records: RecordSource) -> DataSource:
 
  if isinstance(records, Iterable):
  return IterableDataSource(records)
- elif isinstance(records, AsyncIterable):
+ elif isinstance(records, AsyncIterable): # pyright: ignore[reportUnnecessaryIsInstance]
  return AsyncIterableDataSource(records)
  else:
  raise TypeError("expected: `Iterable` or `AsyncIterable` of records")
@@ -1084,7 +1099,7 @@ async def _generate_records(
  transformer = self._get_transformer(table, generator, index, field_type, field_name)
  transformers.append(transformer)
 
- if all(transformer is None for transformer in transformers):
+ if all(transformer.is_identity() for transformer in transformers):
  if len(indices) == len(field_types):
  return source
  else:
@@ -1194,7 +1209,7 @@ def _module_or_list(module: Optional[types.ModuleType], modules: Optional[list[t
  raise TypeError("disallowed: both parameters `module` and `modules`")
 
  if modules is not None:
- if not isinstance(modules, list):
+ if not isinstance(modules, list): # pyright: ignore[reportUnnecessaryIsInstance]
  raise TypeError("expected: list of modules for parameter `modules`")
  entity_modules = modules
  elif module is not None:

pysqlsync/connection.py

@@ -45,7 +45,7 @@ class ConnectionSSLMode(enum.Enum):
 def create_context(ssl_mode: ConnectionSSLMode) -> Optional[ssl.SSLContext]:
  "Creates an SSL context to pass to a database connection object."
 
- if ssl_mode is None or ssl_mode is ConnectionSSLMode.disable:
+ if ssl_mode is ConnectionSSLMode.disable:
  return None
  elif ssl_mode is ConnectionSSLMode.prefer or ssl_mode is ConnectionSSLMode.allow or ssl_mode is ConnectionSSLMode.require:
  ctx = ssl.create_default_context(ssl.Purpose.SERVER_AUTH)

pysqlsync/formation/object_types.py

@@ -21,7 +21,7 @@ class StatementList(list[str]):
  def append(self, __object: Optional[str]) -> None:
  if __object is None:
  return
- if isinstance(__object, str) and not __object.strip():
+ if isinstance(__object, str) and not __object.strip(): # pyright: ignore[reportUnnecessaryIsInstance]
  raise ValueError("empty statement")
  return super().append(__object)
 

pysqlsync/formation/py_to_sql.py

@@ -285,7 +285,7 @@ class DataclassConverterOptions:
  foreign_constraints: bool = True
  check_constraints: bool = True
  initialize_tables: bool = False
- substitutions: dict[TypeLike, SqlDataType] = dataclasses.field(default_factory=dict)
+ substitutions: dict[TypeLike, SqlDataType] = dataclasses.field(default_factory=dict[TypeLike, SqlDataType])
  factory: ObjectFactory = dataclasses.field(default_factory=ObjectFactory)
  skip_annotations: tuple[type, ...] = ()
  auto_default: bool = False
@@ -667,7 +667,7 @@ def dataclass_to_table(self, cls: type[DataclassInstance]) -> Table:
  raise TypeError(f"error processing data-class: {cls}") from e
 
  # foreign/primary key constraints
- constraints = []
+ constraints: list[Constraint] = []
  if self.options.foreign_constraints:
  constraints.extend(self.dataclass_to_constraints(cls))
 

pysqlsync/resultset.py

@@ -41,7 +41,7 @@ def resultset_unwrap_object(signature: type[D], records: Iterable[Any]) -> list[
  if not is_dataclass_type(signature):
  raise TypeError(f"expected: data-class type as result-set signature; got: {signature}")
 
- names = [name for name in signature.__dataclass_fields__.keys()]
+ names = [name for name in signature.__dataclass_fields__.keys()] # pyright: ignore[reportUnknownMemberType]
  return [signature(**{name: record.__getattribute__(name) for name in names}) for record in records]
 
 

requirements-dev.txt

@@ -1,9 +1,9 @@
 # core
-json_strong_typing >= 0.4.1
+json_strong_typing >= 0.4.2
 typing_extensions >= 4.15; python_version<"3.12"
 
 # certificate stores
-certifi >= 2025.10.5; python_version<"3.10"
+certifi >= 2025.11.12; python_version<"3.10"
 truststore >= 0.10; python_version>="3.10"
 
 # data export/import