Adds cvars:
cvar_t *csx_sqlstats_host; cvar_t *csx_sqlstats_username; cvar_t *csx_sqlstats_password; cvar_t *csx_sqlstats_db; cvar_t *csx_sqlstats_table; Exports players' statistics at map change to SQL db right after it saved those to the dat file.
This commit is contained in:
Johnny Bergström
201
dlls/csx_sql/CRank_sql.cpp
Executable file
201
dlls/csx_sql/CRank_sql.cpp
Executable file
@ -0,0 +1,201 @@
|
||||
// The good stuff: http://dev.mysql.com/doc/mysql/en/mysql_query.html
|
||||
|
||||
#include "amxxmodule.h"
|
||||
#include "CRank.h"
|
||||
#include "rank.h"
|
||||
|
||||
#ifndef __linux__
|
||||
#define WINDOWS_LEAN_AND_MEAN
|
||||
#include <winsock.h>
|
||||
#endif
|
||||
#include <mysql/mysql.h>
|
||||
#include <mysql/errmsg.h>
|
||||
|
||||
#include <time.h>
|
||||
#define MYSQL_QUERY_IS_A_OKAY 0
|
||||
|
||||
cvar_t init_csx_sqlstats_host = {"csx_sqlstats_ip", "127.0.0.1", FCVAR_SPONLY | FCVAR_PROTECTED};
|
||||
cvar_t init_csx_sqlstats_username = {"csx_sqlstats_username", "", FCVAR_SPONLY | FCVAR_PROTECTED};
|
||||
cvar_t init_csx_sqlstats_password = {"csx_sqlstats_password", "", FCVAR_SPONLY | FCVAR_PROTECTED};
|
||||
cvar_t init_csx_sqlstats_db = {"csx_sqlstats_db", "amxmodx_stats_cs", FCVAR_SPONLY | FCVAR_PROTECTED};
|
||||
cvar_t init_csx_sqlstats_table = {"csx_sqlstats_table", "cs", FCVAR_SPONLY | FCVAR_PROTECTED};
|
||||
cvar_t *csx_sqlstats_host;
|
||||
cvar_t *csx_sqlstats_username;
|
||||
cvar_t *csx_sqlstats_password;
|
||||
cvar_t *csx_sqlstats_db;
|
||||
cvar_t *csx_sqlstats_table;
|
||||
|
||||
void OnMetaAttach_sql() {
|
||||
CVAR_REGISTER(&init_csx_sqlstats_host);
|
||||
CVAR_REGISTER(&init_csx_sqlstats_username);
|
||||
CVAR_REGISTER(&init_csx_sqlstats_password);
|
||||
CVAR_REGISTER(&init_csx_sqlstats_db);
|
||||
CVAR_REGISTER(&init_csx_sqlstats_table);
|
||||
|
||||
csx_sqlstats_host = CVAR_GET_POINTER(init_csx_sqlstats_host.name);
|
||||
csx_sqlstats_username = CVAR_GET_POINTER(init_csx_sqlstats_username.name);
|
||||
csx_sqlstats_password = CVAR_GET_POINTER(init_csx_sqlstats_password.name);
|
||||
csx_sqlstats_db = CVAR_GET_POINTER(init_csx_sqlstats_db.name);
|
||||
csx_sqlstats_table = CVAR_GET_POINTER(init_csx_sqlstats_table.name);
|
||||
}
|
||||
|
||||
int Error(MYSQL *mysql)
|
||||
{
|
||||
if (mysql == NULL)
|
||||
return 0;
|
||||
|
||||
return mysql_errno(mysql);
|
||||
}
|
||||
|
||||
void RankSystem::saveRankSql()
|
||||
{
|
||||
MF_PrintSrvConsole("[CSX Sql] Exporting players' statistics to SQL db...");
|
||||
clock_t startTime = clock();
|
||||
time_t now = time(NULL);
|
||||
|
||||
MYSQL *mysql = NULL;
|
||||
|
||||
mysql = mysql_init(NULL);
|
||||
int port = 0, error = 0;
|
||||
if (!mysql_real_connect(mysql, csx_sqlstats_host->string, csx_sqlstats_username->string, csx_sqlstats_password->string, NULL, port, NULL, 0)) {
|
||||
error = Error(mysql);
|
||||
if (error) {
|
||||
MF_Log("DB Connection failed (%d): %s", error, mysql_error(mysql));
|
||||
mysql_close(mysql);
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
if (mysql_select_db(mysql, csx_sqlstats_db->string) != 0) {
|
||||
error = Error(mysql);
|
||||
if (error) {
|
||||
MF_Log("DB Select DB failed (%d): %s", error, mysql_error(mysql));
|
||||
mysql_close(mysql);
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
// Query
|
||||
char query[1024];
|
||||
int exportedRecords = 0;
|
||||
|
||||
RankSystem::iterator a = front();
|
||||
|
||||
char *authid, *name;
|
||||
int tks, damage, deaths, kills, shots, hits, hs, defusions, defused, plants, explosions, *bodyHits;
|
||||
|
||||
while ( a )
|
||||
{
|
||||
if ( (*a).score != (1<<31) ) // score must be different than mincell
|
||||
{
|
||||
authid = (*a).unique;
|
||||
if (strcmp(authid, "BOT") == 0 || strcmp(authid, "STEAM_ID_PENDING") == 0) {
|
||||
--a;
|
||||
continue;
|
||||
}
|
||||
exportedRecords++;
|
||||
|
||||
name = (*a).name;
|
||||
tks = (*a).tks;
|
||||
damage = (*a).damage;
|
||||
deaths = (*a).deaths;
|
||||
kills = (*a).kills;
|
||||
shots = (*a).shots;
|
||||
hits = (*a).hits;
|
||||
hs = (*a).hs;
|
||||
defusions = (*a).bDefusions;
|
||||
defused = (*a).bDefused;
|
||||
plants = (*a).bPlants;
|
||||
explosions = (*a).bExplosions;
|
||||
bodyHits = ((*a).bodyHits);
|
||||
|
||||
_snprintf(query, 1023, "UPDATE `%s` SET `timestamp` = %d, `stats_name` = \"%s\", `stats_tks` = \"%d\", `stats_damage` = \"%d\", `stats_deaths` = \"%d\", `stats_frags` = \"%d\", `stats_shots` = \"%d\", `stats_hits` = \"%d\", `stats_hs` = \"%d\", `stats_defusions` = \"%d\", `stats_defused` = \"%d\", `stats_plants` = \"%d\", `stats_explosions` = \"%d\", `stats_bodyhits0` = \"%d\", `stats_bodyhits1` = \"%d\", `stats_bodyhits2` = \"%d\", `stats_bodyhits3` = \"%d\", `stats_bodyhits4` = \"%d\", `stats_bodyhits5` = \"%d\", `stats_bodyhits6` = \"%d\", `stats_bodyhits7` = \"%d\", `stats_bodyhits8` = \"%d\" WHERE `stats_authid` = \"%s\" LIMIT 1",
|
||||
csx_sqlstats_table->string,
|
||||
now,
|
||||
name,
|
||||
tks,
|
||||
damage,
|
||||
deaths,
|
||||
kills,
|
||||
shots,
|
||||
hits,
|
||||
hs,
|
||||
defusions,
|
||||
defused,
|
||||
plants,
|
||||
explosions,
|
||||
bodyHits[0],
|
||||
bodyHits[1],
|
||||
bodyHits[2],
|
||||
bodyHits[3],
|
||||
bodyHits[4],
|
||||
bodyHits[5],
|
||||
bodyHits[6],
|
||||
bodyHits[7],
|
||||
bodyHits[8],
|
||||
authid);
|
||||
//
|
||||
|
||||
int queryResult = mysql_query(mysql, query);
|
||||
if (queryResult != MYSQL_QUERY_IS_A_OKAY)
|
||||
{
|
||||
error = Error(mysql);
|
||||
MF_Log("DB Query Update failed (%d): %s", error, mysql_error(mysql));
|
||||
mysql_close(mysql);
|
||||
return;
|
||||
}
|
||||
|
||||
if (mysql_affected_rows(mysql) == 0) {
|
||||
// New player, do insert
|
||||
_snprintf(query, 1023, "INSERT INTO `%s` (`timestamp`, `stats_authid`, `stats_name`, `stats_tks`, `stats_damage`, `stats_deaths`, `stats_frags`, `stats_shots`, `stats_hits`, `stats_hs`, `stats_defusions`, `stats_defused`, `stats_plants`, `stats_explosions`, `stats_bodyhits0`, `stats_bodyhits1`, `stats_bodyhits2`, `stats_bodyhits3`, `stats_bodyhits4`, `stats_bodyhits5`, `stats_bodyhits6`, `stats_bodyhits7`, `stats_bodyhits8`) VALUES (\"%d\", \"%s\", \"%s\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\", \"%d\")",
|
||||
csx_sqlstats_table->string,
|
||||
now,
|
||||
|
||||
authid,
|
||||
name,
|
||||
|
||||
tks,
|
||||
damage,
|
||||
deaths,
|
||||
kills,
|
||||
shots,
|
||||
|
||||
hits,
|
||||
hs,
|
||||
defusions,
|
||||
defused,
|
||||
plants,
|
||||
|
||||
explosions,
|
||||
|
||||
bodyHits[0],
|
||||
bodyHits[1],
|
||||
bodyHits[2],
|
||||
bodyHits[3],
|
||||
bodyHits[4],
|
||||
bodyHits[5],
|
||||
bodyHits[6],
|
||||
bodyHits[7],
|
||||
bodyHits[8]
|
||||
);
|
||||
|
||||
int queryResult = mysql_query(mysql, query);
|
||||
if (queryResult != MYSQL_QUERY_IS_A_OKAY)
|
||||
{
|
||||
error = Error(mysql);
|
||||
MF_Log("DB Query Insert failed (%d): %s", error, mysql_error(mysql));
|
||||
mysql_close(mysql);
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
--a;
|
||||
}
|
||||
|
||||
// Disconnect
|
||||
mysql_close(mysql);
|
||||
|
||||
clock_t stopTime = clock();
|
||||
MF_PrintSrvConsole("...done! (exported %d records in %.2f seconds)\n", exportedRecords, (double)(stopTime - startTime) / (double)CLOCKS_PER_SEC, stopTime, startTime);
|
||||
}
|
||||
Reference in New Issue
Block a user