remote/sqlite-utils
1
0
Fork 0
mirror of https://github.com/simonw/sqlite-utils.git synced 2026-09-19 06:54:25 +02:00
Code Issues Projects Releases Packages Wiki Activity

Fixed remaining broken tests

Browse source
This commit is contained in:
Simon Willison 2025-05-08 19:51:41 -07:00
commit 058a8dfa4c
1 changed files with 19 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

31
sqlite_utils/db.py
View file

@ -3010,19 +3010,26 @@ class Table(Queryable):
extracts = resolve_extracts(extracts) extracts = resolve_extracts(extracts)
# Build a row-list ready for executemany-style flattening # Build a row-list ready for executemany-style flattening
values: list[list] = [] values: List[list] = []
for record in chunk:
row_vals = []
for col in all_columns:
if col == hash_id:
row_vals.append(hash_record(record, hash_id_columns))
continue
val = record.get(col) for record in chunk:
if val is None and not_null and col in not_null: record_values = []
val = "" for key in all_columns:
row_vals.append(jsonify_if_needed(val)) value = jsonify_if_needed(
values.append(row_vals) record.get(
key,
(
None
if key != hash_id
else hash_record(record, hash_id_columns)
),
)
)
if key in extracts:
extract_table = extracts[key]
value = self.db[extract_table].lookup({"value": value})
record_values.append(value)
values.append(record_values)
columns_sql = ", ".join(f"[{c}]" for c in all_columns) columns_sql = ", ".join(f"[{c}]" for c in all_columns)
placeholder_expr = ", ".join(conversions.get(c, "?") for c in all_columns) placeholder_expr = ", ".join(conversions.get(c, "?") for c in all_columns)