Changeset View
Changeset View
Standalone View
Standalone View
swh/indexer/storage/db.py
| Show First 20 Lines • Show All 344 Lines • ▼ Show 20 Lines | def content_metadata_add_from_temp(self, cur=None): | ||||
| cur.execute("select * from swh_content_metadata_add()") | cur.execute("select * from swh_content_metadata_add()") | ||||
| return cur.fetchone()[0] | return cur.fetchone()[0] | ||||
| def content_metadata_get_from_list(self, ids, cur=None): | def content_metadata_get_from_list(self, ids, cur=None): | ||||
| yield from self._get_from_list( | yield from self._get_from_list( | ||||
| "content_metadata", ids, self.content_metadata_cols, cur=cur | "content_metadata", ids, self.content_metadata_cols, cur=cur | ||||
| ) | ) | ||||
| revision_intrinsic_metadata_hash_keys = ["id", "indexer_configuration_id"] | directory_intrinsic_metadata_hash_keys = ["id", "indexer_configuration_id"] | ||||
| def revision_intrinsic_metadata_missing_from_list(self, metadata, cur=None): | def directory_intrinsic_metadata_missing_from_list(self, metadata, cur=None): | ||||
| """List missing metadata.""" | """List missing metadata.""" | ||||
| yield from self._missing_from_list( | yield from self._missing_from_list( | ||||
| "revision_intrinsic_metadata", | "directory_intrinsic_metadata", | ||||
| metadata, | metadata, | ||||
| self.revision_intrinsic_metadata_hash_keys, | self.directory_intrinsic_metadata_hash_keys, | ||||
| cur=cur, | cur=cur, | ||||
| ) | ) | ||||
| revision_intrinsic_metadata_cols = [ | directory_intrinsic_metadata_cols = [ | ||||
| "id", | "id", | ||||
| "metadata", | "metadata", | ||||
| "mappings", | "mappings", | ||||
| "tool_id", | "tool_id", | ||||
| "tool_name", | "tool_name", | ||||
| "tool_version", | "tool_version", | ||||
| "tool_configuration", | "tool_configuration", | ||||
| ] | ] | ||||
| @stored_procedure("swh_mktemp_revision_intrinsic_metadata") | @stored_procedure("swh_mktemp_directory_intrinsic_metadata") | ||||
| def mktemp_revision_intrinsic_metadata(self, cur=None): | def mktemp_directory_intrinsic_metadata(self, cur=None): | ||||
| pass | pass | ||||
| def revision_intrinsic_metadata_add_from_temp(self, cur=None): | def directory_intrinsic_metadata_add_from_temp(self, cur=None): | ||||
| cur = self._cursor(cur) | cur = self._cursor(cur) | ||||
| cur.execute("select * from swh_revision_intrinsic_metadata_add()") | cur.execute("select * from swh_directory_intrinsic_metadata_add()") | ||||
| return cur.fetchone()[0] | return cur.fetchone()[0] | ||||
| def revision_intrinsic_metadata_get_from_list(self, ids, cur=None): | def directory_intrinsic_metadata_get_from_list(self, ids, cur=None): | ||||
| yield from self._get_from_list( | yield from self._get_from_list( | ||||
| "revision_intrinsic_metadata", | "directory_intrinsic_metadata", | ||||
| ids, | ids, | ||||
| self.revision_intrinsic_metadata_cols, | self.directory_intrinsic_metadata_cols, | ||||
| cur=cur, | cur=cur, | ||||
| ) | ) | ||||
| origin_intrinsic_metadata_cols = [ | origin_intrinsic_metadata_cols = [ | ||||
| "id", | "id", | ||||
| "metadata", | "metadata", | ||||
| "from_revision", | "from_directory", | ||||
| "mappings", | "mappings", | ||||
| "tool_id", | "tool_id", | ||||
| "tool_name", | "tool_name", | ||||
| "tool_version", | "tool_version", | ||||
| "tool_configuration", | "tool_configuration", | ||||
| ] | ] | ||||
| origin_intrinsic_metadata_regconfig = "pg_catalog.simple" | origin_intrinsic_metadata_regconfig = "pg_catalog.simple" | ||||
| ▲ Show 20 Lines • Show All 133 Lines • Show Last 20 Lines | |||||