diff options
author | Erik Johnston <erik@matrix.org> | 2015-03-04 12:04:19 +0000 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2015-03-04 12:04:19 +0000 |
commit | 82b34e813de4dadb8ec5bce068f7113e32e60ead (patch) | |
tree | 882f9d407ff6afe56e57d9f3e0cf701b658581c6 /scripts | |
parent | SYN-67: Begin changing the way we handle schema versioning (diff) | |
download | synapse-82b34e813de4dadb8ec5bce068f7113e32e60ead.tar.xz |
SYN-67: Finish up implementing new database schema management
Diffstat (limited to 'scripts')
-rw-r--r-- | scripts/upgrade_appservice_db.py | 54 |
1 files changed, 0 insertions, 54 deletions
diff --git a/scripts/upgrade_appservice_db.py b/scripts/upgrade_appservice_db.py deleted file mode 100644 index ae1b91c64f..0000000000 --- a/scripts/upgrade_appservice_db.py +++ /dev/null @@ -1,54 +0,0 @@ -from synapse.storage import read_schema -import argparse -import json -import sqlite3 - - -def do_other_deltas(cursor): - cursor.execute("PRAGMA user_version") - row = cursor.fetchone() - - if row and row[0]: - user_version = row[0] - # Run every version since after the current version. - for v in range(user_version + 1, 10): - print "Running delta: %d" % (v,) - sql_script = read_schema("delta/v%d" % (v,)) - cursor.executescript(sql_script) - - -def update_app_service_table(cur): - cur.execute("SELECT id, regex FROM application_services_regex") - for row in cur.fetchall(): - try: - print "checking %s..." % row[0] - json.loads(row[1]) - except ValueError: - # row isn't in json, make it so. - string_regex = row[1] - new_regex = json.dumps({ - "regex": string_regex, - "exclusive": True - }) - cur.execute( - "UPDATE application_services_regex SET regex=? WHERE id=?", - (new_regex, row[0]) - ) - - -def main(dbname): - con = sqlite3.connect(dbname) - cur = con.cursor() - do_other_deltas(cur) - update_app_service_table(cur) - cur.execute("PRAGMA user_version = 14") - cur.close() - con.commit() - - -if __name__ == "__main__": - parser = argparse.ArgumentParser() - parser.add_argument("database") - args = parser.parse_args() - - main(args.database) |