Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/db.py
Show First 20 Lines • Show All 1,182 Lines • ▼ Show 20 Lines | _raw_extrinsic_metadata_select_query = f""" | ||||
INNER JOIN metadata_authority | INNER JOIN metadata_authority | ||||
ON (metadata_authority.id=authority_id) | ON (metadata_authority.id=authority_id) | ||||
INNER JOIN metadata_fetcher ON (metadata_fetcher.id=fetcher_id) | INNER JOIN metadata_fetcher ON (metadata_fetcher.id=fetcher_id) | ||||
WHERE raw_extrinsic_metadata.id=%s AND authority_id=%s | WHERE raw_extrinsic_metadata.id=%s AND authority_id=%s | ||||
""" | """ | ||||
def raw_extrinsic_metadata_add( | def raw_extrinsic_metadata_add( | ||||
self, | self, | ||||
object_type: str, | type: str, | ||||
id: str, | id: str, | ||||
discovery_date: datetime.datetime, | discovery_date: datetime.datetime, | ||||
authority_id: int, | authority_id: int, | ||||
fetcher_id: int, | fetcher_id: int, | ||||
format: str, | format: str, | ||||
metadata: bytes, | metadata: bytes, | ||||
origin: Optional[str], | origin: Optional[str], | ||||
visit: Optional[int], | visit: Optional[int], | ||||
snapshot: Optional[str], | snapshot: Optional[str], | ||||
release: Optional[str], | release: Optional[str], | ||||
revision: Optional[str], | revision: Optional[str], | ||||
path: Optional[bytes], | path: Optional[bytes], | ||||
directory: Optional[str], | directory: Optional[str], | ||||
cur, | cur, | ||||
): | ): | ||||
query = self._raw_extrinsic_metadata_insert_query | query = self._raw_extrinsic_metadata_insert_query | ||||
args: Dict[str, Any] = dict( | args: Dict[str, Any] = dict( | ||||
type=object_type, | type=type, | ||||
id=id, | id=id, | ||||
authority_id=authority_id, | authority_id=authority_id, | ||||
fetcher_id=fetcher_id, | fetcher_id=fetcher_id, | ||||
discovery_date=discovery_date, | discovery_date=discovery_date, | ||||
format=format, | format=format, | ||||
metadata=metadata, | metadata=metadata, | ||||
origin=origin, | origin=origin, | ||||
visit=visit, | visit=visit, | ||||
snapshot=snapshot, | snapshot=snapshot, | ||||
release=release, | release=release, | ||||
revision=revision, | revision=revision, | ||||
path=path, | path=path, | ||||
directory=directory, | directory=directory, | ||||
) | ) | ||||
params = [args[col] for col in self._raw_extrinsic_metadata_insert_cols] | params = [args[col] for col in self._raw_extrinsic_metadata_insert_cols] | ||||
cur.execute(query, params) | cur.execute(query, params) | ||||
def raw_extrinsic_metadata_get( | def raw_extrinsic_metadata_get( | ||||
self, | self, | ||||
object_type: str, | type: str, | ||||
id: str, | id: str, | ||||
authority_id: int, | authority_id: int, | ||||
after_time: Optional[datetime.datetime], | after_time: Optional[datetime.datetime], | ||||
after_fetcher: Optional[int], | after_fetcher: Optional[int], | ||||
limit: int, | limit: int, | ||||
cur, | cur, | ||||
): | ): | ||||
query_parts = [self._raw_extrinsic_metadata_select_query] | query_parts = [self._raw_extrinsic_metadata_select_query] | ||||
▲ Show 20 Lines • Show All 105 Lines • Show Last 20 Lines |