Module: Switchman::ActiveRecord::Migrator
- Defined in:
- lib/switchman/active_record/migration.rb
Instance Method Summary collapse
-
#generate_migrator_advisory_lock_id ⇒ Object
significant change: use the shard name instead of the database name in the lock id.
-
#with_advisory_lock_connection ⇒ Object
significant change: strip out prefer_secondary from config.
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 |