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_metadata_hash_keys = ['id', 'indexer_configuration_id'] | |||||
| def origin_metadata_missing_from_list(self, metadata, cur=None): | |||||
| """List missing metadata. | |||||
| """ | |||||
| yield from self._missing_from_list( | |||||
| 'origin_metadata', metadata, self.origin_metadata_hash_keys, | |||||
| cur=cur) | |||||
| origin_metadata_cols = [ | |||||
| 'id', 'translated_metadata', | |||||
| 'tool_id', 'tool_name', 'tool_version', 'tool_configuration'] | |||||
| @stored_procedure('swh_mktemp_origin_metadata') | |||||
| def mktemp_origin_metadata(self, cur=None): pass | |||||
| def origin_metadata_add_from_temp(self, conflict_update, cur=None): | |||||
| self._cursor(cur).execute("SELECT swh_origin_metadata_add(%s)", | |||||
| (conflict_update, )) | |||||
| def origin_metadata_get_from_list(self, ids, cur=None): | |||||
| yield from self._get_from_list( | |||||
| 'origin_metadata', ids, self.origin_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 | |||||