MySQL.cpp

Aller à la documentation de ce fichier.

/*! \file MySQL.cpp
    \brief Gestion base de MySQL.

    Gestionnaire de base de données MySQL. \n

    \author     aerith (www.aerith.fr)
    \version    1.0
    \date       08/09/2007
*/

#include    "MySQL.h"


MUTEX   MySQL::MySQLMutex;
int     MySQL::MySQLInstance = 0;

MySQL::MySQL(char *pHost, char *pUser, char *pPass, char *pBase, int iPort)
{
    if(!MySQLInstance)
        MutexInit(&MySQLMutex);

    MySQLInstance++;

    strncpy(Host, pHost, MYSQL_HOST);
    strncpy(User, pUser, MYSQL_USER);
    strncpy(Pass, pPass, MYSQL_PASS);
    strncpy(Name, pBase, MYSQL_BASE);
    Port = iPort;

    Connected = 0;
}

MySQL::~MySQL()
{
    MySQLInstance--;

    if(!MySQLInstance)
        MutexStop(&MySQLMutex);

    mysql_close(&Base);

    Datas.clear();
}

int     MySQL::Open()
{
    BEGIN

    if(!Connected)
    {
        mysql_init(&Base);

        if(!mysql_real_connect(&Base, Host, User, Pass, Name, Port, NULL, 0))
        {
            MySQLError();
            CERROR = ERROR_C_CONNECT;
        }

        Connected = 1;
    }
    ENDTRY(ERROR_C_ALREADY_START)

    ENDBEGIN
}

int     MySQL::Close()
{
    BEGIN

    if(Connected)
    {
        mysql_close(&Base);

        Connected = 0;
    }
    ENDTRY(ERROR_C_ALREADY_STOP)

    ENDBEGIN
}

int     MySQL::Query(char *pQuery, ...)
{
    char    Temp[MYSQL_BUFFER];
    va_list args;
    BEGIN

    if(Connected)
    {
        va_start(args, pQuery);
        vsprintf(Temp, pQuery, args);
        va_end(args);

        if(mysql_query(&Base, Temp))
        {
            MySQLError();
            CERROR = ERROR_C_SEND;
        }
        else
        {
            CERROR = SaveResult();
        }
    }
    ENDTRY(ERROR_C_ALREADY_STOP)

    ENDBEGIN
}

int     MySQL::QueryBin(char *pQuery, int iSize)
{
    BEGIN

    if(Connected)
    {
        if(mysql_real_query(&Base, pQuery, iSize))
        {
            MySQLError();
            CERROR = ERROR_C_SEND;
        }
        else
        {
            CERROR = SaveResult();
        }
    }
    ENDTRY(ERROR_C_ALREADY_STOP)

    ENDBEGIN
}

int     MySQL::SaveResult()
{
    MYSQL_RES   *Res;
    MYSQL_ROW   Row;
    BEGIN

    Res = mysql_store_result(&Base);
    if(Res)
    {
        Datas.clear();

        while(Row = mysql_fetch_row(Res))
            Datas.push_back(Row);

        if(mysql_errno(&Base))
        {
            CERROR = ERROR_C_RECEIVE;
        }
    }
    else
    {
        if(mysql_field_count(&Base))
        {
            CERROR = ERROR_C_UNKNOW;
        }
    }

    if(CERROR)
    {
        MySQLError();
        Datas.clear();
    }

    mysql_free_result(Res);

    ENDBEGIN
}

---