diff --git a/unwind/db.py b/unwind/db.py index 968111e..c07b3a9 100644 --- a/unwind/db.py +++ b/unwind/db.py @@ -535,22 +535,6 @@ def sql_fields(tp: Type): return (f"{tp._table}.{f.name}" for f in fields(tp)) -def sql_fieldmap(tp: Type): - """-> {alias: (table, field_name)}""" - return {f"{tp._table}_{f.name}": (tp._table, f.name) for f in fields(tp)} - - -def mux(*tps: Type): - return ", ".join( - f"{t}.{n} AS {k}" for tp in tps for k, (t, n) in sql_fieldmap(tp).items() - ) - - -def demux(tp: Type[ModelType], row) -> ModelType: - d = {n: row[k] for k, (_, n) in sql_fieldmap(tp).items()} - return fromplain(tp, d, serialized=True) - - def sql_in(column: str, values: Iterable[T], not_=False) -> tuple[str, dict[str, T]]: c = column.replace(".", "___") value_map = {f"{c}_{i}": v for i, v in enumerate(values, start=1)}