Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/db.py
Show First 20 Lines • Show All 1,115 Lines • ▼ Show 20 Lines | |||||
"""List of columns of the object_metadata table, used when writing | """List of columns of the object_metadata table, used when writing | ||||
metadata.""" | metadata.""" | ||||
_object_metadata_insert_query = f""" | _object_metadata_insert_query = f""" | ||||
INSERT INTO object_metadata | INSERT INTO object_metadata | ||||
({', '.join(_object_metadata_insert_cols)}) | ({', '.join(_object_metadata_insert_cols)}) | ||||
VALUES ({', '.join('%s' for _ in _object_metadata_insert_cols)}) | VALUES ({', '.join('%s' for _ in _object_metadata_insert_cols)}) | ||||
ON CONFLICT (id, authority_id, discovery_date, fetcher_id) | ON CONFLICT (id, authority_id, discovery_date, fetcher_id) | ||||
DO UPDATE SET | DO NOTHING | ||||
format=EXCLUDED.format, | |||||
metadata=EXCLUDED.metadata | |||||
""" | """ | ||||
object_metadata_get_cols = [ | object_metadata_get_cols = [ | ||||
"id", | "id", | ||||
"discovery_date", | "discovery_date", | ||||
"metadata_authority.type", | "metadata_authority.type", | ||||
"metadata_authority.url", | "metadata_authority.url", | ||||
"metadata_fetcher.id", | "metadata_fetcher.id", | ||||
▲ Show 20 Lines • Show All 166 Lines • Show Last 20 Lines |