Class: DbVcs::Adapters::Mysql

Inherits:
Object
  • Object
show all
Extended by:
DbVcs::AdapterInterface
Defined in:
lib/db_vcs/adapters/mysql.rb

Defined Under Namespace

Classes: Config

Class Method Summary collapse

Methods included from DbVcs::AdapterInterface

config, connection, copy_database, create_database, db_exists?, drop_by_dbname, list_databases

Class Method Details

.config ⇒ DbVcs::Adapters::Mysql::Config 



29
30
31
 
# File 'lib/db_vcs/adapters/mysql.rb', line 29

def config
  DbVcs.config.mysql_config
end

.connection ⇒ Mysql2::Client 



34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/db_vcs/adapters/mysql.rb', line 34

def connection
  @connection ||=
    begin
      require "mysql2"
      Mysql2::Client.new(
        host: config.host,
        username: config.username,
        port: config.port,
        password: config.password
      )
    end
end

.copy_database(to_db, from_db) ⇒ Object 



58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
# File 'lib/db_vcs/adapters/mysql.rb', line 58

def copy_database(to_db, from_db)
  create_opts =
    connection.query("      SELECT `DEFAULT_CHARACTER_SET_NAME` as charset, `DEFAULT_COLLATION_NAME` as collation\n      FROM `INFORMATION_SCHEMA`.`SCHEMATA` WHERE `SCHEMA_NAME` = '\#{from_db}' LIMIT 1\n    SQL\n  connection.query(<<~SQL)\n    CREATE DATABASE \#{to_db} CHARACTER SET \#{create_opts[\"charset\"]} COLLATE \#{create_opts[\"collation\"]}\n  SQL\n  password_opt = config.password.to_s.strip.empty? ? \"\" : \"-p\#{config.password}\"\n  command =\n    <<~SH\n    \#{config.mysqldump_path} -u \#{config.username} \#{password_opt} -h \#{config.host} -P \#{config.port} \#{from_db} \\\n    | \#{config.mysql_path} -u \#{config.username} \#{password_opt} -h \#{config.host} -P \#{config.port} \#{to_db}\n  SH\n  `\#{command}`\nend\n").first

.create_database(db_name) ⇒ Object 



78
79
80
 
# File 'lib/db_vcs/adapters/mysql.rb', line 78

def create_database(db_name)
  connection.query("CREATE DATABASE #{db_name}")
end

.db_exists?(db_name) ⇒ Boolean 



49
50
51
52
53
 
# File 'lib/db_vcs/adapters/mysql.rb', line 49

def db_exists?(db_name)
  !connection
     .query("SELECT 1 as one FROM `INFORMATION_SCHEMA`.`SCHEMATA` WHERE `SCHEMA_NAME` = '#{db_name}' LIMIT 1")
     .first.nil?
end

.drop_by_dbname(db_name) ⇒ void 



89
90
91
 
# File 'lib/db_vcs/adapters/mysql.rb', line 89

def drop_by_dbname(db_name)
  connection.query("DROP DATABASE #{db_name}")
end

.list_databases ⇒ Array<String> 



83
84
85
 
# File 'lib/db_vcs/adapters/mysql.rb', line 83

def list_databases
  connection.query("SELECT `SCHEMA_NAME` FROM `INFORMATION_SCHEMA`.`SCHEMATA`").to_a.flat_map(&:values)
end