Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2025-03-12 19:16:31 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add LIMIT to scalar subquery

Browse Source
This commit is contained in:
Erik Johnston 2014-09-25 15:51:21 +01:00
parent 24e4c48468
commit c818aa13eb
3 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
synapse/storage/__init__.py
View File

@ -255,7 +255,8 @@ class DataStore(RoomMemberStore, RoomStore,
@defer.inlineCallbacks @defer.inlineCallbacks
def get_current_state(self, room_id, event_type=None, state_key=""): def get_current_state(self, room_id, event_type=None, state_key=""):
del_sql = ( del_sql = (
"SELECT event_id FROM redactions WHERE redacts = e.event_id" "SELECT event_id FROM redactions WHERE redacts = e.event_id "
"LIMIT 1"
) )
sql = ( sql = (

3
synapse/storage/roommember.py
View File

@ -183,7 +183,8 @@ class RoomMemberStore(SQLBaseStore):
def _get_members_query_txn(self, txn, where_clause, where_values): def _get_members_query_txn(self, txn, where_clause, where_values):
del_sql = ( del_sql = (
"SELECT event_id FROM redactions WHERE redacts = e.event_id" "SELECT event_id FROM redactions WHERE redacts = e.event_id "
"LIMIT 1"
) )
sql = ( sql = (

9
synapse/storage/stream.py
View File

@ -158,7 +158,8 @@ class StreamStore(SQLBaseStore):
) )
del_sql = ( del_sql = (
"SELECT event_id FROM redactions WHERE redacts = e.event_id" "SELECT event_id FROM redactions WHERE redacts = e.event_id "
"LIMIT 1"
) )
if limit: if limit:
@ -230,7 +231,8 @@ class StreamStore(SQLBaseStore):
limit_str = "" limit_str = ""
del_sql = ( del_sql = (
"SELECT event_id FROM redactions WHERE redacts = events.event_id" "SELECT event_id FROM redactions WHERE redacts = events.event_id "
"LIMIT 1"
) )
sql = ( sql = (
@ -272,7 +274,8 @@ class StreamStore(SQLBaseStore):
# TODO (erikj): Handle compressed feedback # TODO (erikj): Handle compressed feedback
del_sql = ( del_sql = (
"SELECT event_id FROM redactions WHERE redacts = events.event_id" "SELECT event_id FROM redactions WHERE redacts = events.event_id "
"LIMIT 1"
) )
sql = ( sql = (