Module: Switchman::ActiveRecord::Migrator

Defined in:
lib/switchman/active_record/migration.rb

Instance Method Summary collapse

Instance Method Details

#generate_migrator_advisory_lock_id ⇒ Object

significant change: use the shard name instead of the database name in the lock id. Especially if you’re going through pgbouncer, the database name you’re accessing may not be consistent



26
27
28
29
30
31
32
 
# File 'lib/switchman/active_record/migration.rb', line 26

def generate_migrator_advisory_lock_id
  db_name_hash = Zlib.crc32(Shard.current.name)
  shard_name_hash = ::ActiveRecord::Migrator::MIGRATOR_SALT * db_name_hash
  # Store in internalmetadata to allow other tools to be able to lock out migrations
  ::ActiveRecord::InternalMetadata[:migrator_advisory_lock_id] = shard_name_hash
  shard_name_hash
end

#with_advisory_lock_connection ⇒ Object

significant change: strip out prefer_secondary from config



35
36
37
38
39
40
41
42
43
 
# File 'lib/switchman/active_record/migration.rb', line 35

def with_advisory_lock_connection
  pool = ::ActiveRecord::ConnectionAdapters::ConnectionHandler.new.establish_connection(
    ::ActiveRecord::Base.connection_db_config.configuration_hash.except(:prefer_secondary)
  )

  pool.with_connection { |connection| yield(connection) } # rubocop:disable Style/ExplicitBlockArgument
ensure
  pool&.disconnect!
end