Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-11 10:04:22 -05:00
Code Issues Packages Projects Releases Wiki Activity

Make SQL a bit cleaner

Browse Source
This commit is contained in:
Erik Johnston 2018-10-29 14:01:11 +00:00
parent 03e634dad4
commit b2399f6281
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
synapse/storage/state.py
View File

@ -1272,14 +1272,13 @@ class StateGroupWorkerStore(EventsWorkerStore, SQLBaseStore):
# Check if state groups are referenced # Check if state groups are referenced
sql = """ sql = """
SELECT state_group, count(*) FROM event_to_state_groups SELECT DISTINCT state_group FROM event_to_state_groups
LEFT JOIN events_to_purge AS ep USING (event_id) LEFT JOIN events_to_purge AS ep USING (event_id)
WHERE state_group IN (%s) AND ep.event_id IS NULL WHERE state_group IN (%s) AND ep.event_id IS NULL
GROUP BY state_group
""" % (",".join("?" for _ in current_search),) """ % (",".join("?" for _ in current_search),)
txn.execute(sql, list(current_search)) txn.execute(sql, list(current_search))
referenced = set(sg for sg, cnt in txn if cnt > 0) referenced = set(sg for sg, in txn)
referenced_groups |= referenced referenced_groups |= referenced
# We don't continue iterating up the state group graphs for state # We don't continue iterating up the state group graphs for state