Migrasi data di Ruby on Rails

img



TL; DR Harap pindahkan kode migrasi data Anda ke tugas Rake atau gunakan permata bergaya skema lengkap. Tutupi logika ini dengan tes.



Saya bekerja sebagai pengembang backend di FunBox. Untuk sejumlah proyek, kami menulis backend Ruby On Rails. Kami berupaya untuk membangun proses pembangunan yang memadai, oleh karena itu, dihadapkan pada suatu masalah, kami mencoba untuk memahaminya dan mengembangkan rekomendasi metodologis. Begitu pula yang terjadi dengan masalah migrasi data. Setelah saya melakukan migrasi data dalam tugas Rake terpisah yang dicakup dengan pengujian, dan tim memiliki pertanyaan: "Mengapa tidak dalam migrasi skema?" Saya bertanya kepada pengembang di obrolan internal dan, yang mengejutkan saya, pendapat terbagi. Jelaslah bahwa pertanyaan itu ambigu dan layak untuk dianalisis dan dijadikan artikel. Program maksimum untuk tujuan per artikel akan terpenuhi untuk saya ketika seseorang mengutip tautan ke teks ini dalam tinjauan kode sebagai tanggapan atas pertanyaan mengapa migrasi data tertentu diambil atau, sebaliknya, tidak dikeluarkan dari migrasi skema.



Penyimpangan lirik



, . . « . ». « ».



IT . Ruby, - . , , . , : , , , , , , .



, , . , , , , .





— , (views), , . .

— (, , , .) . . , . CI, , ( ) SQL , .

— . , DML- UPDATE SQL. . .

(Continuous Delivery) — , .



Rails , , DDL-. , . , Rails omakase- . , .





, , . , . , , . .





. , . (, ) , .





, . . -, , .



deadlocks .



, , , Zero Downtime Migrations Strong Migrations.







— DSL (Domain Specific Language) Ruby DDL- SQL . DSL, , . , .



DSL, , SRP. . , , …



( , )



Ruby On Rails Data Migration , . , . Rails-, . .





SQL ORM ActiveRecord.



:



  1. . .
  2. , .
  3. callbacks , .


«» . , .



«» Rails ( 4.2):



    # db/migrate/20100513121110_add_flag_to_product.rb

    class AddFlagToProduct < ActiveRecord::Migration
      class Product < ActiveRecord::Base
      end

      def change
        add_column :products, :flag, :boolean
        Product.reset_column_information
        Product.all.each do |product|
          product.update_attributes!(:flag => false)
        end
      end
    end


.



, each find_each c batch-.



, , 4.2 .



SQL



, , SQL, :



  1. , . , , , (SQL), .
  2. JOIN-, , .
  3. , deadlock.




Thoughtbot : -, DDL. CI. .



. , , - . , , . , .



, , . , .



, . , .



, , . , , , .



,



, .



, nullable- .



, .



, :



    UPDATE table SET field = 'f' WHERE field IS NULL


:



    class ClientDemandsMakeApprovedNullable < ActiveRecord::Migration
      def up
        change_column_null :client_demands, :approved, true
        change_column_default :client_demands, :approved, nil
      end

      def down
        execute("UPDATE client_demands SET approved = 'f' WHERE approved IS NULL")
        change_column_null :client_demands, :approved, false
        change_column_default :client_demands, :approved, false
      end
    end


, . , , . Dan Mayer Managing DB Schema & Data Changes Modifying Large Tables.







. «», . . , , , .



, .



, , .





, . . REPL .

, :



  1. ;
  2. ;
  3. .


. , . . .

, , , , .



Rake-



, — Rake-. . -.



Rake- . , . . . — .



, , Rake, Thoughtbot:



    # lib/tasks/temporary/users.rake
    namespace :users do
      desc "Actualize achievements counter cache"
      task actualize_achievements_counter_cache: :environment do
        # C (ActiveRelation)   
        users = User.with_achievements
        #    
        puts "Going to update #{users.count} users"
        # ,   ,  
        #    .    
        ActiveRecord::Base.transaction do
          # Batch-   find_each
          users.find_each do |user|        
            #     
            user.actualize_achievements_counter_cache!
            #  
            print "."
          end
        end

        puts "Done!"
      end
    end


each find_each, . memory bloats. Akshay Mohite.



. , Rake- .



, . . , , . .





Mark Qualie up, . «» . :



    class AddLastSmiledAtColumnToUsers < ActiveRecord::Migration[5.1]
      def change
        add_column :users, :last_smiled_at, :datetime
        add_index :users, :last_smiled_at
      end

      class Data
        def up
          User.all.find_in_batches(batch_size: 250).each do |group|
            ActiveRecord::Base.transaction do
              group.each do |user|
                user.last_smiled_at = user.smiles.last.created_at
                user.save if user.changed?
              end
            end
          end
        end
      end
    end


:



    Dir.glob("#{Rails.root}/db/migrate/*.rb").each { |file| require file }
    AddLastSmiledAtColumnToUsers::Data.new.up


Job, .





, - , .



, , .



, . , .



data-migrate (> 670), , Readme. Rails 5+.



, Rails 4+:





. .



, Rake-. . , .



db/data, db/migrate c :



rails g data_migration add_this_to_that


:



rake data:migrate
rake db:migrate:with_data
rake db:rollback:with_data
rake db:migrate:status:with_data


, .





  Rails Rake
+ - - - -
Zero Downtime Deployment - + + + +
Test First - - + +
+ - - +
+ - + + +
+ - - + +


.

— , :



  1. — ;
  2. Zero Downtime Deployment — , ;
  3. Test First — ;
  4. — ;
  5. — , ;
  6. — , , .




, Rake- — .



, . .



, — , . , .







UPD 2020-08-06: Extrapolator « ».

- , Test First .

.



UPD 2020-08-07: . , . . , .



UPD 2020-08-08: , . , . , , . « », , . . , .




All Articles