dandri/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2026-06-04 21:11:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use a "many" insert for add_profile_updates

Browse Source
This commit is contained in:
Jason Robinson
2026-06-01 12:19:05 +03:00
parent 3444aef480
commit 4c2bbbce20
1 changed files with 23 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
synapse/storage/databases/main/profile.py
+23 -10
View File
@@ -477,19 +477,32 @@ class ProfileWorkerStore(SQLBaseStore):
stream_ids = self._profile_updates_id_gen.get_next_mult_txn(
txn, len(updated_fields)
)
values = []
inserted_ts = self.clock.time_msec()
for stream_id, field_name in zip(stream_ids, updated_fields):
self.db_pool.simple_insert_txn(
txn,
table="profile_updates",
values={
"stream_id": stream_id,
"instance_name": self._instance_name,
"user_id": user_id_str,
"field_name": field_name,
"inserted_ts": self.clock.time_msec(),
},
values.append(
[
stream_id,
self._instance_name,
user_id_str,
field_name,
inserted_ts,
]
)
self.db_pool.simple_insert_many_txn(
txn,
table="profile_updates",
keys=[
"stream_id",
"instance_name",
"user_id",
"field_name",
"inserted_ts",
],
values=values,
)
return stream_ids[-1]
return await self.db_pool.runInteraction(