/*
				RFT MySql Version 1.1.0
				© 2012 by RFT

*/
#include <a_samp>
#include <a_mysql>


/*
native r_mysql_Connect_To_Database(host[], user[], password[], database[]);
native r_LoadSQLEntrance(Table[], Where1[], Where2[]);
native r_UnloadSQLEntrance();
native r_mysql_GetString(Var[]);
native r_mysql_GetFloat(Var[]);
native r_mysql_GetInt(Var[]);
native r_mysql_SetString(Var[], to[]);
native r_mysql_SetFloat(Var[], Float:to);
native r_mysql_SetInt(Var[], to);
*/





new bool:r_in_use=false;
new bool:r_GET[3][64];





stock r_mysql_Connect_To_Database(host[], user[], password[], database[])
{
	printf("MySql: Verbindung zur Datenbank: %s wird hergestellt...", database);
	mysql_connect(host, user, database, password);
	if(mysql_ping()!=1)
	{
		printf("MySql: Verbindung zur Datenbank %s konnte nicht hergestellt werden.", database);
		printf("MySql: Es wird erneut versucht eine Verbindung zur Datenbank %s herzustellen...", database);
		mysql_connect(host, user, database, password);
		if(mysql_ping()!=1)
		{
		    printf("MySql: Es konnte erneut keine Verbindung zur Datenbank: %s hergestellt werden. Der Server wird beendet.", database);
		    SendRconCommand("exit");
		    return true;
		}
		else printf("MySql: Der erneute versuch eine Verbindung zur Datenbank: %s herzustellen war erfolgreich.", database);
	}
	else printf("MySql: Verbindung zur Datenbank: %s erfolgreich hergestellt...", database);
	return true;
}

stock r_LoadSQLEntrance(Table[], Where1[], Where2[])
{
	new query[128];
	if(r_in_use==false)
	{
	    strmid(r_GET[0], Table, 0, strlen(Table), 64);
		strmid(r_GET[1], Where1, 0, strlen(Where1), 64);
		strmid(r_GET[2], Where2, 0, strlen(Where2), 64);
		format(query, sizeof(query), "SELECT * FROM %s WHERE `%s`='%s'", Table, Where1, Where2);
		mysql_query(query);
		mysql_store_result();
		mysql_retrieve_row();
		r_in_use=true;
		return 1;
	}
	else
	{
	    print("[RFT_MYSQL]Fehler");
	    return 0;
	}
}

stock r_UpdateRow()
{
	r_UnloadSQLEntrance();
    r_LoadSQLEntrance(r_GET[0], r_GET[1], r_GET[2]);
    return true;
}

stock r_mysql_GetString(Var[])
{
	new load[128];
	mysql_fetch_field_row(load, Var);
	return load;
}

stock Float:r_mysql_GetFloat(Var[])
{
	return floatstr(r_mysql_GetString(Var));
}

stock r_mysql_GetInt(Var[])
{
	return strval(r_mysql_GetString(Var));
}

stock r_mysql_SetString(Var[], to[])
{
	if(r_in_use==true)
	{
		new query[128];
		format(query, sizeof(query), "UPDATE %s SET `%s` = '%s' WHERE `%s` = '%s'", r_GET[0], Var, to, r_GET[1], r_GET[2]);
		mysql_query(query);
		r_UpdateRow();
		return 1;
	}
	return 0;
}

stock r_mysql_SetFloat(Var[], Float:to)
{
	new str[32];
	format(str, sizeof(str), "%f", to);
	r_mysql_SetString(Var, str);
	return 1;
}

stock r_mysql_SetInt(Var[], to)
{
	new str[32];
	format(str, sizeof(str), "%d", to);
	r_mysql_SetString(Var, str);
	return 1;
}

stock r_UnloadSQLEntrance()
{
	if(r_in_use==true)
	{
	    r_in_use=false;
	    mysql_free_result();
	    return 1;
	}
	else return 0;
}