showard | 915bbca | 2008-03-31 23:33:26 +0000 | [diff] [blame] | 1 | INDEXES = ( |
| 2 | ('ineligible_host_queues', 'job_id'), |
| 3 | ('ineligible_host_queues', 'host_id'), |
| 4 | ('host_queue_entries', 'job_id'), |
| 5 | ('host_queue_entries', 'host_id'), |
| 6 | ('host_queue_entries', 'meta_host'), |
| 7 | ('hosts_labels', 'label_id'), |
| 8 | ) |
| 9 | |
| 10 | def get_index_name(table, field): |
jadmanski | 0afbb63 | 2008-06-06 21:10:57 +0000 | [diff] [blame] | 11 | return table + '_' + field |
showard | 915bbca | 2008-03-31 23:33:26 +0000 | [diff] [blame] | 12 | |
| 13 | |
| 14 | def migrate_up(manager): |
jadmanski | 0afbb63 | 2008-06-06 21:10:57 +0000 | [diff] [blame] | 15 | for table, field in INDEXES: |
| 16 | manager.execute('CREATE INDEX %s ON %s (%s)' % |
| 17 | (get_index_name(table, field), table, field)) |
showard | 915bbca | 2008-03-31 23:33:26 +0000 | [diff] [blame] | 18 | |
| 19 | |
| 20 | def migrate_down(manager): |
jadmanski | 0afbb63 | 2008-06-06 21:10:57 +0000 | [diff] [blame] | 21 | for table, field in INDEXES: |
| 22 | manager.execute('DROP INDEX %s ON %s' % |
| 23 | (get_index_name(table, field), table)) |