Class: Departure::Runner

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/departure/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 = Departure.configuration) ⇒ Runner

Constructor



17
18
19
20
21
22
23
 
# File 'lib/departure/runner.rb', line 17

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
  @redirect_stderr = config&.redirect_stderr
end

Instance Method Details

#affected_rows ⇒ Integer

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



50
51
52
 
# File 'lib/departure/runner.rb', line 50

def affected_rows
  raw_connection.affected_rows
end

#database_adapter ⇒ Object 



25
26
27
 
# File 'lib/departure/runner.rb', line 25

def database_adapter
  @mysql_adapter
end

#execute(command_line) ⇒ Boolean

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



59
60
61
 
# File 'lib/departure/runner.rb', line 59

def execute(command_line)
  Command.new(command_line, error_log_path, logger, redirect_stderr).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.



37
38
39
40
41
42
43
44
 
# File 'lib/departure/runner.rb', line 37

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

#raw_connection ⇒ Object 



29
30
31
 
# File 'lib/departure/runner.rb', line 29

def raw_connection
  database_adapter.raw_connection
end