Class: IsolatedServer::Mysql

Inherits:
Base
  • Object
show all
Includes:
DBConnection
Defined in:
lib/isolated_server/mysql.rb,
lib/isolated_server/mysql/jdbc_connection.rb,
lib/isolated_server/mysql/mysql2_connection.rb

Defined Under Namespace

Modules: DBConnection Classes: WrappedJDBCConnection

Instance Attribute Summary collapse

Attributes inherited from Base

#base, #params, #pid, #port

Class Method Summary collapse

Instance Method Summary collapse

Methods included from DBConnection

#connection

Methods inherited from Base

#cleanup!, #down!, #exec_server, exec_wait, #grab_free_port, #kill!, #locate_executable

Constructor Details

#initialize(options = {}) ⇒ Mysql

Returns a new instance of Mysql.



16
17
18
19
20
21
22
23
 
# File 'lib/isolated_server/mysql.rb', line 16

def initialize(options = {})
  super options
  @mysql_data_dir = "#{@base}/mysqld"
  @mysql_socket   = "#{@mysql_data_dir}/mysqld.sock"
  @load_data_path = options[:data_path]
  @log_bin        = options[:log_bin] || "--log-bin"
  @server_id      = rand(2**31)
end

Instance Attribute Details

#initial_binlog_file ⇒ Object (readonly)

Returns the value of attribute initial_binlog_file.



14
15
16
 
# File 'lib/isolated_server/mysql.rb', line 14

def initial_binlog_file
  @initial_binlog_file
end

#initial_binlog_pos ⇒ Object (readonly)

Returns the value of attribute initial_binlog_pos.



14
15
16
 
# File 'lib/isolated_server/mysql.rb', line 14

def initial_binlog_pos
  @initial_binlog_pos
end

#mysql_data_dir ⇒ Object (readonly)

Returns the value of attribute mysql_data_dir.



14
15
16
 
# File 'lib/isolated_server/mysql.rb', line 14

def mysql_data_dir
  @mysql_data_dir
end

#server_id ⇒ Object (readonly)

Returns the value of attribute server_id.



14
15
16
 
# File 'lib/isolated_server/mysql.rb', line 14

def server_id
  @server_id
end

Class Method Details

.thread_boot(*params) ⇒ Object

TODO:

Extract and genericize more of this into Base

For JRuby



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/isolated_server/mysql.rb', line 27

def self.thread_boot(*params)
  bin = [File.dirname(__FILE__) + "/../bin/boot_isolated_mysql_server"]
  mysql_dir, mysql_port = nil, nil
  restore_env = {}

  if `which ruby` =~ (/rvm/)
    bin = ["rvm", "1.8.7", "do", "ruby"] + bin
  end

  params = ["--pid", $$.to_s] + params

  Thread.abort_on_exception = true
  Thread.new do
    ENV.keys.grep(/GEM|BUNDLE|RUBYOPT/).each do |k|
      restore_env[k] = ENV.delete(k)
    end
    IO.popen(bin + params, "r") do |pipe|
      mysql_dir = pipe.readline.split(' ').last
      mysql_port = pipe.readline.split(' ').last.to_i
      sleep
    end
  end

  while mysql_port.nil?
    sleep 1
  end
  new(:port => mysql_port, :base => mysql_dir)
end

Instance Method Details

#boot! ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
67
68
69
 
# File 'lib/isolated_server/mysql.rb', line 56

def boot!
  @port ||= grab_free_port

  setup_data_dir
  setup_binlog
  setup_tmp_dir

  up!

  record_initial_master_position

  setup_time_zone
  setup_server_id
end

#console ⇒ Object 



92
93
94
 
# File 'lib/isolated_server/mysql.rb', line 92

def console
  system("mysql -uroot --port #{@port.to_s.shellescape} mysql --host 127.0.0.1")
end

#make_slave_of(master) ⇒ Object 



101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
 
# File 'lib/isolated_server/mysql.rb', line 101

def make_slave_of(master)
  binlog_file = master.initial_binlog_file || (@log_bin.split('/').last + ".000001")
  binlog_pos = master.initial_binlog_pos || 4

  connection.query("    CHANGE MASTER TO MASTER_HOST='127.0.0.1',\n                     MASTER_PORT=\#{master.port},\n                     MASTER_USER='root', MASTER_PASSWORD='',\n                     MASTER_LOG_FILE='\#{binlog_file}',\n                     MASTER_LOG_POS=\#{binlog_pos}\n    EOL\n  )\n  connection.query(\"SLAVE START\")\n  connection.query(\"SET GLOBAL READ_ONLY=1\")\nend\n"

#reconnect! ⇒ Object 



96
97
98
99
 
# File 'lib/isolated_server/mysql.rb', line 96

def reconnect!
  @cx = nil
  connection
end

#set_rw(rw) ⇒ Object 



117
118
119
120
 
# File 'lib/isolated_server/mysql.rb', line 117

def set_rw(rw)
  ro = rw ? 0 : 1
  connection.query("SET GLOBAL READ_ONLY=#{ro}")
end

#up! ⇒ Object 



71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'lib/isolated_server/mysql.rb', line 71

def up!
  exec_server([
    locate_executable("mysqld"),
    '--no-defaults',
    '--default-storage-engine=innodb',
    "--datadir=#{@mysql_data_dir}",
    "--pid-file=#{@base}/mysqld.pid",
    "--port=#{@port}",
    "--socket=#{@mysql_data_dir}/mysql.sock",
    @log_bin,
    '--log-slave-updates',
    *@params
  ].shelljoin)

  sleep(0.1) until up?
end

#up? ⇒ Boolean

Returns:

  • (Boolean) 


88
89
90
 
# File 'lib/isolated_server/mysql.rb', line 88

def up?
  system("mysql -h127.0.0.1 --port=#{@port.to_s.shellescape} --database=mysql -u root -e 'select 1' >/dev/null 2>&1")
end