Sha256: df110f8fbb776cfd37db88090e6bda0bf889b0096cedb91f7ab260fbf96565a8
Contents?: true
Size: 1.7 KB
Versions: 6
Compression:
Stored size: 1.7 KB
Contents
require 'open3'
module Departure
# It executes pt-online-schema-change commands in a new process and gets its
# output and status
class Runner
# Constructor
#
# @param logger [#say, #write]
# @param cli_generator [CliGenerator]
# @param mysql_adapter [ActiveRecord::ConnectionAdapter] it must implement
# #execute and #raw_connection
def initialize(logger, cli_generator, mysql_adapter, config = Departure.configuration)
@logger = logger
@cli_generator = cli_generator
@mysql_adapter = mysql_adapter
@error_log_path = config.error_log_path
end
# Executes the passed sql statement using pt-online-schema-change for ALTER
# TABLE statements, or the specified mysql adapter otherwise.
#
# @param sql [String]
def query(sql)
if alter_statement?(sql)
command_line = cli_generator.parse_statement(sql)
execute(command_line)
else
mysql_adapter.execute(sql)
end
end
# Returns the number of rows affected by the last UPDATE, DELETE or INSERT
# statements
#
# @return [Integer]
def affected_rows
mysql_adapter.raw_connection.affected_rows
end
# TODO: rename it so we don't confuse it with AR's #execute
# Runs and logs the given command
#
# @param command_line [String]
# @return [Boolean]
def execute(command_line)
Command.new(command_line, error_log_path, logger).run
end
private
attr_reader :logger, :cli_generator, :mysql_adapter, :error_log_path
# Checks whether the sql statement is an ALTER TABLE
#
# @param sql [String]
# @return [Boolean]
def alter_statement?(sql)
sql =~ /\Aalter table/i
end
end
end
Version data entries
6 entries across 6 versions & 2 rubygems