Commit d7e8bfac authored by Grzegorz Bizon's avatar Grzegorz Bizon

Improve stages index migration code readability

parent 9f235064
...@@ -4,18 +4,20 @@ ...@@ -4,18 +4,20 @@
module Gitlab module Gitlab
module BackgroundMigration module BackgroundMigration
class MigrateStageIndex class MigrateStageIndex
module Migratable def perform(start_id, stop_id)
class Stage < ActiveRecord::Base migrate_stage_index_sql(start_id.to_i, stop_id.to_i).tap do |sql|
self.table_name = 'ci_stages' ActiveRecord::Base.connection.execute(sql)
end end
end end
def perform(start_id, stop_id) private
def migrate_stage_index_sql(start_id, stop_id)
if Gitlab::Database.postgresql? if Gitlab::Database.postgresql?
sql = <<~SQL <<~SQL
WITH freqs AS ( WITH freqs AS (
SELECT stage_id, stage_idx, COUNT(*) AS freq FROM ci_builds SELECT stage_id, stage_idx, COUNT(*) AS freq FROM ci_builds
WHERE stage_id BETWEEN #{start_id.to_i} AND #{stop_id.to_i} WHERE stage_id BETWEEN #{start_id} AND #{stop_id}
AND stage_idx IS NOT NULL AND stage_idx IS NOT NULL
GROUP BY stage_id, stage_idx GROUP BY stage_id, stage_idx
), indexes AS ( ), indexes AS (
...@@ -29,18 +31,16 @@ module Gitlab ...@@ -29,18 +31,16 @@ module Gitlab
AND ci_stages.index IS NULL; AND ci_stages.index IS NULL;
SQL SQL
else else
sql = <<~SQL <<~SQL
UPDATE ci_stages UPDATE ci_stages
SET index = SET index =
(SELECT stage_idx FROM ci_builds (SELECT stage_idx FROM ci_builds
WHERE ci_builds.stage_id = ci_stages.id WHERE ci_builds.stage_id = ci_stages.id
GROUP BY ci_builds.stage_idx ORDER BY COUNT(*) DESC LIMIT 1) GROUP BY ci_builds.stage_idx ORDER BY COUNT(*) DESC LIMIT 1)
WHERE ci_stages.id BETWEEN #{start_id.to_i} AND #{stop_id.to_i} WHERE ci_stages.id BETWEEN #{start_id} AND #{stop_id}
AND ci_stages.index IS NULL AND ci_stages.index IS NULL
SQL SQL
end end
ActiveRecord::Base.connection.execute(sql)
end end
end end
end end
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment