diff --git a/common/dbcore.cpp b/common/dbcore.cpp index ce1b41bdc..9b6236e5a 100644 --- a/common/dbcore.cpp +++ b/common/dbcore.cpp @@ -58,6 +58,11 @@ void DBcore::ping() { MDatabase.unlock(); } +MySQLRequestResult DBcore::QueryDatabase(std::string query, bool retryOnFailureOnce) +{ + return QueryDatabase(query.c_str(), query.length(), retryOnFailureOnce); +} + MySQLRequestResult DBcore::QueryDatabase(const char* query, uint32 querylen, bool retryOnFailureOnce) { LockMutex lock(&MDatabase); diff --git a/common/dbcore.h b/common/dbcore.h index 13a395eac..2c3602a81 100644 --- a/common/dbcore.h +++ b/common/dbcore.h @@ -7,6 +7,7 @@ #endif #include +#include #include "../common/types.h" #include "../common/Mutex.h" #include "../common/linked_list.h" @@ -24,6 +25,7 @@ public: eStatus GetStatus() { return pStatus; } bool RunQuery(const char* query, uint32 querylen, char* errbuf = 0, MYSQL_RES** result = 0, uint32* affected_rows = 0, uint32* last_insert_id = 0, uint32* errnum = 0, bool retry = true); MySQLRequestResult QueryDatabase(const char* query, uint32 querylen, bool retryOnFailureOnce = true); + MySQLRequestResult QueryDatabase(std::string query, bool retryOnFailureOnce = true); uint32 DoEscapeString(char* tobuf, const char* frombuf, uint32 fromlen); void ping(); MYSQL* getMySQL(){ return &mysql; }