DataBase.cpp

Aller à la documentation de ce fichier.

/*! \file DataBase.cpp
    \brief Gestion base de données.

    Gestionnaire de base de données avec notion de table et entrée indexé et libélé.

    \author     aerith (www.aerith.fr)
    \version    1.0
    \date       26/07/2007
*/

#include    "DataBase.h"


MUTEX   DataBase::DBMutex;
int     DataBase::DBInstance = 0;

DataBase::DataBase(char *pRepertoire)
{
    if(!DBInstance)
        MutexInit(&DBMutex);

    DBInstance++;

    strncpy(Repertoire, pRepertoire, DB_REPERTOIRE);
    NbTable     = 0;
    IdMax       = 0;

    LoadTables();
}

DataBase::~DataBase()
{
    for(int i = 0; i < NbTable; i++)
        delete Tables[i];
    Tables.clear();

    DBInstance--;

    if(!DBInstance)
        MutexStop(&DBMutex);
}

int     DataBase::LoadTables()
{
    FILE    *Fichier;
    int     Id;
    int     Size;
    char    Name[DB_NAME];
    BEGIN
    LOC("DataBase::LoadTables");

    MutexLock(&DBMutex);

    sprintf(Name, "%s/DB.sys", Repertoire);
    Fichier = fopen(Name, "r");
    if(Fichier)
    {
        for(int i = 0; i < NbTable; i++)
            delete Tables[i];
        Tables.clear();
        NbTable = 0;

        while(!feof(Fichier) && !CERROR)
        {
            TRY if(fread(&Id, sizeof(int), 1, Fichier))
            {
                TRYIF(fread(&Size, sizeof(int), 1, Fichier), ERROR_C_DATA_FILE)
                if(Size > DB_NAME)
                    Size = DB_NAME;

                TRY if(fread(Name, sizeof(char), Size, Fichier))
                {
                    Name[Size] = '\0';

                    Tables.push_back(new DataBaseTable(Repertoire, Id, 0, Name));

                    NbTable++;
                    IdMax = Id;
                }
                ENDTRY(ERROR_C_DATA_FILE)
            }
        }

        fclose(Fichier);
    }
    ENDTRY(ERROR_C_DATA_FILE)

    MutexUnLock(&DBMutex);

    PERROR

    ENDBEGIN
}

int     DataBase::SaveTables()
{
    FILE    *Fichier;
    int     i;
    int     Id;
    int     Size;
    char    Name[DB_BUFFERSIZE];
    BEGIN

    MutexLock(&DBMutex);

    sprintf(Name, "%s/DB.sys", Repertoire);
    Fichier = fopen(Name, "w");
    if(Fichier)
    {
        for(i = 0; i < NbTable; i++)
        {
            Id = Tables[i]->GetId();
            TRYIF(fwrite(&Id, sizeof(int), 1, Fichier), ERROR_C_DATA_FILE)

            strcpy(Name, Tables[i]->GetName());
            Size = strlen(Name);
            TRYIF(fwrite(&Size, sizeof(int), 1, Fichier), ERROR_C_DATA_FILE)
            TRYIF(fwrite(Name, sizeof(char), Size, Fichier), ERROR_C_DATA_FILE)
        }

        fclose(Fichier);
    }
    ENDTRY(ERROR_C_DATA_FILE)

    MutexUnLock(&DBMutex);

    ENDBEGIN
}

int     DataBase::AddTable(char *pName, int iNbData)
{
    Tables.push_back(new DataBaseTable(Repertoire, IdMax + 1, iNbData, pName));
    if(!Tables[NbTable])
        return ERROR_C_MEMORY;
        
    IdMax++;
    NbTable++;
    
    return ERROR_C_NOERROR;
}

int     DataBase::DelTable(int iId)
{
    int     i;

    if(NbTable > 0)
    {
        for(i = 0; i < NbTable; i++)
        {
            if(Tables[i]->GetId() == iId)
            {
                Tables.erase(Tables.begin() + i);

                NbTable--;

                return ERROR_C_NOERROR;
            }
        }
    }
    
    return ERROR_C_NOERROR;
}

int     DataBase::SaveBase()
{
    int     i;
    int     j = 0;
    char    Name[DB_BUFFERSIZE];
    BEGIN

    MutexLock(&DBMutex);

    for(i = 1; (i <= IdMax) && !CERROR; i++)
    {
        if(Tables[j]->GetId() == i)
        {
            TRY CERROR = Tables[j]->SaveEntrys();

            j++;
        }
        else
        {
            sprintf(Name, "%s/%i.dbt", Repertoire, i);

            FileDelete(Name);
        }
    }

    MutexUnLock(&DBMutex);

    TRY CERROR = SaveTables();

    ENDBEGIN
}

---