Changeset View
Changeset View
Standalone View
Standalone View
swh/indexer/storage/db.py
Show First 20 Lines • Show All 272 Lines • ▼ Show 20 Lines | class Db(BaseDb): | ||||
def revision_metadata_get_from_list(self, ids, cur=None): | def revision_metadata_get_from_list(self, ids, cur=None): | ||||
yield from self._get_from_list( | yield from self._get_from_list( | ||||
'revision_metadata', ids, self.revision_metadata_cols, cur=cur) | 'revision_metadata', ids, self.revision_metadata_cols, cur=cur) | ||||
indexer_configuration_cols = ['id', 'tool_name', 'tool_version', | indexer_configuration_cols = ['id', 'tool_name', 'tool_version', | ||||
'tool_configuration'] | 'tool_configuration'] | ||||
origin_intrinsic_metadata_hash_keys = ['id', 'indexer_configuration_id'] | |||||
def origin_intrinsic_metadata_missing_from_list(self, metadata, cur=None): | |||||
"""List missing metadata. | |||||
""" | |||||
yield from self._missing_from_list( | |||||
'origin_intrinsic_metadata', metadata, | |||||
self.origin_intrinsic_metadata_hash_keys, cur=cur) | |||||
origin_intrinsic_metadata_cols = [ | |||||
'id', 'translated_metadata', | |||||
'tool_id', 'tool_name', 'tool_version', 'tool_configuration'] | |||||
@stored_procedure('swh_mktemp_origin_intrinsic_metadata') | |||||
def mktemp_origin_intrinsic_metadata(self, cur=None): pass | |||||
def origin_intrinsic_metadata_add_from_temp(self, conflict_update, | |||||
cur=None): | |||||
self._cursor(cur).execute( | |||||
"SELECT swh_origin_intrinsic_metadata_add(%s)", | |||||
(conflict_update, )) | |||||
def origin_intrinsic_metadata_get_from_list(self, ids, cur=None): | |||||
yield from self._get_from_list( | |||||
'origin_intrinsic_metadata', ids, | |||||
self.origin_intrinsic_metadata_cols, cur=cur) | |||||
indexer_configuration_cols = ['id', 'tool_name', 'tool_version', | |||||
'tool_configuration'] | |||||
@stored_procedure('swh_mktemp_indexer_configuration') | @stored_procedure('swh_mktemp_indexer_configuration') | ||||
def mktemp_indexer_configuration(self, cur=None): | def mktemp_indexer_configuration(self, cur=None): | ||||
pass | pass | ||||
def indexer_configuration_add_from_temp(self, cur=None): | def indexer_configuration_add_from_temp(self, cur=None): | ||||
cur = self._cursor(cur) | cur = self._cursor(cur) | ||||
cur.execute("SELECT %s from swh_indexer_configuration_add()" % ( | cur.execute("SELECT %s from swh_indexer_configuration_add()" % ( | ||||
','.join(self.indexer_configuration_cols), )) | ','.join(self.indexer_configuration_cols), )) | ||||
Show All 17 Lines |