class Convergence::DatabaseConnector::MysqlConnector

Attributes

config[R]

Public Class Methods

new(config) click to toggle source
# File lib/convergence/database_connector/mysql_connector.rb, line 7
def initialize(config)
  @config = config
end

Public Instance Methods

client(database_name = @config.database) click to toggle source
# File lib/convergence/database_connector/mysql_connector.rb, line 11
def client(database_name = @config.database)
  @mysql ||= Mysql2::Client.new(
    {
      host: @config.host,
      port: @config.port,
      username: @config.username,
      password: @config.password,
      database: database_name
    }.merge!(@config.mysql.ssl_options)
  )
end
schema_client() click to toggle source
# File lib/convergence/database_connector/mysql_connector.rb, line 23
def schema_client
  @schema_mysql ||= Mysql2::Client.new(
    {
      host: @config.host,
      port: @config.port,
      username: @config.username,
      password: @config.password,
      database: 'information_schema'
    }.merge!(@config.mysql.ssl_options)
  )
end