pa/eqemu-server
2
0
Fork 0
mirror of https://github.com/EQEmu/Server.git synced 2025-12-12 05:21:29 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #195 from addtheice/RunQueryToDatabaseQuery_QGlobals

Browse Source 
Run query to database query q globals
This commit is contained in:
Alex 2014-08-21 14:03:57 -07:00
commit f81acf23a7
2 changed files with 25 additions and 60 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

84
zone/QGlobals.cpp
View File

@ -51,7 +51,7 @@ void QGlobalCache::Combine(std::list<QGlobal> &cacheA, std::list<QGlobal> cacheB
void QGlobalCache::GetQGlobals(std::list<QGlobal> &globals, NPC *n, Client *c, Zone *z) { void QGlobalCache::GetQGlobals(std::list<QGlobal> &globals, NPC *n, Client *c, Zone *z) {
globals.clear(); globals.clear();
QGlobalCache *npc_c = nullptr; QGlobalCache *npc_c = nullptr;
QGlobalCache *char_c = nullptr; QGlobalCache *char_c = nullptr;
QGlobalCache *zone_c = nullptr; QGlobalCache *zone_c = nullptr;
@ -139,75 +139,39 @@ void QGlobalCache::PurgeExpiredGlobals()
void QGlobalCache::LoadByNPCID(uint32 npcID) void QGlobalCache::LoadByNPCID(uint32 npcID)
{ {
char errbuf[MYSQL_ERRMSG_SIZE]; std::string query = StringFormat("SELECT name, charid, npcid, zoneid, value, expdate "
char *query = 0; "FROM quest_globals WHERE npcid = %d", npcID);
MYSQL_RES *result; LoadBy(query);
MYSQL_ROW row;
if (database.RunQuery(query, MakeAnyLenString(&query, "select name, charid, npcid, zoneid, value, expdate"
" from quest_globals where npcid = %d", npcID), errbuf, &result))
{
while((row = mysql_fetch_row(result)))
{
AddGlobal(0, QGlobal(std::string(row[0]), atoi(row[1]), atoi(row[2]), atoi(row[3]), row[4], row[5]?atoi(row[5]):0xFFFFFFFF));
}
mysql_free_result(result);
}
safe_delete_array(query);
} }
void QGlobalCache::LoadByCharID(uint32 charID) void QGlobalCache::LoadByCharID(uint32 charID)
{ {
char errbuf[MYSQL_ERRMSG_SIZE]; std::string query = StringFormat("SELECT name, charid, npcid, zoneid, value, expdate "
char *query = 0; "FROM quest_globals WHERE charid = %d && npcid = 0", charID);
MYSQL_RES *result; LoadBy(query);
MYSQL_ROW row;
if (database.RunQuery(query, MakeAnyLenString(&query, "select name, charid, npcid, zoneid, value, expdate from"
" quest_globals where charid = %d && npcid = 0", charID), errbuf, &result))
{
while((row = mysql_fetch_row(result)))
{
AddGlobal(0, QGlobal(std::string(row[0]), atoi(row[1]), atoi(row[2]), atoi(row[3]), row[4], row[5]?atoi(row[5]):0xFFFFFFFF));
}
mysql_free_result(result);
}
safe_delete_array(query);
} }
void QGlobalCache::LoadByZoneID(uint32 zoneID) void QGlobalCache::LoadByZoneID(uint32 zoneID)
{ {
char errbuf[MYSQL_ERRMSG_SIZE]; std::string query = StringFormat("SELECT name, charid, npcid, zoneid, value, expdate "
char *query = 0; "FROM quest_globals WHERE zoneid = %d && npcid = 0 && charid = 0", zoneID);
MYSQL_RES *result; LoadBy(query);
MYSQL_ROW row;
if (database.RunQuery(query, MakeAnyLenString(&query, "select name, charid, npcid, zoneid, value, expdate from quest_globals"
" where zoneid = %d && npcid = 0 && charid = 0", zoneID), errbuf, &result))
{
while((row = mysql_fetch_row(result)))
{
AddGlobal(0, QGlobal(std::string(row[0]), atoi(row[1]), atoi(row[2]), atoi(row[3]), row[4], row[5]?atoi(row[5]):0xFFFFFFFF));
}
mysql_free_result(result);
}
safe_delete_array(query);
} }
void QGlobalCache::LoadByGlobalContext() void QGlobalCache::LoadByGlobalContext()
{ {
char errbuf[MYSQL_ERRMSG_SIZE]; std::string query = "SELECT name, charid, npcid, zoneid, value, expdate "
char *query = 0; "FROM quest_globals WHERE zoneid = 0 && npcid = 0 && charid = 0";
MYSQL_RES *result; LoadBy(query);
MYSQL_ROW row; }
void QGlobalCache::LoadBy(const std::string query)
{
auto results = database.QueryDatabase(query);
if (!results.Success())
return;
for (auto row = results.begin(); row != results.end(); ++row)
AddGlobal(0, QGlobal(std::string(row[0]), atoi(row[1]), atoi(row[2]), atoi(row[3]), row[4], row[5]? atoi(row[5]): 0xFFFFFFFF));
if (database.RunQuery(query, MakeAnyLenString(&query, "select name, charid, npcid, zoneid, value, expdate from quest_globals"
" where zoneid = 0 && npcid = 0 && charid = 0"), errbuf, &result))
{
while((row = mysql_fetch_row(result)))
{
AddGlobal(0, QGlobal(std::string(row[0]), atoi(row[1]), atoi(row[2]), atoi(row[3]), row[4], row[5]?atoi(row[5]):0xFFFFFFFF));
}
mysql_free_result(result);
}
safe_delete_array(query);
} }

1
zone/QGlobals.h
View File

@ -42,6 +42,7 @@ public:
void LoadByZoneID(uint32 zoneID); //zone void LoadByZoneID(uint32 zoneID); //zone
void LoadByGlobalContext(); //zone void LoadByGlobalContext(); //zone
protected: protected:
void LoadBy(const std::string query);
std::list<QGlobal> qGlobalBucket; std::list<QGlobal> qGlobalBucket;
}; };