class Mysqlcollector::Mysql

Public Class Methods

new() click to toggle source
# File lib/mysqlcollector/mysql.rb, line 5
def initialize
  @conn = Mysql2::Client.new(host: $config[:mysql_host],
                             port: $config[:mysql_port],
                             username: $config[:mysql_username],
                             password: $config[:mysql_password])

  Mysqlcollector::Log.new.debug("Connected on MySQL server: #{$config[:mysql_host]}:#{$config[:mysql_port]}");
rescue Exception => error
  Mysqlcollector::Log.new.error(error.message)
end

Public Instance Methods

close() click to toggle source
# File lib/mysqlcollector/mysql.rb, line 26
def close
  @conn.close
rescue
  exit 1
end
execute(sql) click to toggle source
# File lib/mysqlcollector/mysql.rb, line 16
def execute(sql)
  begin
    Mysqlcollector::Log.new.debug("MySQL Query: #{sql}")

    @conn.query(sql).each(:as => :hash)
  rescue Exception => error
    Mysqlcollector::Log.new.sql_error(error, sql);
  end
end