Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/db.py
Show First 20 Lines • Show All 446 Lines • ▼ Show 20 Lines | def origin_visit_get_latest( | ||||
The origin_visit information, or None if no visit matches. | The origin_visit information, or None if no visit matches. | ||||
""" | """ | ||||
cur = self._cursor(cur) | cur = self._cursor(cur) | ||||
query_parts = [ | query_parts = [ | ||||
'SELECT %s' % ', '.join(self.origin_visit_get_cols), | 'SELECT %s' % ', '.join(self.origin_visit_get_cols), | ||||
'FROM origin_visit'] | 'FROM origin_visit'] | ||||
if require_snapshot: | |||||
# Makes sure the snapshot is known | |||||
query_parts.append( | |||||
'INNER JOIN snapshot ON (origin_visit.snapshot=snapshot.id)') | |||||
query_parts.append('WHERE origin = %s') | query_parts.append('WHERE origin = %s') | ||||
if require_snapshot: | if require_snapshot: | ||||
query_parts.append('AND snapshot is not null') | query_parts.append('AND snapshot is not null') | ||||
if allowed_statuses: | if allowed_statuses: | ||||
query_parts.append( | query_parts.append( | ||||
cur.mogrify('AND status IN %s', | cur.mogrify('AND status IN %s', | ||||
▲ Show 20 Lines • Show All 460 Lines • Show Last 20 Lines |