|
|
|
@ -72,7 +72,6 @@ class StreamStore(SQLBaseStore): |
|
|
|
|
"messages", query, query_args, from_pkey, to_pkey, limit=limit |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
logger.debug("[SQL] %s : %s", query, query_args) |
|
|
|
|
cursor = txn.execute(query, query_args) |
|
|
|
|
return self._as_events(cursor, MessagesTable, from_pkey) |
|
|
|
|
|
|
|
|
@ -110,7 +109,6 @@ class StreamStore(SQLBaseStore): |
|
|
|
|
limit=limit, group_by=" GROUP BY messages.id " |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
logger.debug("[SQL] %s : %s", query, query_args) |
|
|
|
|
cursor = txn.execute(query, query_args) |
|
|
|
|
|
|
|
|
|
# convert the result set into events |
|
|
|
@ -195,7 +193,6 @@ class StreamStore(SQLBaseStore): |
|
|
|
|
"feedback", query, query_args, from_pkey, to_pkey, limit=limit |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
logger.debug("[SQL] %s : %s", query, query_args) |
|
|
|
|
cursor = txn.execute(query, query_args) |
|
|
|
|
return self._as_events(cursor, FeedbackTable, from_pkey) |
|
|
|
|
|
|
|
|
@ -227,7 +224,6 @@ class StreamStore(SQLBaseStore): |
|
|
|
|
"room_data", query, query_args, from_pkey, to_pkey, limit=limit |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
logger.debug("[SQL] %s : %s", query, query_args) |
|
|
|
|
cursor = txn.execute(query, query_args) |
|
|
|
|
return self._as_events(cursor, RoomDataTable, from_pkey) |
|
|
|
|
|
|
|
|
|