Class: Arrival::Runner

Inherits:
Object
  • Object
show all
Defined in:
lib/arrival/runner.rb

Overview

It executes pt-online-schema-change commands in a new process and gets its output and status

Instance Method Summary collapse

Constructor Details

#initialize(logger, cli_generator, mysql_adapter, config = Arrival.configuration) ⇒ Runner

Constructor

Parameters:

  • logger (#say, #write)
  • cli_generator (CliGenerator)
  • mysql_adapter (ActiveRecord::ConnectionAdapter) —

    it must implement #execute and #raw_connection



13
14
15
16
17
18
 
# File 'lib/arrival/runner.rb', line 13

def initialize(logger, cli_generator, mysql_adapter, config = Arrival.configuration)
  @logger = logger
  @cli_generator = cli_generator
  @mysql_adapter = mysql_adapter
  @error_log_path = config.error_log_path
end

Instance Method Details

#affected_rows ⇒ Integer

Returns the number of rows affected by the last UPDATE, DELETE or INSERT statements

Returns:

  • (Integer) 


37
38
39
 
# File 'lib/arrival/runner.rb', line 37

def affected_rows
  mysql_adapter.raw_connection.affected_rows
end

#execute(command_line) ⇒ Boolean

TODO: rename it so we don’t confuse it with AR’s #execute Runs and logs the given command

Parameters:

  • command_line (String)

Returns:

  • (Boolean) 


46
47
48
 
# File 'lib/arrival/runner.rb', line 46

def execute(command_line)
  Command.new(command_line, error_log_path, logger).run
end

#query(sql) ⇒ Object

Executes the passed sql statement using pt-online-schema-change for ALTER TABLE statements, or the specified mysql adapter otherwise.

Parameters:

  • sql (String) 


24
25
26
27
28
29
30
31
 
# File 'lib/arrival/runner.rb', line 24

def query(sql)
  if alter_statement?(sql)
    command_line = cli_generator.parse_statement(sql)
    execute(command_line)
  else
    mysql_adapter.execute(sql)
  end
end