Mirrors
/
synapse
mirror of https://github.com/element-hq/synapse.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

pep8

This commit is contained in:
Matthew Hodgson 2018-04-28 22:32:24 +01:00
parent 42c89c8215
commit 006e18b6bb
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
synapse/storage/schema/delta/48/group_unique_indexes.py
View File

@ -32,23 +32,25 @@ DROP INDEX groups_rooms_r_idx;
CREATE INDEX group_rooms_r_idx ON group_rooms(room_id); CREATE INDEX group_rooms_r_idx ON group_rooms(room_id);
""" """
def run_create(cur, database_engine, *args, **kwargs): def run_create(cur, database_engine, *args, **kwargs):
rowid = "ctid" if isinstance(database_engine, PostgresEngine) then "rowid" rowid = "ctid" if isinstance(database_engine, PostgresEngine) else "rowid"
# remove duplicates from group_users & group_invites tables # remove duplicates from group_users & group_invites tables
cur.execute(""" cur.execute("""
DELETE FROM group_users WHERE %s NOT IN ( DELETE FROM group_users WHERE %s NOT IN (
SELECT min(%s) FROM group_users GROUP BY group_id, user_id SELECT min(%s) FROM group_users GROUP BY group_id, user_id
); );
""" % (rowid, rowid)); """ % (rowid, rowid))
cur.execute(""" cur.execute("""
DELETE FROM group_invites WHERE %s NOT IN ( DELETE FROM group_invites WHERE %s NOT IN (
SELECT min(%s) FROM group_invites GROUP BY group_id, user_id SELECT min(%s) FROM group_invites GROUP BY group_id, user_id
); );
""" % (rowid, rowid)); """ % (rowid, rowid))
for statement in get_statements(FIX_INDEXES.splitlines()): for statement in get_statements(FIX_INDEXES.splitlines()):
cur.execute(statement) cur.execute(statement)
def run_upgrade(*args, **kwargs): def run_upgrade(*args, **kwargs):
pass pass