#include "CDataBase.h"

CDataBase::CDataBase(const char *host, const char *user, const char *passwd, const char *db): 
	m_host(host), m_user(user), m_passwd(passwd), m_db(db), m_bConn(false), m_ErrMsg(NULL)
{
	if (mysql_init(&m_mysql) && mysql_real_connect(&m_mysql, m_host, m_user, m_passwd, m_db, MYSQL_PORT, NULL, 0))
	{
		//printf("Connect to MySQL Server Successfully!\n");
		m_bConn = true;
	}
	else
	{
		//printf("Failed to connect MySQL Server! [Error]: %s\n", mysql_error(&m_mysql));
		m_ErrMsg = mysql_error(&m_mysql);
		mysql_close(&m_mysql);
	}
}

CDataBase::~CDataBase()
{
	if (m_bConn)
	{
		mysql_close(&m_mysql);
		m_bConn = false;
	}
}

bool CDataBase::ExecuteSql(const char* sql)
{
	if (!m_bConn)
	{
		return false;
	}
	if (mysql_real_query(&m_mysql, sql, (unsigned long)strlen(sql)) == 0)
	{
		//printf("'%s'   Query successfully!\n", sql);
		return true;
	}
	else
	{
		//printf("'%s'  [Error]: %s\n", sql, mysql_error(&m_mysql));
		m_ErrMsg = mysql_error(&m_mysql);
		return false;
	}
}

MYSQL_RES* CDataBase::StoreResult()
{
	MYSQL_RES* res = NULL;
	if((res = mysql_store_result(&m_mysql)) != NULL)
	{
		return res;
	}
	else
	{
		//printf("Failed to store result!\n");
		return false;
	}
}

void CDataBase::FreeResult(MYSQL_RES *res)
{
	if (res)
	{
		mysql_free_result(res);
	}
}