Class: ScalingoBackupsManager::Restore::Mysql

Inherits:
Object
  • Object
show all
Defined in:
lib/scalingo_backups_manager/restore/mysql.rb

Class Method Summary collapse

Class Method Details

.restore(filename, options = {}) ⇒ Object



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
# File 'lib/scalingo_backups_manager/restore/mysql.rb', line 8

def self.restore(filename, options = {})
  opts = options.reverse_merge({
    database_config_file: 'database.yml',
    env: 'development',
    host: nil,
    remote_database_name: nil,
    local_database_name: nil,
    skip_rm: false,
    port: nil,
  })
  destination_path = filename.split("/")
  backup_name = destination_path.pop.gsub(".tar.gz", "")
  destination_path = destination_path.join("/") + backup_name + "/"
  if Dir.exist?(destination_path)
    puts "Unzipped backup is already present, skipping..."
  else
    unless Dir.exist?(destination_path)
      p "Creating destination folder..."
      Dir.mkdir(destination_path)
    end
    untar_cmd = "tar zxvf #{filename} -C #{destination_path}"
    p "Untar file with command #{untar_cmd}"
    system untar_cmd
  end

  database_yml_content = File.read("config/#{opts[:database_config_file]}")
  parsed_database_config = ERB.new(database_yml_content).result
  rails_db_config = YAML.load(parsed_database_config)[opts[:env]]
  config = {
    host: rails_db_config["host"],
    database: rails_db_config["database"],
    password: rails_db_config["password"],
    user: rails_db_config["username"],
    port: rails_db_config["port"]
  }

  restore_cmd = "/usr/bin/env mysql -h #{opts[:host] || config[:host]}"

  if config[:user].present?
    restore_cmd << " -u #{config[:user]}"
    if config[:password].present?
      restore_cmd << " --password="
      restore_cmd << "#{config[:password]}"
    end
  end

  if config[:port].present? || opts[:port].present?
    restore_cmd << " -P #{opts[:port] || config[:port] || 5432}"
  end

  restore_cmd << " #{config[:database]}"

  file_path = Dir["#{destination_path}*.sql"]
  if file_path.empty?
    puts "*** No SQL file found in tar ***"
    return
  end
  restore_cmd << " < #{file_path.first}"

  puts "*** Restoring backup to mysql database ***"
  puts "Command: #{restore_cmd}"
  system(restore_cmd)
  FileUtils.rm_r destination_path unless opts[:skip_rm]
end