local DATABASE_HOST = "137.74.9.117"
local DATABASE_PORT = 3306
local DATABASE_NAME = "realism"
local DATABASE_USERNAME = "els"
local DATABASE_PASSWORD = "Lsasbpb34"

RealEntrprsDB = {}
require("mysqloo")
RealEntrprsDB.db = mysqloo.connect( DATABASE_HOST, DATABASE_USERNAME, DATABASE_PASSWORD, DATABASE_NAME, DATABASE_PORT )

function RealEntrprsDB_Init()
    use_mysqloo = file.Exists("bin/gmsv_mysqloo_*.dll", "LUA")
    if use_mysqloo then
    RealEntrprsDB_ConnectToDatabase()
    timer.Simple(60, RealEntrprsDB_Init )
    else
    ServerLog("RealEntrprs: Erreur modul mysqloo")
    end

end
hook.Add( "Initialize", "RealEntrprsDB_Init", RealEntrprsDB_Init )

function RealEntrprsDB_Format( str )
    if not str then return "NULL" end
    return string.format( "%q", str )
end

function Escape( str )
    if not RealEntrprsDB.db then
        Msg( "Non connecté à la DB.\n" )
        return
    end

    if not str then return end

    local esc = RealEntrprsDB.db:escape( str )
    if not esc then
        return nil
    end
    return "'" .. esc .. "'"
end

function RealEntrprsDB.db:onConnected(db)
print("Connecté")
end

function RealEntrprsDB.db:onConnectionFailed( db, err )
print("Database connecion probleme")
print(err)
end

function RealEntrprsDB_ConnectToDatabase()
    if not IsValid(RealEntrprsDB.db) then
        RealEntrprsDB.db:connect()
        return
    end

    if RealEntrprsDB.db:status() ~= 0 then
        RealEntrprsDB.db:connect()
        return
    end

end




function RealEntrprs_tbl_exist()
    print(RealEntrprsDB.db:status())

    local db = RealEntrprsDB.db

    print(db:status())


    local query = "CREATE TABLE IF NOT EXISTS RealEntrprs_data ( unique_id VARCHAR(255), nom TEXT, description TEXT, total_ca INTEGER )"
    local q = RealEntrprsDB.db:query( query )
    function q:onSuccess( data )
        ServerLog("RealEntrprs: Check de l'existance de la table RealEntrprs_data. Elle existe ou elle vient d'être créée!\n")
    end
    function q:onError( err )
        if db:status() == mysqloo.DATABASE_NOT_CONNECTED then
            ServerLog("RealEntrprs: DB non connectée, on recommence...\n")
            timer.Simple( 3, function() RealEntrprsDB_ConnectToDatabase() RealEntrprs_tbl_exist() end )
        end
        ServerLog("RealEntrprs: SQL Erreur - " .. err .. " sur le query: " .. query .. "\n")
    end
    q:start()

    local query = "CREATE TABLE IF NOT EXISTS RealEntrprs_ventesdata ( unique_id VARCHAR(255), nom TEXT, produit TEXT, prix INTEGER )"
    local q = RealEntrprsDB.db:query( query )
    function q:onSuccess( data )
        ServerLog("RealEntrprs: Check de l'existance de la table RealEntrprs_ventesdata. Elle existe ou elle vient d'être créée!\n")
    end
    function q:onError( err )
        if db:status() == mysqloo.DATABASE_NOT_CONNECTED then
            ServerLog("RealEntrprs: DB non connectée, on recommence...\n")
            timer.Simple( 3, function() RealEntrprsDB_ConnectToDatabase() RealEntrprs_tbl_exist() end )
        end
        ServerLog("RealEntrprs: SQL Erreur - " .. err .. " sur le query: " .. query .. "\n")
    end
    q:start()

    local query = "CREATE TABLE IF NOT EXISTS RealEntrprs_pnjsdata ( nom TEXT, title_pnj TEXT, description_pnj TEXT, position_pnj VARCHAR(255), model_pnj TEXT )"
    local q = RealEntrprsDB.db:query( query )
    function q:onSuccess( data )
        ServerLog("RealEntrprs: Check de l'existance de la table RealEntrprs_pnjsdata. Elle existe ou elle vient d'être créée!\n")
    end
    function q:onError( err )
        if db:status() == mysqloo.DATABASE_NOT_CONNECTED then
            ServerLog("RealEntrprs: DB non connectée, on recommence...\n")
            timer.Simple( 3, function() RealEntrprsDB_ConnectToDatabase() RealEntrprs_tbl_exist() end )
        end
        ServerLog("RealEntrprs: SQL Erreur - " .. err .. " sur le query: " .. query .. "\n")
    end
    q:start()

    local query = "CREATE TABLE IF NOT EXISTS RealEntrprs_produitsdata ( nom TEXT, title_pnj TEXT, nom_produit TEXT, description_produit TEXT, prix_produit INTEGER, stock_produit INTEGER )"
    local q = RealEntrprsDB.db:query( query )
    function q:onSuccess( data )
        ServerLog("RealEntrprs: Check de l'existance de la table RealEntrprs_produitsdata. Elle existe ou elle vient d'être créée!\n")
    end
    function q:onError( err )
        if db:status() == mysqloo.DATABASE_NOT_CONNECTED then
            ServerLog("RealEntrprs: DB non connectée, on recommence...\n")
            timer.Simple( 3, function() RealEntrprsDB_ConnectToDatabase() RealEntrprs_tbl_exist() end )
        end
        ServerLog("RealEntrprs: SQL Erreur - " .. err .. " sur le query: " .. query .. "\n")
    end
    q:start()
