Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/db.py
Show First 20 Lines • Show All 1,018 Lines • ▼ Show 20 Lines | def metadata_provider_add(self, provider_name, provider_type, | ||||
cur.execute(insert, (provider_name, provider_type, provider_url, | cur.execute(insert, (provider_name, provider_type, provider_url, | ||||
jsonize(metadata))) | jsonize(metadata))) | ||||
return cur.fetchone()[0] | return cur.fetchone()[0] | ||||
def metadata_provider_get(self, provider_id, cur=None): | def metadata_provider_get(self, provider_id, cur=None): | ||||
cur = self._cursor(cur) | cur = self._cursor(cur) | ||||
cur.execute('''select %s | cur.execute('''select %s | ||||
from metadata_provider | from metadata_provider | ||||
where provider_id=%%s ''' % ( | where id=%%s ''' % ( | ||||
','.join(self.metadata_provider_cols)), | ','.join(self.metadata_provider_cols)), | ||||
(provider_id, )) | (provider_id, )) | ||||
data = cur.fetchone() | data = cur.fetchone() | ||||
if not data: | if not data: | ||||
return None | return None | ||||
return line_to_bytes(data) | return line_to_bytes(data) | ||||
Show All 14 Lines |