Sha256: 8261589a349d25d26b7243ff07deb0d800b5602e6e2cc2ec90f1bfffc9fb34cd
Contents?: true
Size: 1.23 KB
Versions: 8
Compression:
Stored size: 1.23 KB
Contents
# Copyright (c) 2011 - 2013, SoundCloud Ltd., Rany Keddo, Tobias Bielohlawek, Tobias
# Schmidt
require 'lhm/command'
require 'lhm/migration'
require 'lhm/sql_retry'
module Lhm
# Switches origin with destination table using an atomic rename.
#
# It should only be used if the MySQL server version is not affected by the
# bin log affecting bug #39675. This can be verified using
# Lhm::SqlHelper.supports_atomic_switch?.
class AtomicSwitcher
include Command
attr_reader :connection
LOG_PREFIX = "AtomicSwitcher"
def initialize(migration, connection = nil)
@migration = migration
@connection = connection
@origin = migration.origin
@destination = migration.destination
end
def atomic_switch
"rename table `#{ @origin.name }` to `#{ @migration.archive_name }`, " \
"`#{ @destination.name }` to `#{ @origin.name }`"
end
def validate
unless @connection.data_source_exists?(@origin.name) &&
@connection.data_source_exists?(@destination.name)
error "`#{ @origin.name }` and `#{ @destination.name }` must exist"
end
end
private
def execute
@connection.execute(atomic_switch, should_retry: true, log_prefix: LOG_PREFIX)
end
end
end
Version data entries
8 entries across 8 versions & 2 rubygems