Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/db.py
Show First 20 Lines • Show All 682 Lines • ▼ Show 20 Lines | def _origin_query(self, url_pattern, count=False, offset=0, limit=50, | ||||
else: | else: | ||||
origin_cols = ','.join(self.origin_cols) | origin_cols = ','.join(self.origin_cols) | ||||
query = """SELECT %s | query = """SELECT %s | ||||
FROM origin | FROM origin | ||||
WHERE """ | WHERE """ | ||||
if with_visit: | if with_visit: | ||||
query += """ | query += """ | ||||
EXISTS (SELECT 1 from origin_visit WHERE origin=origin.id) | EXISTS ( | ||||
SELECT 1 | |||||
FROM origin_visit | |||||
INNER JOIN snapshot ON snapshot=snapshot.id | |||||
WHERE origin=origin.id | |||||
) | |||||
AND """ | AND """ | ||||
query += 'url %s %%s ' | query += 'url %s %%s ' | ||||
if not count: | if not count: | ||||
query += 'ORDER BY id OFFSET %%s LIMIT %%s' | query += 'ORDER BY id OFFSET %%s LIMIT %%s' | ||||
if not regexp: | if not regexp: | ||||
query = query % (origin_cols, 'ILIKE') | query = query % (origin_cols, 'ILIKE') | ||||
query_params = ('%'+url_pattern+'%', offset, limit) | query_params = ('%'+url_pattern+'%', offset, limit) | ||||
▲ Show 20 Lines • Show All 178 Lines • Show Last 20 Lines |