Class: Maatkit::ParallelRestore

Inherits:
Object
  • Object
show all
Defined in:
lib/maatkit-ruby/mk-parallel-restore.rb

Overview

Restore MySQL tables in parallel.

Maatkit::ParallelRestore.new( array, str, array)

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ ParallelRestore

Returns a new ParallelRestore Object



76
77
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 76

def initialize()
end

Instance Attribute Details

#ask_pass ⇒ Object

FALSE



15
16
17
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 15

def ask_pass
  @ask_pass
end

#atomic_resume ⇒ Object

TRUE



16
17
18
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 16

def atomic_resume
  @atomic_resume
end

#base_dir ⇒ Object

/home/joel/maatkit_ruby/lib/maatkit_ruby



17
18
19
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 17

def base_dir
  @base_dir
end

#biggest_first ⇒ Object

TRUE



18
19
20
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 18

def biggest_first
  @biggest_first
end

#bin_log ⇒ Object

TRUE



19
20
21
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 19

def bin_log
  @bin_log
end

#bulk_insert_buffer_size ⇒ Object

(No # value)



20
21
22
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 20

def bulk_insert_buffer_size
  @bulk_insert_buffer_size
end

#charset ⇒ Object

BINARY



21
22
23
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 21

def charset
  @charset
end

#commit ⇒ Object

TRUE



22
23
24
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 22

def commit
  @commit
end

#config ⇒ Object

/etc/maatkit/maatkit.conf,/etc/maatkit/mk_parallel_restore.conf,/home/joel/.maatkit.conf,/home/joel/.mk_parallel_restore.conf



23
24
25
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 23

def config
  @config
end

#create_databases ⇒ Object

FALSE



24
25
26
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 24

def create_databases
  @create_databases
end

#create_tables ⇒ Object

TRUE



25
26
27
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 25

def create_tables
  @create_tables
end

#csv ⇒ Object

FALSE



26
27
28
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 26

def csv
  @csv
end

#database ⇒ Object

(No # value)



27
28
29
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 27

def database
  @database
end

#databases ⇒ Object

(No # value)



28
29
30
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 28

def databases
  @databases
end

#databases_regex ⇒ Object

(No # value)



29
30
31
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 29

def databases_regex
  @databases_regex
end

#decompress ⇒ Object

gzip # _d # _c



30
31
32
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 30

def decompress
  @decompress
end

#defaults_file ⇒ Object

(No # value)



31
32
33
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 31

def defaults_file
  @defaults_file
end

#disable_keys ⇒ Object

TRUE



32
33
34
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 32

def disable_keys
  @disable_keys
end

#drop_tables ⇒ Object

TRUE



33
34
35
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 33

def drop_tables
  @drop_tables
end

#dry_run ⇒ Object

FALSE



34
35
36
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 34

def dry_run
  @dry_run
end

#fast_index ⇒ Object

FALSE



35
36
37
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 35

def fast_index
  @fast_index
end

#fifo ⇒ Object

TRUE



36
37
38
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 36

def fifo
  @fifo
end

#foreign_key_checks ⇒ Object

TRUE



37
38
39
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 37

def foreign_key_checks
  @foreign_key_checks
end

#help ⇒ Object

TRUE



38
39
40
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 38

def help
  @help
end

#host ⇒ Object

(No # value)



39
40
41
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 39

def host
  @host
end

#ignore ⇒ Object

FALSE



40
41
42
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 40

def ignore
  @ignore
end

#ignore_databases ⇒ Object

Returns the value of attribute ignore_databases.



41
42
43
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 41

def ignore_databases
  @ignore_databases
end

#ignore_tables ⇒ Object

Returns the value of attribute ignore_tables.



42
43
44
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 42

def ignore_tables
  @ignore_tables
end

#local ⇒ Object

FALSE



43
44
45
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 43

def local
  @local
end

#lock_tables ⇒ Object

FALSE



44
45
46
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 44

def lock_tables
  @lock_tables
end

#no_auto_value_on_0 ⇒ Object

TRUE



45
46
47
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 45

def no_auto_value_on_0
  @no_auto_value_on_0
end

#only_empty_databases ⇒ Object

FALSE



46
47
48
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 46

def only_empty_databases
  @only_empty_databases
end

#password ⇒ Object

(No # value)



47
48
49
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 47

def password
  @password
end

#path_to_mk_parallel_restore ⇒ Object

Sets the executable path, otherwise the environment path will be used.



71
72
73
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 71

def path_to_mk_parallel_restore
  @path_to_mk_parallel_restore
end

#pid ⇒ Object

(No # value)



48
49
50
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 48

def pid
  @pid
end

#port ⇒ Object

(No # value)



49
50
51
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 49

def port
  @port
end

#progress ⇒ Object

FALSE



50
51
52
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 50

def progress
  @progress
end

#quiet ⇒ Object

FALSE



51
52
53
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 51

def quiet
  @quiet
end

#replace ⇒ Object

FALSE



52
53
54
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 52

def replace
  @replace
end

#resume ⇒ Object

TRUE



53
54
55
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 53

def resume
  @resume
end

#set_vars ⇒ Object

wait_timeout=10000



54
55
56
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 54

def set_vars
  @set_vars
end

#socket ⇒ Object

(No # value)



55
56
57
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 55

def socket
  @socket
end

#tab ⇒ Object

FALSE



56
57
58
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 56

def tab
  @tab
end

#tables ⇒ Object

(No # value)



57
58
59
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 57

def tables
  @tables
end

#tables_regex ⇒ Object

(No # value)



58
59
60
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 58

def tables_regex
  @tables_regex
end

#threads ⇒ Object

2



59
60
61
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 59

def threads
  @threads
end

#truncate ⇒ Object

FALSE



60
61
62
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 60

def truncate
  @truncate
end

#umask ⇒ Object

0



61
62
63
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 61

def umask
  @umask
end

#unique_checks ⇒ Object

TRUE



62
63
64
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 62

def unique_checks
  @unique_checks
end

#user ⇒ Object

(No # value)



63
64
65
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 63

def user
  @user
end

#verbose ⇒ Object

1



64
65
66
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 64

def verbose
  @verbose
end

#version ⇒ Object

FALSE



65
66
67
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 65

def version
  @version
end

#wait ⇒ Object

300



66
67
68
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 66

def wait
  @wait
end

Instance Method Details

#start(options = nil) ⇒ Object

Execute the command



82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
 
# File 'lib/maatkit-ruby/mk-parallel-restore.rb', line 82

def start(options = nil)
  tmp = Tempfile.new('tmp')
  command = option_string() + options.to_s + " 2> " + tmp.path
  success = system(command)
  if success
    begin
      while (line = tmp.readline)
        line.chomp
        selected_string = line
      end
    rescue EOFError
      tmp.close
    end
    return selected_string
  else
    tmp.close!
    return success
  end
end