#include <a_samp>
#include <a_mysql>

#define MySQL_Host      ""
#define MySQL_User      ""
#define MySQL_Pass      ""
#define MySQL_Data      ""

enum pInfo
{
    pNumber
}

new PlayerInfo[MAX_PLAYERS][pInfo];

main()
{
}

public OnPlayerConnect(playerid)
{
    do { PlayerInfo[playerid][pNumber] = 1000 + random(8999); }
    while(IsNumberTaken(playerid));
    return 1;
}

public OnPlayerDisconnect(playerid, reason)
{
    new query[90];
    format(query, sizeof query, "SELECT * FROM `Accounts` WHERE `Username` = '%s'", GetName(playerid));
    mysql_query(query);
    mysql_store_result();

    if(mysql_num_rows())
    {
        format(query, sizeof query, "UPDATE `Accounts` SET `Number` = %i WHERE `Username` = '%s'", PlayerInfo[playerid][pNumber], GetName(playerid));
        mysql_query(query);
    }
    else
    {
        format(query, sizeof query, "INSERT INTO `Accounts` (`Username`, `Number`) VALUES('%s', %i)", GetName(playerid), PlayerInfo[playerid][pNumber]);
        mysql_query(query);
    }

    mysql_free_result();
    return 1;
}

public OnGameModeInit()
{
    SetGameModeText("Coming Soon");

    mysql_debug(1);
    mysql_connect(MySQL_Host, MySQL_User, MySQL_Data, MySQL_Pass);
    return 1;
}

public OnGameModeExit()
{
    mysql_close();
    return 1;
}

forward IsNumberTaken(playerid);
public IsNumberTaken(playerid)
{
    for(new i = 0; i < MAX_PLAYERS; i++) if(PlayerInfo[i][pNumber] == PlayerInfo[playerid][pNumber] && i != playerid) return 1;

    new query[50];
    format(query, sizeof query, "SELECT * FROM `Accounts` WHERE `Number` = %i", PlayerInfo[playerid][pNumber]);
    mysql_query(query);
    mysql_store_result();

    if(mysql_num_rows()) return 1;

    mysql_free_result();
    return 0;
}

stock GetName(playerid)
{
    new name[MAX_PLAYER_NAME], escaped[MAX_PLAYER_NAME];
    GetPlayerName(playerid, name, sizeof name);
    mysql_real_escape_string(name, escaped);
    return escaped;
}