end

--ADD
function RealEntrprs_addentreprise( uid, nom, description )
    local query = RealEntrprsDB.db:query( "INSERT INTO RealEntrprs_data VALUES ('" ..uid.. "', '" ..nom.. "', '" ..description.. "', '0')" )
    query:start()
end
function RealEntrprs_addpnj( nom, titre, description, position, model )
    local query = RealEntrprsDB.db:query("INSERT INTO RealEntrprs_pnjsdata VALUES ('" ..nom.. "', '" ..titre.. "', '" ..description.. "', '" ..model.. "'')")
    query:start()
end
function RealEntrprs_addproduit( nom, titre_pnj, nom_produit, description, prix )
    local query = RealEntrprsDB.db:query("INSERT INTO RealEntrprs_produitsdata VALUES ('" ..nom.. "', '" ..titre_pnj.. "', '" ..nom_produit.. "', '" ..description.. "', '" .. prix.. "'')")
    query:start()
end

--GET
function RealEntrprs_getentreprises( ply )
    local uid = ply:SteamID64()
    local query = RealEntrprsDB.db:query("SELECT * FROM RealEntrprs_data WHERE unique_id='" .. uid .. "'")
    query:start()
        function query:onSuccess( result )
            if result then
                net.Start("SendPlayerEntreprises")
                    net.WriteTable( result )
                net.Send( ply )
            else
                result = {}
                net.Start("SendPlayerEntreprises")
                    net.WriteTable( result )
                net.Send( ply )
            end
        end
end


--MODIFY


--DELETE
function RealEntrprs_delentreprise( nom )
    local query = RealEntrprsDB.db:query("DELETE FROM RealEntrprs_data WHERE nom='" ..nom.. "'")
    querystart()

    local query = RealEntrprsDB.db:query("DELETE FROM RealEntrprs_ventesdata WHERE nom='" ..nom.. "'")
    query:start()

    local query = RealEntrprsDB.db:query("DELETE FROM RealEntrprs_pnjsdata WHERE nom='" ..nom.. "'")
    query:start()

    local query = RealEntrprsDB.db:query("DELETE FROM RealEntrprs_produitsdata WHERE nom='" ..nom.. "'")
    query:start()

end
function RealEntrprs_delproduit( nom, titre_pnj, nom_produit )

    local query = RealEntrprsDB.db:query("DELETE FROM RealEntrprs_produitsdata WHERE nom='" ..nom.. "' and titre_pnj='"..titre_pnj.. "' and nom_produit='"..nom_produit.."'")
    query:start()
end
function RealEntrprs_delpnj( titre )
    local query = RealEntrprsDB.db:query("DELETE FROM RealEntrprs_pnjsdata WHERE titre_pnj='" ..titre.. "'")
    query:start()

    local query = RealEntrprsDB.db:query("DELETE FROM RealEntrprs_produitsdata WHERE titre_pnj='" ..titre.. "'")
    query:start()

end