DB = {}
DB.User = "D3A4"
DB.Pass = "theadminmodofd3"
DB.DBase = "D3A"

function DB.Connect()
    if (DB.CONNECTION) then return end

    DB.CONNECTION = mysqloo.connect("127.0.0.1", DB.User, DB.Pass, DB.DBase, 3306)
    DB.CONNECTION.onConnected = function()
        D3A.Print("Database connection successful.")
    end

    DB.CONNECTION.onConnectionFailed = function(s, e)
        D3A.Error("Database connection failed: " .. e)
    end

    DB.CONNECTION:connect()
end

function DB.Escape(s)
    return DB.CONNECTION:escape(s)
end

function DB.EnsureConnection()
    local status = DB.Connection:status()
    while (status != 0) do
        if (stat != 1) then
            DB.Connection:connect()
        end
    end
end

function DB.QueryWait(q)
    q = q or function() end

    DB.EnsureConnection()

    local query = DB.Connection:query(q)
    local retvar

    query.onSuccess = function(self)
        retvar = self:getData()
    end

    query.onError = function(self, e)
        D3A.Error("MySQL error: " .. e .. "\nQuery given: " .. q)
        retvar = {}
    end

    query:start()
    query:wait()

    return retvar
end

function DB.Query(q, c)
    DB.EnsureConnection()

    local query = DB.Connection:query(q)

    query.onSuccess = function(self)
        c(self:getData())
    end

    query.onError = function(self, e)
        D3A.Error("MySQL error: " .. e .. "\nQuery given: " .. q)
    end

    query:start()
end

DB.Connect()

timer.Create("DB.Keepalive", 30, 0, function()
    if (DB) then
        DB.Query("SHOW VARIABLES LIKE 'keepalive'")
    end
end)