Merge pull request #5713 from matrix-org/erikj/use_cache_for_filtered_state
Delegate to cached version when using get_filtered_current_state_idspull/5725/head
commit
d7bd9651bc
|
@ -0,0 +1 @@
|
||||||
|
Improve caching when fetching `get_filtered_current_state_ids`.
|
|
@ -510,6 +510,12 @@ class StateGroupWorkerStore(EventsWorkerStore, SQLBaseStore):
|
||||||
event ID.
|
event ID.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
|
where_clause, where_args = state_filter.make_sql_filter_clause()
|
||||||
|
|
||||||
|
if not where_clause:
|
||||||
|
# We delegate to the cached version
|
||||||
|
return self.get_current_state_ids(room_id)
|
||||||
|
|
||||||
def _get_filtered_current_state_ids_txn(txn):
|
def _get_filtered_current_state_ids_txn(txn):
|
||||||
results = {}
|
results = {}
|
||||||
sql = """
|
sql = """
|
||||||
|
@ -517,8 +523,6 @@ class StateGroupWorkerStore(EventsWorkerStore, SQLBaseStore):
|
||||||
WHERE room_id = ?
|
WHERE room_id = ?
|
||||||
"""
|
"""
|
||||||
|
|
||||||
where_clause, where_args = state_filter.make_sql_filter_clause()
|
|
||||||
|
|
||||||
if where_clause:
|
if where_clause:
|
||||||
sql += " AND (%s)" % (where_clause,)
|
sql += " AND (%s)" % (where_clause,)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue