blob: c28f49899b6f646f327d45ec9fa5495d31fea61e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
# frozen_string_literal: true
class SwapColumnsForCiStagesPipelineIdBigintForSelfHost < Gitlab::Database::Migration[2.2]
include Gitlab::Database::MigrationHelpers::Swapping
milestone '16.6'
disable_ddl_transaction!
TABLE_NAME = :ci_stages
TRIGGER_FUNCTION_NAME = :trigger_07bc3c48f407
COLUMN_NAME = :pipeline_id
BIGINT_COLUMN_NAME = :pipeline_id_convert_to_bigint
FK_NAME = :fk_fb57e6cc56
BIGINT_FK_NAME = :fk_c5ddde695f
INDEX_NAMES = %i[
index_ci_stages_on_pipeline_id
index_ci_stages_on_pipeline_id_and_id
index_ci_stages_on_pipeline_id_and_name
index_ci_stages_on_pipeline_id_and_position
]
BIGINT_INDEX_NAMES = %i[
index_ci_stages_on_pipeline_id_convert_to_bigint
index_ci_stages_on_pipeline_id_convert_to_bigint_and_id
index_ci_stages_on_pipeline_id_convert_to_bigint_and_name
index_ci_stages_on_pipeline_id_convert_to_bigint_and_position
]
def up
return if column_type_of?(:bigint)
swap
end
def down
return if column_type_of?(:integer)
swap
end
private
def column_type_of?(type)
column_for(TABLE_NAME, COLUMN_NAME).sql_type.to_s == type.to_s
end
def swap
with_lock_retries(raise_on_exhaustion: true) do
# Lock the tables involved.
lock_tables(:ci_pipelines, :ci_stages)
# Rename the columns to swap names
swap_columns(TABLE_NAME, COLUMN_NAME, BIGINT_COLUMN_NAME)
# Reset the trigger function
reset_trigger_function(TRIGGER_FUNCTION_NAME)
# Swap fkey constraint
swap_foreign_keys(TABLE_NAME, FK_NAME, BIGINT_FK_NAME)
# Swap index
INDEX_NAMES.each_with_index do |index_name, i|
swap_indexes(TABLE_NAME, index_name, BIGINT_INDEX_NAMES[i])
end
end
end
end
|
