dandri/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2026-07-31 00:50:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove unnecessary select from _record_profile_updates_for_user_left_room_txn

Browse Source
This commit is contained in:
Jason Robinson
2026-07-15 11:47:52 +03:00
parent 34ce70f6af
commit cbe7c81727
1 changed files with 14 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
synapse/storage/databases/main/profile.py
+14 -23
View File
@@ -1042,30 +1042,21 @@ class ProfileWorkerStore(SQLBaseStore):
users_to_update: The set of users who no longer share rooms with the user.
"""
# First clear the previous rows from the table
txn.execute(
"""
SELECT stream_id FROM profile_updates
WHERE user_id = ?
""",
(user_id.to_string(),),
user_clause, user_args = make_in_list_sql_clause(
txn.database_engine,
"user_id",
users_to_update,
)
txn.execute(
f"""
DELETE FROM profile_updates_per_user
WHERE {user_clause}
AND stream_id IN (
SELECT stream_id FROM profile_updates WHERE user_id = ?
)
""",
(*user_args, user_id.to_string()),
)
res = txn.fetchall()
if res:
user_clause, user_args = make_in_list_sql_clause(
txn.database_engine,
"user_id",
users_to_update,
)
txn.execute(
f"""
DELETE FROM profile_updates_per_user
WHERE {user_clause}
AND stream_id IN (
SELECT stream_id FROM profile_updates WHERE user_id = ?
)
""",
(*user_args, user_id.to_string()),
)
# Now record the "left room" action in the stream
self._record_profile_updates_txn(