diff --git a/src/game/server/score/sql_score.cpp b/src/game/server/score/sql_score.cpp
new file mode 100644
index 000000000..aee288fe5
--- /dev/null
+++ b/src/game/server/score/sql_score.cpp
@@ -0,0 +1,519 @@
+/* CSqlScore class by Sushi */
+#include <string.h>
+
+#include <engine/shared/config.h>
+#include "../entities/character.h"
+#include "../gamemodes/race.h"
+#include "sql_score.h"
+
+static LOCK gs_SqlLock = 0;
+
+CSqlScore::CSqlScore(CGameContext *pGameServer)
+: m_pGameServer(pGameServer),
+  m_pServer(pGameServer->Server()),
+  m_pDatabase(g_Config.m_SvSqlDatabase),
+  m_pPrefix(g_Config.m_SvSqlPrefix),
+  m_pUser(g_Config.m_SvSqlUser),
+  m_pPass(g_Config.m_SvSqlPw),
+  m_pIp(g_Config.m_SvSqlIp),
+  m_Port(g_Config.m_SvSqlPort)
+{
+	str_copy(m_aMap, g_Config.m_SvMap, sizeof(m_aMap));
+	ClearString(m_aMap);
+	
+	if(gs_SqlLock == 0)
+		gs_SqlLock = lock_create();
+	
+	Init();
+}
+
+CSqlScore::~CSqlScore()
+{
+	lock_wait(gs_SqlLock);
+	lock_release(gs_SqlLock);
+}
+
+bool CSqlScore::Connect()
+{
+	try 
+	{
+		// Create connection
+		m_pDriver = get_driver_instance();
+		char aBuf[256];
+		str_format(aBuf, sizeof(aBuf), "tcp://%s:%d", m_pIp, m_Port);
+		m_pConnection = m_pDriver->connect(aBuf, m_pUser, m_pPass);
+		
+		// Create Statement
+		m_pStatement = m_pConnection->createStatement();
+		
+		// Create database if not exists
+		str_format(aBuf, sizeof(aBuf), "CREATE DATABASE IF NOT EXISTS %s", m_pDatabase);
+		m_pStatement->execute(aBuf);
+		
+		// Connect to specific database
+		m_pConnection->setSchema(m_pDatabase);
+		dbg_msg("SQL", "SQL connection established");
+		return true;
+	} 
+	catch (sql::SQLException &e)
+	{
+		dbg_msg("SQL", "ERROR: SQL connection failed");
+		return false;
+	}
+	return false;
+}
+
+void CSqlScore::Disconnect()
+{
+	try
+	{
+		delete m_pConnection;
+		dbg_msg("SQL", "SQL connection disconnected");
+	}
+	catch (sql::SQLException &e)
+	{
+		dbg_msg("SQL", "ERROR: No SQL connection");
+	}
+}
+
+// create tables... should be done only once
+void CSqlScore::Init()
+{
+	// create connection
+	if(Connect())
+	{
+		try
+		{
+			// create tables
+			char aBuf[768];
+			str_format(aBuf, sizeof(aBuf), "CREATE TABLE IF NOT EXISTS %s_%s_race (Name VARCHAR(31) NOT NULL, Time FLOAT DEFAULT 0, IP VARCHAR(16) DEFAULT '0.0.0.0', cp1 FLOAT DEFAULT 0, cp2 FLOAT DEFAULT 0, cp3 FLOAT DEFAULT 0, cp4 FLOAT DEFAULT 0, cp5 FLOAT DEFAULT 0, cp6 FLOAT DEFAULT 0, cp7 FLOAT DEFAULT 0, cp8 FLOAT DEFAULT 0, cp9 FLOAT DEFAULT 0, cp10 FLOAT DEFAULT 0, cp11 FLOAT DEFAULT 0, cp12 FLOAT DEFAULT 0, cp13 FLOAT DEFAULT 0, cp14 FLOAT DEFAULT 0, cp15 FLOAT DEFAULT 0, cp16 FLOAT DEFAULT 0, cp17 FLOAT DEFAULT 0, cp18 FLOAT DEFAULT 0, cp19 FLOAT DEFAULT 0, cp20 FLOAT DEFAULT 0, cp21 FLOAT DEFAULT 0, cp22 FLOAT DEFAULT 0, cp23 FLOAT DEFAULT 0, cp24 FLOAT DEFAULT 0, cp25 FLOAT DEFAULT 0);", m_pPrefix, m_aMap);
+			m_pStatement->execute(aBuf);
+			dbg_msg("SQL", "Tables were created successfully");
+			
+			// get the best time
+			str_format(aBuf, sizeof(aBuf), "SELECT Time FROM %s_%s_race ORDER BY `Time` ASC LIMIT 0, 1;", m_pPrefix, m_aMap);
+			m_pResults = m_pStatement->executeQuery(aBuf);
+			
+			if(m_pResults->next())
+			{
+				((CGameControllerRACE*)GameServer()->m_pController)->m_CurrentRecord = (float)m_pResults->getDouble("Time");
+				
+				dbg_msg("SQL", "Getting best time on server done");
+			
+				// delete results
+				delete m_pResults;
+			}
+				
+			// delete statement
+			delete m_pStatement;
+		}
+		catch (sql::SQLException &e)
+		{
+			dbg_msg("SQL", "ERROR: Tables were NOT created");
+		}
+
+		// disconnect from database
+		Disconnect();
+	}
+}
+
+// update stuff
+void CSqlScore::LoadScoreThread(void *pUser)
+{
+	lock_wait(gs_SqlLock);
+	
+	CSqlScoreData *pData = (CSqlScoreData *)pUser;
+	
+	// Connect to database
+	if(pData->m_pSqlData->Connect())
+	{
+		try
+		{
+			// check strings
+			pData->m_pSqlData->ClearString(pData->m_aName);
+			
+			char aBuf[512];
+			// check if there is an entry with the same ip
+			if(g_Config.m_SvScoreIP)
+			{
+				str_format(aBuf, sizeof(aBuf), "SELECT * FROM %s_%s_race WHERE IP='%s';", pData->m_pSqlData->m_pPrefix, pData->m_pSqlData->m_aMap, pData->m_aIP);
+				pData->m_pSqlData->m_pResults = pData->m_pSqlData->m_pStatement->executeQuery(aBuf);
+				
+				if(pData->m_pSqlData->m_pResults->next())
+				{
+					// get the best time
+					pData->m_pSqlData->PlayerData(pData->m_ClientID)->m_BestTime = (float)pData->m_pSqlData->m_pResults->getDouble("Time");
+					char aColumn[8];
+					for(int i = 0; i < NUM_TELEPORT; i++)
+					{
+						str_format(aColumn, sizeof(aColumn), "cp%d", i+1);
+						pData->m_pSqlData->PlayerData(pData->m_ClientID)->m_aBestCpTime[i] = (float)pData->m_pSqlData->m_pResults->getDouble(aColumn);
+					}
+					
+					dbg_msg("SQL", "Getting best time done");
+				
+					// delete statement and results
+					delete pData->m_pSqlData->m_pStatement;
+					delete pData->m_pSqlData->m_pResults;
+				
+					// disconnect from database
+					pData->m_pSqlData->Disconnect();
+					
+					delete pData;
+
+					lock_release(gs_SqlLock);
+					
+					return;
+				}
+				
+			}
+		
+			str_format(aBuf, sizeof(aBuf), "SELECT * FROM %s_%s_race WHERE Name='%s';", pData->m_pSqlData->m_pPrefix, pData->m_pSqlData->m_aMap, pData->m_aName);
+			pData->m_pSqlData->m_pResults = pData->m_pSqlData->m_pStatement->executeQuery(aBuf);
+			if(pData->m_pSqlData->m_pResults->next())
+			{
+				// check if IP differs
+				const char* pIP = pData->m_pSqlData->m_pResults->getString("IP").c_str();
+				if(str_comp(pIP, pData->m_aIP) != 0)
+				{
+					// set the new ip
+					str_format(aBuf, sizeof(aBuf), "UPDATE %s_%s_race SET IP='%s' WHERE Name='%s';", pData->m_pSqlData->m_pPrefix, pData->m_pSqlData->m_aMap, pData->m_aIP, pData->m_aName);
+					pData->m_pSqlData->m_pStatement->execute(aBuf);
+				}
+				
+				// get the best time
+				pData->m_pSqlData->PlayerData(pData->m_ClientID)->m_BestTime = (float)pData->m_pSqlData->m_pResults->getDouble("Time");
+				char aColumn[8];
+				if(g_Config.m_SvCheckpointSave)
+				{
+					for(int i = 0; i < NUM_TELEPORT; i++)
+					{
+						str_format(aColumn, sizeof(aColumn), "cp%d", i+1);
+						pData->m_pSqlData->PlayerData(pData->m_ClientID)->m_aBestCpTime[i] = (float)pData->m_pSqlData->m_pResults->getDouble(aColumn);
+					}
+				}
+			}
+			
+			dbg_msg("SQL", "Getting best time done");
+			
+			// delete statement and results
+			delete pData->m_pSqlData->m_pStatement;
+			delete pData->m_pSqlData->m_pResults;
+		}
+		catch (sql::SQLException &e)
+		{
+			dbg_msg("SQL", "ERROR: Could not update account");
+		}
+		
+		// disconnect from database
+		pData->m_pSqlData->Disconnect();
+	}
+	
+	delete pData;
+
+	lock_release(gs_SqlLock);
+}
+
+void CSqlScore::LoadScore(int ClientID)
+{
+	CSqlScoreData *Tmp = new CSqlScoreData();
+	Tmp->m_ClientID = ClientID;
+	str_copy(Tmp->m_aName, Server()->ClientName(ClientID), sizeof(Tmp->m_aName));
+	Server()->GetClientIP(ClientID, Tmp->m_aIP, sizeof(Tmp->m_aIP));
+	Tmp->m_pSqlData = this;
+	
+	void *LoadThread = thread_create(LoadScoreThread, Tmp);
+#if defined(CONF_FAMILY_UNIX)
+	pthread_detach((pthread_t)LoadThread);
+#endif
+}
+
+void CSqlScore::SaveScoreThread(void *pUser)
+{
+	lock_wait(gs_SqlLock);
+	
+	CSqlScoreData *pData = (CSqlScoreData *)pUser;
+	
+	// Connect to database
+	if(pData->m_pSqlData->Connect())
+	{
+		try
+		{
+			// check strings
+			pData->m_pSqlData->ClearString(pData->m_aName);
+			
+			char aBuf[768];
+			
+			// fisrt check for IP
+			str_format(aBuf, sizeof(aBuf), "SELECT * FROM %s_%s_race WHERE IP='%s';", pData->m_pSqlData->m_pPrefix, pData->m_pSqlData->m_aMap, pData->m_aIP);
+			pData->m_pSqlData->m_pResults = pData->m_pSqlData->m_pStatement->executeQuery(aBuf);
+			
+			// if ip found...
+			if(pData->m_pSqlData->m_pResults->next())
+			{
+				// update time
+				if(g_Config.m_SvCheckpointSave)
+					str_format(aBuf, sizeof(aBuf), "UPDATE %s_%s_race SET Name='%s', Time='%.2f', cp1='%.2f', cp2='%.2f', cp3='%.2f', cp4='%.2f', cp5='%.2f', cp6='%.2f', cp7='%.2f', cp8='%.2f', cp9='%.2f', cp10='%.2f', cp11='%.2f', cp12='%.2f', cp13='%.2f', cp14='%.2f', cp15='%.2f', cp16='%.2f', cp17='%.2f', cp18='%.2f', cp19='%.2f', cp20='%.2f', cp21='%.2f', cp22='%.2f', cp23='%.2f', cp24='%.2f', cp25='%.2f' WHERE IP='%s';", pData->m_pSqlData->m_pPrefix, pData->m_pSqlData->m_aMap, pData->m_aName, pData->m_Time, pData->m_aCpCurrent[0], pData->m_aCpCurrent[1], pData->m_aCpCurrent[2], pData->m_aCpCurrent[3], pData->m_aCpCurrent[4], pData->m_aCpCurrent[5], pData->m_aCpCurrent[6], pData->m_aCpCurrent[7], pData->m_aCpCurrent[8], pData->m_aCpCurrent[9], pData->m_aCpCurrent[10], pData->m_aCpCurrent[11], pData->m_aCpCurrent[12], pData->m_aCpCurrent[13], pData->m_aCpCurrent[14], pData->m_aCpCurrent[15], pData->m_aCpCurrent[16], pData->m_aCpCurrent[17], pData->m_aCpCurrent[18], pData->m_aCpCurrent[19], pData->m_aCpCurrent[20], pData->m_aCpCurrent[21], pData->m_aCpCurrent[22], pData->m_aCpCurrent[23], pData->m_aCpCurrent[24], pData->m_aIP);
+				else
+					str_format(aBuf, sizeof(aBuf), "UPDATE %s_%s_race SET Name='%s', Time='%.2f' WHERE IP='%s';", pData->m_pSqlData->m_pPrefix, pData->m_pSqlData->m_aMap, pData->m_aName, pData->m_Time, pData->m_aIP);
+				pData->m_pSqlData->m_pStatement->execute(aBuf);
+				
+				dbg_msg("SQL", "Updateing time done");
+				
+				// delete results statement
+				delete pData->m_pSqlData->m_pResults;
+				delete pData->m_pSqlData->m_pStatement;
+				
+				// disconnect from database
+				pData->m_pSqlData->Disconnect();
+				
+				delete pData;
+				
+				lock_release(gs_SqlLock);
+				
+				return;
+			}
+			
+			// if no entry found... create a new one
+			str_format(aBuf, sizeof(aBuf), "INSERT IGNORE INTO %s_%s_race(Name, IP, Time, cp1, cp2, cp3, cp4, cp5, cp6, cp7, cp8, cp9, cp10, cp11, cp12, cp13, cp14, cp15, cp16, cp17, cp18, cp19, cp20, cp21, cp22, cp23, cp24, cp25) VALUES ('%s', '%s', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f', '%.2f');", pData->m_pSqlData->m_pPrefix, pData->m_pSqlData->m_aMap, pData->m_aName, pData->m_aIP, pData->m_Time, pData->m_aCpCurrent[0], pData->m_aCpCurrent[1], pData->m_aCpCurrent[2], pData->m_aCpCurrent[3], pData->m_aCpCurrent[4], pData->m_aCpCurrent[5], pData->m_aCpCurrent[6], pData->m_aCpCurrent[7], pData->m_aCpCurrent[8], pData->m_aCpCurrent[9], pData->m_aCpCurrent[10], pData->m_aCpCurrent[11], pData->m_aCpCurrent[12], pData->m_aCpCurrent[13], pData->m_aCpCurrent[14], pData->m_aCpCurrent[15], pData->m_aCpCurrent[16], pData->m_aCpCurrent[17], pData->m_aCpCurrent[18], pData->m_aCpCurrent[19], pData->m_aCpCurrent[20], pData->m_aCpCurrent[21], pData->m_aCpCurrent[22], pData->m_aCpCurrent[23], pData->m_aCpCurrent[24]);
+			pData->m_pSqlData->m_pStatement->execute(aBuf);
+			
+			dbg_msg("SQL", "Updateing time done");
+			
+			// delete results statement
+			delete pData->m_pSqlData->m_pResults;
+			delete pData->m_pSqlData->m_pStatement;
+		}
+		catch (sql::SQLException &e)
+		{
+			dbg_msg("SQL", "ERROR: Could not update time");
+		}
+		
+		// disconnect from database
+		pData->m_pSqlData->Disconnect();
+	}
+	
+	delete pData;
+
+	lock_release(gs_SqlLock);
+}
+
+void CSqlScore::SaveScore(int ClientID, float Time, CCharacter *pChar)
+{
+	CSqlScoreData *Tmp = new CSqlScoreData();
+	Tmp->m_ClientID = ClientID;
+	str_copy(Tmp->m_aName, Server()->ClientName(ClientID), sizeof(Tmp->m_aName));
+	Server()->GetClientIP(ClientID, Tmp->m_aIP, sizeof(Tmp->m_aIP));
+	Tmp->m_Time = Time;
+	for(int i = 0; i < NUM_TELEPORT; i++)
+		Tmp->m_aCpCurrent[i] = pChar->m_CpCurrent[i];
+	Tmp->m_pSqlData = this;
+	
+	void *SaveThread = thread_create(SaveScoreThread, Tmp);
+#if defined(CONF_FAMILY_UNIX)
+	pthread_detach((pthread_t)SaveThread);
+#endif
+}
+
+void CSqlScore::ShowRankThread(void *pUser)
+{
+	lock_wait(gs_SqlLock);
+	
+	CSqlScoreData *pData = (CSqlScoreData *)pUser;
+	
+	// Connect to database
+	if(pData->m_pSqlData->Connect())
+	{
+		try
+		{
+			// check strings
+			pData->m_pSqlData->ClearString(pData->m_aName);
+			
+			// check sort methode
+			char aBuf[512];
+			str_format(aBuf, sizeof(aBuf), "SELECT Name, IP, Time FROM %s_%s_race ORDER BY `Time` ASC;", pData->m_pSqlData->m_pPrefix, pData->m_pSqlData->m_aMap);
+			pData->m_pSqlData->m_pResults = pData->m_pSqlData->m_pStatement->executeQuery(aBuf);
+			int RowCount = 0;
+			bool Found = false;
+			while(pData->m_pSqlData->m_pResults->next())
+			{
+				RowCount++;
+				
+				if(pData->m_Search)
+				{
+					if(str_find_nocase(pData->m_pSqlData->m_pResults->getString("Name").c_str(), pData->m_aName))
+					{
+						Found = true;
+						break;
+					}
+				}
+				else if(!str_comp(pData->m_pSqlData->m_pResults->getString("IP").c_str(), pData->m_aIP))
+				{
+					Found = true;
+					break;
+				}
+			}
+			
+			if(!Found)
+			{
+				str_format(aBuf, sizeof(aBuf), "%s is not ranked", pData->m_aName);
+				pData->m_pSqlData->GameServer()->SendChatTarget(pData->m_ClientID, aBuf);
+			}
+			else
+			{
+				float Time = (float)pData->m_pSqlData->m_pResults->getDouble("Time");
+				if(!g_Config.m_SvShowTimes)
+					str_format(aBuf, sizeof(aBuf), "Your time: %d minute(s) %5.2f second(s)", (int)(Time/60), Time-((int)Time/60*60));
+				else
+					str_format(aBuf, sizeof(aBuf), "%d. %s Time: %d minute(s) %5.2f second(s)", RowCount, pData->m_pSqlData->m_pResults->getString("Name").c_str(), (int)(Time/60), Time-((int)Time/60*60));
+				
+				if(pData->m_Search)
+					strcat(aBuf, pData->m_aRequestingPlayer);
+					
+				pData->m_pSqlData->GameServer()->SendChatTarget(-1, aBuf);
+			}
+			
+			dbg_msg("SQL", "Showing rank done");
+			
+			// delete results and statement
+			delete pData->m_pSqlData->m_pResults;	
+			delete pData->m_pSqlData->m_pStatement;
+		}
+		catch (sql::SQLException &e)
+		{
+			dbg_msg("SQL", "ERROR: Could not show rank");
+		}
+		
+		// disconnect from database
+		pData->m_pSqlData->Disconnect();
+	}
+	
+	delete pData;
+
+	lock_release(gs_SqlLock);
+}
+
+void CSqlScore::ShowRank(int ClientID, const char* pName, bool Search)
+{
+	CSqlScoreData *Tmp = new CSqlScoreData();
+	Tmp->m_ClientID = ClientID;
+	str_copy(Tmp->m_aName, pName, sizeof(Tmp->m_aName));
+	Server()->GetClientIP(ClientID, Tmp->m_aIP, sizeof(Tmp->m_aIP));
+	Tmp->m_Search = Search;
+	str_format(Tmp->m_aRequestingPlayer, sizeof(Tmp->m_aRequestingPlayer), " (%s)", Server()->ClientName(ClientID));
+	Tmp->m_pSqlData = this;
+	
+	void *RankThread = thread_create(ShowRankThread, Tmp);
+#if defined(CONF_FAMILY_UNIX)
+	pthread_detach((pthread_t)RankThread);
+#endif
+}
+
+void CSqlScore::ShowTop5Thread(void *pUser)
+{
+	lock_wait(gs_SqlLock);
+	
+	CSqlScoreData *pData = (CSqlScoreData *)pUser;
+	
+	// Connect to database
+	if(pData->m_pSqlData->Connect())
+	{
+		try
+		{
+			// check sort methode
+			char aBuf[512];
+			str_format(aBuf, sizeof(aBuf), "SELECT Name, Time FROM %s_%s_race ORDER BY `Time` ASC LIMIT %d, 5;", pData->m_pSqlData->m_pPrefix, pData->m_pSqlData->m_aMap, pData->m_Num-1);
+			pData->m_pSqlData->m_pResults = pData->m_pSqlData->m_pStatement->executeQuery(aBuf);
+			
+			// show top5
+			pData->m_pSqlData->GameServer()->SendChatTarget(pData->m_ClientID, "----------- Top 5 -----------");
+			
+			int Rank = pData->m_Num;
+			float Time = 0;
+			while(pData->m_pSqlData->m_pResults->next())
+			{
+				Time = (float)pData->m_pSqlData->m_pResults->getDouble("Time");
+				str_format(aBuf, sizeof(aBuf), "%d. %s Time: %d minute(s) %.2f second(s)", Rank, pData->m_pSqlData->m_pResults->getString("Name").c_str(), (int)(Time/60),  Time-((int)Time/60*60));
+				pData->m_pSqlData->GameServer()->SendChatTarget(pData->m_ClientID, aBuf);
+				Rank++;
+			}
+			pData->m_pSqlData->GameServer()->SendChatTarget(pData->m_ClientID, "------------------------------");
+			
+			dbg_msg("SQL", "Showing top5 done");
+			
+			// delete results and statement
+			delete pData->m_pSqlData->m_pResults;
+			delete pData->m_pSqlData->m_pStatement;
+		}
+		catch (sql::SQLException &e)
+		{
+			dbg_msg("SQL", "ERROR: Could not show top5");
+		}
+		
+		// disconnect from database
+		pData->m_pSqlData->Disconnect();
+	}
+	
+	delete pData;
+
+	lock_release(gs_SqlLock);
+}
+
+void CSqlScore::ShowTop5(int ClientID, int Debut)
+{
+	CSqlScoreData *Tmp = new CSqlScoreData();
+	Tmp->m_Num = Debut;
+	Tmp->m_ClientID = ClientID;
+	Tmp->m_pSqlData = this;
+	
+	void *Top5Thread = thread_create(ShowTop5Thread, Tmp);
+#if defined(CONF_FAMILY_UNIX)
+	pthread_detach((pthread_t)Top5Thread);
+#endif
+}
+
+// anti SQL injection
+void CSqlScore::ClearString(char *pString)
+{	
+	// replace ' ' ' with ' \' ' and remove '\'
+	for(int i = 0; i < str_length(pString); i++)
+	{
+		// replace '-' with '_'
+		if(pString[i] == '-')
+			pString[i] = '_';
+		
+		if(pString[i] == '\'')
+		{
+			// count \ before the '
+			int SlashCount = 0;
+			for(int j = i-1; j >= 0; j--)
+			{
+				if(pString[i] != '\\')
+					break;
+				
+				SlashCount++;
+			}
+			
+			if(SlashCount % 2 == 0)
+			{
+				for(int j = str_length(pString)-1; j > i; j--)
+				{
+					pString[j] = pString[j-1];
+				}
+				pString[i] = '\\';
+				i++;
+			}
+		}
+	}
+
+	// aaand remove spaces and \ at the end xD
+	for(int i = str_length(pString)-1; i >= 0; i--)
+	{
+		if(pString[i] == ' ' || pString[i] == '\\')
+			pString[i] = '\0';
+		else
+			break;
+	}
+}
+
+
diff --git a/src/game/server/score/sql_score.h b/src/game/server/score/sql_score.h
new file mode 100644
index 000000000..1a7f0a4c2
--- /dev/null
+++ b/src/game/server/score/sql_score.h
@@ -0,0 +1,73 @@
+/* CSqlScore Class by Sushi */
+#ifndef GAME_SERVER_SQLSCORE_H
+#define GAME_SERVER_SQLSCORE_H
+
+#include <mysql_connection.h>
+
+#include <cppconn/driver.h>
+#include <cppconn/exception.h>
+#include <cppconn/resultset.h>
+#include <cppconn/statement.h>
+
+#include "../score.h"
+
+class CSqlScore : public IScore
+{
+	CGameContext *m_pGameServer;
+	IServer *m_pServer;
+	
+	sql::Driver *m_pDriver;
+	sql::Connection *m_pConnection;
+	sql::Statement *m_pStatement;
+	sql::ResultSet *m_pResults;
+	
+	// copy of config vars
+	const char* m_pDatabase;
+	const char* m_pPrefix;
+	const char* m_pUser;
+	const char* m_pPass;
+	const char* m_pIp;
+	char m_aMap[64];
+	int m_Port;
+	
+	CGameContext *GameServer() { return m_pGameServer; }
+	IServer *Server() { return m_pServer; }
+	
+	static void LoadScoreThread(void *pUser);
+	static void SaveScoreThread(void *pUser);
+	static void ShowRankThread(void *pUser);
+	static void ShowTop5Thread(void *pUser);
+	
+	void Init();
+	
+	bool Connect();
+	void Disconnect();
+	
+	// anti SQL injection
+	void ClearString(char *pString);
+	
+public:
+	
+	CSqlScore(CGameContext *pGameServer);
+	~CSqlScore();
+	
+	virtual void LoadScore(int ClientID);
+	virtual void SaveScore(int ClientID, float Time, CCharacter *pChar);
+	virtual void ShowRank(int ClientID, const char* pName, bool Search=false);
+	virtual void ShowTop5(int ClientID, int Debut=1);
+};
+
+struct CSqlScoreData
+{
+	CSqlScore *m_pSqlData;
+	int m_ClientID;
+	char m_aName[16];
+	char m_aIP[16];
+	float m_Time;
+	float m_aCpCurrent[NUM_TELEPORT];
+	int m_Num;
+	bool m_Search;
+	char m_aRequestingPlayer[MAX_NAME_LENGTH];
+};
+
+#endif