• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1import common
2from autotest_lib.database import db_utils
3
4UP_SQL = """
5CREATE INDEX afe_drone_sets_drones_droneset_ibfk
6ON afe_drone_sets_drones (droneset_id);
7
8ALTER TABLE afe_drone_sets_drones
9DROP KEY afe_drone_sets_drones_unique;
10
11ALTER TABLE afe_drone_sets_drones
12ADD CONSTRAINT afe_drone_sets_drones_unique
13UNIQUE KEY (drone_id);
14"""
15
16# On first migration to 62, this key will be deleted automatically. However, if
17# you migrate to 62, then down to 61, then back to 62, this key will remain.
18DROP_KEY_SQL = """
19ALTER TABLE afe_drone_sets_drones
20DROP KEY afe_drone_sets_drones_drone_ibfk;
21"""
22
23DOWN_SQL = """
24CREATE INDEX afe_drone_sets_drones_drone_ibfk
25ON afe_drone_sets_drones (drone_id);
26
27ALTER TABLE afe_drone_sets_drones
28DROP KEY afe_drone_sets_drones_unique;
29
30ALTER TABLE afe_drone_sets_drones
31ADD CONSTRAINT afe_drone_sets_drones_unique
32UNIQUE KEY (droneset_id, drone_id);
33
34ALTER TABLE afe_drone_sets_drones
35DROP KEY afe_drone_sets_drones_droneset_ibfk;
36"""
37
38
39def migrate_up(manager):
40    query = ('SELECT * FROM afe_drone_sets_drones '
41             'GROUP BY drone_id HAVING COUNT(*) > 1')
42    rows = manager.execute(query)
43    if rows:
44        raise Exception('Some drones are associated with more than one drone '
45                        'set. Please remove all duplicates before running this '
46                        'migration.')
47    manager.execute_script(UP_SQL)
48
49    if db_utils.check_index_exists(manager, 'afe_drone_sets_drones',
50                                   'afe_drone_sets_drones_drone_ibfk'):
51        manager.execute(DROP_KEY_SQL)
52