18 lines
652 B
Ruby
18 lines
652 B
Ruby
class Migrations::BackfillStableIdJob < ApplicationJob
|
|
queue_as :low_priority
|
|
|
|
DEFAULT_LIMIT = 50_000
|
|
|
|
def perform(iteration, limit = DEFAULT_LIMIT)
|
|
sql = "UPDATE champs SET stable_id = t.stable_id, stream = 'main'
|
|
FROM types_de_champ t
|
|
WHERE champs.type_de_champ_id = t.id
|
|
AND champs.id IN (SELECT id FROM champs WHERE champs.stable_id IS NULL LIMIT ?);"
|
|
query = ActiveRecord::Base.sanitize_sql_array([sql, limit])
|
|
ActiveRecord::Base.connection.execute(query)
|
|
|
|
if Champ.exists?(stable_id: nil)
|
|
Migrations::BackfillStableIdJob.set(wait: 2.seconds).perform_later(iteration + 1, limit)
|
|
end
|
|
end
|
|
end
|