diff options
author | Erik Johnston <erik@matrix.org> | 2017-07-20 10:47:01 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2017-07-20 10:47:01 +0100 |
commit | d7d24750be64913a10335603f7a48dbba10e51b0 (patch) | |
tree | 0d46aaaa6dce33a8a6d9ee82ad49315b8772ad0c /scripts | |
parent | Merge pull request #2371 from matrix-org/erikj/push_cache_hit (diff) | |
download | synapse-d7d24750be64913a10335603f7a48dbba10e51b0.tar.xz |
Fix port script for user directory tables
Diffstat (limited to 'scripts')
-rwxr-xr-x | scripts/synapse_port_db | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/scripts/synapse_port_db b/scripts/synapse_port_db index 7d158a46a4..8da8a3b1d2 100755 --- a/scripts/synapse_port_db +++ b/scripts/synapse_port_db @@ -252,6 +252,24 @@ class Porter(object): ) return + if table in ( + "user_directory", "user_directory_search", "users_who_share_rooms", + "users_in_pubic_room", + ): + # We don't port these tables, as they're a faff and we can regenreate + # them anyway. + self.progress.update(table, table_size) # Mark table as done + return + + if table == "user_directory_stream_pos": + # We need to make sure there is a single row, `(X, null)` + yield self.postgres_store._simple_insert( + table=table, + values={"stream_id": None}, + ) + self.progress.update(table, table_size) # Mark table as done + return + forward_select = ( "SELECT rowid, * FROM %s WHERE rowid >= ? ORDER BY rowid LIMIT ?" % (table,) |