| @@ -1,20 +1,21 | |||||
| 1 | class AddUniqueIndexOnMembers < ActiveRecord::Migration |
|
1 | class AddUniqueIndexOnMembers < ActiveRecord::Migration | |
| 2 | def self.up |
|
2 | def self.up | |
| 3 |
# |
|
3 | # Clean and reassign MemberRole rows if needed | |
|
|
4 | MemberRole.delete_all("member_id NOT IN (SELECT id FROM #{Member.table_name})") | |||
| 4 | MemberRole.update_all("member_id =" + |
|
5 | MemberRole.update_all("member_id =" + | |
| 5 | " (SELECT min(m2.id) FROM #{Member.table_name} m1, #{Member.table_name} m2" + |
|
6 | " (SELECT min(m2.id) FROM #{Member.table_name} m1, #{Member.table_name} m2" + | |
| 6 | " WHERE m1.user_id = m2.user_id AND m1.project_id = m2.project_id" + |
|
7 | " WHERE m1.user_id = m2.user_id AND m1.project_id = m2.project_id" + | |
| 7 | " AND m1.id = #{MemberRole.table_name}.member_id)") |
|
8 | " AND m1.id = #{MemberRole.table_name}.member_id)") | |
| 8 | # Remove duplicates |
|
9 | # Remove duplicates | |
| 9 | Member.connection.select_values("SELECT m.id FROM #{Member.table_name} m" + |
|
10 | Member.connection.select_values("SELECT m.id FROM #{Member.table_name} m" + | |
| 10 | " WHERE m.id > (SELECT min(m1.id) FROM #{Member.table_name} m1 WHERE m1.user_id = m.user_id AND m1.project_id = m.project_id)").each do |i| |
|
11 | " WHERE m.id > (SELECT min(m1.id) FROM #{Member.table_name} m1 WHERE m1.user_id = m.user_id AND m1.project_id = m.project_id)").each do |i| | |
| 11 | Member.delete_all(["id = ?", i]) |
|
12 | Member.delete_all(["id = ?", i]) | |
| 12 | end |
|
13 | end | |
| 13 |
|
14 | |||
| 14 | # Then add a unique index |
|
15 | # Then add a unique index | |
| 15 | add_index :members, [:user_id, :project_id], :unique => true |
|
16 | add_index :members, [:user_id, :project_id], :unique => true | |
| 16 | end |
|
17 | end | |
| 17 |
|
18 | |||
| 18 | def self.down |
|
19 | def self.down | |
| 19 | end |
|
20 | end | |
| 20 | end |
|
21 | end | |
General Comments 0
You need to be logged in to leave comments.
Login now