W-MySQL Core_mysql.inc

#include <a_mysql>

new Handle;

#define MYSQL_HOST "127.0.0.1"
#define MYSQL_USER "root"
#define MYSQL_DATA "database"
#define MYSQL_PASS ""




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

#if defined _ALS_OnGameModeExit
  #undef OnGameModeExit
#else
#define _ALS_OnGameModeExit
#endif

#define OnGameModeExit L_OnGameModeExit

forward L_OnGameModeExit();





stock GetMysql(table[],field[],where1[]="", is1[]="", where2[]="", is2[]="")
{
    //new where1Ex[50];
    //new is1Ex[50];
    //new where2Ex[50];
    //new is2Ex[50];
    new query[256];
    new random_number = random(999999);

    new pfad[25];
    format(pfad, 25, "/mysql/%d_cache.json",random_number);
    djCreateFile(pfad);

    if(strlen(where1) != 0)
    {
        //mysql_escape_string(where1, where1Ex, Handle, 50);
        //mysql_escape_string(is1, is1Ex, Handle, 50);
        format(query, sizeof(query), " WHERE %s='%s'", where1, is1);
        if(strlen(where2) != 0)
        {
            //mysql_escape_string(where2, where2Ex, Handle, 50);
            //mysql_escape_string(is2, is2Ex, Handle, 50);
            format(query, sizeof(query), "%s AND %s='%s'",query, where2, is2);
        }
    }

    format(query, sizeof(query), "SELECT %s FROM %s%s", field, table, query);
    print(query);
    mysql_tquery(Handle, query, "LoadMysqlData", "d",random_number);

    return random_number;
}

forward LoadMysqlData(cid);
public LoadMysqlData(cid)
{
    new num_fields, num_rows;
    cache_get_data(num_rows, num_fields);

    new pfad[25];
    format(pfad, 25, "/mysql/%d_cache.json",cid);

    djSetInt(pfad,"count",num_rows);
    if(num_rows != 0)
    {
        //Eintrag Vorhanden
        if(num_rows >= 2)
        {
            for(new row = 0; row < num_rows; row ++)
            {
                for(new field = 0; field < num_fields; field++)
                {
                    new field_name[32];
                    cache_get_field_name(field, field_name);
                    new key[32];
                    format(key,32,"%d/%s",row,field_name);
                    new dest[128];
                    cache_get_field_content(row, field_name, dest);
                    djSet(pfad,key,dest);

                }
            }
        }
        else
        {
            for(new field = 0; field < num_fields; field++)
            {
                new field_name[32];
                cache_get_field_name(field, field_name);
                new key[32];
                format(key,32,"0/%s",field_name);
                new dest[128];
                cache_get_field_content(0, field_name, dest);
                djSet(pfad,key,dest);
            }
        }

    }
    return 1;
}

stock DeleteMySQL(_id)
{
    new pfad[25];
    format(pfad, 25, "/mysql/%d_cache.json",_id);
    return djRemoveFile(pfad);
}

stock GetMySQLInt(_id,_key[],_row = 0)
{
    new pfad[25];
    format(pfad, 25, "/mysql/%d_cache.json",_id);

    new key[32];
    format(key, 32, "%d/%s",_row,_key);
    return strval(dj(pfad,_key));
}

stock Float:GetMySQLFloat(_id,_key[],_row = 0)
{
    new pfad[25];
    format(pfad, 25, "/mysql/%d_cache.json",_id);

    new key[32];
    format(key, 32, "%d/%s",_row,_key);
    return floatstr(dj(pfad,_key));
}

stock GetMySQLString(_id,_key[],_row = 0)
{
    new pfad[25];
    format(pfad, 25, "/mysql/%d_cache.json",_id);

    new key[32];
    format(key, 32, "%d/%s",_row,_key);
    return dj(pfad,_key);
}