Skip to content
This repository has been archived by the owner on Apr 26, 2024. It is now read-only.

Commit

Permalink
Add another index to device_lists_changes_in_room (#14534)
Browse files Browse the repository at this point in the history
This helps avoid reading unnecessarily large amounts of data from the
table when querying with a set of room IDs.
  • Loading branch information
erikjohnston authored and H-Shay committed Dec 13, 2022
1 parent 58fedf5 commit a494e0b
Show file tree
Hide file tree
Showing 3 changed files with 28 additions and 0 deletions.
1 change: 1 addition & 0 deletions changelog.d/14534.misc
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
Improve DB performance by reducing amount of data that gets read in `device_lists_changes_in_room`.
7 changes: 7 additions & 0 deletions synapse/storage/databases/main/devices.py
Original file line number Diff line number Diff line change
Expand Up @@ -1441,6 +1441,13 @@ def __init__(
self._remove_duplicate_outbound_pokes,
)

self.db_pool.updates.register_background_index_update(
"device_lists_changes_in_room_by_room_index",
index_name="device_lists_changes_in_room_by_room_idx",
table="device_lists_changes_in_room",
columns=["room_id", "stream_id"],
)

async def _drop_device_list_streams_non_unique_indexes(
self, progress: JsonDict, batch_size: int
) -> int:
Expand Down
20 changes: 20 additions & 0 deletions synapse/storage/schema/main/delta/73/13add_device_lists_index.sql
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
/* Copyright 2022 The Matrix.org Foundation C.I.C
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/


-- Adds an index on `device_lists_changes_in_room (room_id, stream_id)`, which
-- speeds up `/sync` queries.
INSERT INTO background_updates (ordering, update_name, progress_json) VALUES
(7313, 'device_lists_changes_in_room_by_room_index', '{}');

0 comments on commit a494e0b

Please sign in to comment.