// BuffDatabaseSQL.cpp

#include "Net7.h"

#ifdef USE_MYSQL_SECTOR

#include "BuffDatabaseSQL.h"
#include "mysql/mysqlplus.h"
#include "StringManager.h"


BuffContent::BuffContent()
{
	m_BuffData.clear();
	m_updating = false;
}

BuffContent::~BuffContent()
{
    m_BuffData.clear();
}

bool BuffContent::LoadBuffContent()
{
	char QueryString[1024];

	if (m_updating) return false;

	m_updating = true;

	LogMessage("Loading Buff Data...");

	if(!g_MySQL_User || !g_MySQL_Pass)
    {
		LogMessage("You need to set a mysql user/pass in the net7.cfg\n");
		return false;
	}

	sql_connection_c connection( "net7", g_MySQL_Host, g_MySQL_User, g_MySQL_Pass);
	sql_query_c BuffTable( &connection );
    sql_result_c result;
	sql_result_c *buff_result = &result;

    sprintf(QueryString, "SELECT * FROM `buffs`");

    if ( !BuffTable.execute( QueryString ) )
    {
        LogMessage( "MySQL Login error/Database error: (User: %s Pass: %s)\n", g_MySQL_User, g_MySQL_Pass );
        return false;
    }

    BuffTable.store(buff_result);

    if (!buff_result->n_rows() || !buff_result->n_fields())
    {
        LogMessage("Error loading rows/fields\n");
        return false;
    }

	sql_row_c BuffSQLData;
	for(unsigned int x=0;x<buff_result->n_rows();x++)
	{
		struct BuffData current_buff;
		memset(&current_buff, 0, sizeof(BuffData));

		buff_result->fetch_row(&BuffSQLData);
		const char * name = g_StringMgr->GetStr(BuffSQLData["buff_name"]);
		m_BuffData[name].EffectID = BuffSQLData["EffectID"];
		m_BuffData[name].EffectLength = BuffSQLData["EffectLength"];
    }

	m_updating = false;

	LogMessage("Buff Data Loaded.\n");

    return true;
}

long BuffContent::GetBuffEffect(char *buff)
{
	if (m_BuffData.count(buff) > 0)
	{
		return m_BuffData[buff].EffectID;
	}

	return -1;
}

long BuffContent::GetBuffEffectTime(char *buff)
{
	if (m_BuffData.count(buff) > 0)
	{
		return m_BuffData[buff].EffectLength;
	}

	return -1;
}

#endif