class Sequent::Migrations::Versions
Constants
- DONE
- MIGRATE_OFFLINE_RUNNING
- MIGRATE_ONLINE_FINISHED
- MIGRATE_ONLINE_RUNNING
Public Class Methods
Source
# File lib/sequent/migrations/versions.rb, line 77 def self.current_snapshot_xmin_xact_id connection.execute('SELECT pg_snapshot_xmin(pg_current_snapshot())::text::bigint AS xmin').first['xmin'] end
Source
# File lib/sequent/migrations/versions.rb, line 28 def self.current_version done.latest_version || 0 end
Source
# File lib/sequent/migrations/versions.rb, line 73 def self.end_offline!(new_version) find_by!(version: new_version, status: MIGRATE_OFFLINE_RUNNING).update(status: DONE) end
Source
# File lib/sequent/migrations/versions.rb, line 50 def self.end_online!(new_version) find_by!(version: new_version, status: MIGRATE_ONLINE_RUNNING).update(status: MIGRATE_ONLINE_FINISHED) end
Source
# File lib/sequent/migrations/versions.rb, line 40 def self.latest order('version desc').limit(1).first end
Source
# File lib/sequent/migrations/versions.rb, line 36 def self.latest_version latest&.version end
Source
# File lib/sequent/migrations/versions.rb, line 11 def self.migration_sql <<~SQL.chomp CREATE TABLE IF NOT EXISTS #{table_name} (version integer NOT NULL, CONSTRAINT version_pk PRIMARY KEY(version)); ALTER TABLE #{table_name} drop constraint if exists only_one_running; ALTER TABLE #{table_name} ADD COLUMN IF NOT EXISTS status INTEGER DEFAULT NULL CONSTRAINT only_one_running CHECK (status in (1,2,3)); ALTER TABLE #{table_name} ADD COLUMN IF NOT EXISTS xmin_xact_id BIGINT; DROP INDEX IF EXISTS single_migration_running; CREATE UNIQUE INDEX single_migration_running ON #{table_name} ((status * 0)) where status is not null; SQL end
Source
# File lib/sequent/migrations/versions.rb, line 54 def self.rollback!(new_version) running.where(version: new_version).delete_all end
Source
# File lib/sequent/migrations/versions.rb, line 58 def self.start_offline!(new_version) current_migration = find_by(version: new_version) fail MigrationNotStarted if current_migration.blank? current_migration.with_lock('FOR UPDATE NOWAIT') do current_migration.reload fail MigrationDone if current_migration.status.nil? fail ConcurrentMigration if current_migration.status != MIGRATE_ONLINE_FINISHED current_migration.update(status: MIGRATE_OFFLINE_RUNNING) end rescue ActiveRecord::LockWaitTimeout raise ConcurrentMigration end
Source
# File lib/sequent/migrations/versions.rb, line 44 def self.start_online!(new_version) create!(version: new_version, status: MIGRATE_ONLINE_RUNNING, xmin_xact_id: current_snapshot_xmin_xact_id) rescue ActiveRecord::RecordNotUnique raise ConcurrentMigration, "Migration for version #{new_version} is already running" end
Source
# File lib/sequent/migrations/versions.rb, line 32 def self.version_currently_migrating running.latest_version end