| def migrate_up(manager): |
| manager.execute_script(CLEAN_DATABASE) |
| manager.execute(ADD_HOST_QUEUE_DELETED_COLUMN) |
| manager.execute(DROP_DEFAULT) |
| |
| def migrate_down(manager): |
| manager.execute(DROP_HOST_QUEUE_DELETED_COLUMN) |
| |
| CLEAN_DATABASE = """DELETE FROM acl_groups_hosts |
| WHERE host_id IN |
| (SELECT id FROM hosts WHERE invalid = TRUE); |
| |
| DELETE FROM ineligible_host_queues |
| WHERE host_id IN |
| (SELECT id FROM hosts WHERE invalid = TRUE); |
| |
| UPDATE host_queue_entries |
| SET status = 'Abort' |
| WHERE host_id IN |
| (SELECT id FROM hosts WHERE invalid = TRUE) |
| AND active = TRUE; |
| |
| UPDATE host_queue_entries |
| SET status = 'Aborted', complete = TRUE |
| WHERE host_id IN |
| (SELECT id FROM hosts WHERE invalid = TRUE) |
| AND active = FALSE AND complete = FALSE; |
| |
| DELETE FROM hosts_labels |
| WHERE host_id IN |
| (SELECT id FROM hosts WHERE invalid = TRUE);""" |
| |
| DROP_HOST_QUEUE_DELETED_COLUMN = """ALTER TABLE host_queue_entries |
| DROP COLUMN deleted""" |
| |
| ADD_HOST_QUEUE_DELETED_COLUMN = """ALTER TABLE host_queue_entries |
| ADD COLUMN deleted BOOLEAN |
| NOT NULL DEFAULT FALSE""" |
| |
| DROP_DEFAULT = """ALTER TABLE host_queue_entries |
| ALTER COLUMN deleted DROP DEFAULT""" |