require 'database_check_exception'
require 'mysql'

class DatabaseCheck < Check
  def type
    "Database"
  end

  def perform_check
    dsn = URI(uri)
    scheme = dsn.scheme
    host = dsn.host
    port = dsn.port
    user = dsn.user
    pass = dsn.password
    base = dsn.path.gsub(/^\/*|\/*$/, '')
    raise DatabaseCheckException.unhandled_database_type(scheme) unless scheme == 'mysql'
    my = Mysql.connect(host, user, pass, base)
    my.query('SELECT CURRENT_TIMESTAMP;')
  end
end