Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/postgresql/db.py
| Show First 20 Lines • Show All 893 Lines • ▼ Show 20 Lines | def revision_get_from_list(self, revisions, ignore_displayname=False, cur=None): | ||||
| LEFT JOIN person author ON revision.author = author.id | LEFT JOIN person author ON revision.author = author.id | ||||
| LEFT JOIN person committer ON revision.committer = committer.id | LEFT JOIN person committer ON revision.committer = committer.id | ||||
| ORDER BY sortkey | ORDER BY sortkey | ||||
| """ | """ | ||||
| % query_keys, | % query_keys, | ||||
| ((sortkey, id) for sortkey, id in enumerate(revisions)), | ((sortkey, id) for sortkey, id in enumerate(revisions)), | ||||
| ) | ) | ||||
| extid_cols = ["extid", "extid_version", "extid_type", "target", "target_type"] | extid_cols = [ | ||||
| "extid", | |||||
| "extid_version", | |||||
| "extid_type", | |||||
| "target", | |||||
| "target_type", | |||||
| "payload_type", | |||||
| "payload", | |||||
| ] | |||||
| def extid_get_from_extid_list( | def extid_get_from_extid_list( | ||||
| self, extid_type: str, ids: List[bytes], version: Optional[int] = None, cur=None | self, extid_type: str, ids: List[bytes], version: Optional[int] = None, cur=None | ||||
| ): | ): | ||||
| cur = self._cursor(cur) | cur = self._cursor(cur) | ||||
| query_keys = ", ".join( | query_keys = ", ".join( | ||||
| self.mangle_query_key(k, "extid") for k in self.extid_cols | self.mangle_query_key(k, "extid") for k in self.extid_cols | ||||
| ) | ) | ||||
| ▲ Show 20 Lines • Show All 635 Lines • Show Last 20 Lines | |||||