/home/alex/STDB/stdb/include/stdb.h

/***************************************************************************
                          stdb.h  -  Simple Tansactional Data Base
                             -------------------
    begin                : 16/mar/2004
    copyright            : (C) 2004 by Andreu Moreno
    email                : amoreno@euss.es
 ***************************************************************************/

/***************************************************************************
 *                                                                         *
 *  This library is free software; you can redistribute it and/or
 *  modify it under the terms of the GNU Lesser General Public
 *  License as published by the Free Software Foundation; either
 *  version 2.1 of the License, or (at your option) any later version.

 *  This library is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 *  Lesser General Public License for more details.

 *  You should have received a copy of the GNU Lesser General Public
 *  License along with this library; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
 *                                                                         *
 ***************************************************************************/

/*
 *
 * $Author: alex_blanquer $
 * $Revision: 1.3 $
 * $Log: stdb.h,v $
 * Revision 1.3  2005/05/11 23:56:16  alex_blanquer
 * Bug fixed test1.cpp and modified Doxygen config/doc stuff
 *
 * Revision 1.2  2005/05/10 10:59:52  amoreno
 * Added comments, doxygen formatted and bug cleaning
 *
 * Revision 1.1.1.1  2004/03/23 10:13:10  amoreno
 * Initial import.
 *
 *
 */

#ifndef STDB_H
#define STDB_H

#include <sys/time.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <error.h>
#include <iostream>
#include <fstream>
#include <fcntl.h>
#include <time.h>
#include <map>
#include <string>
#include <stack>
#include <vector>
#include <queue>
#include <list>
#include <deque>

using namespace std;

#define uint32 unsigned long int
#define COMMIT 'C'
#define BUFFSIZE 128



class Tstdb{
private:


    char *db,*log;


    int MaxLogSize;
    

    int MaxTime;


    typedef map<string,string,less<string> > TDBMemory;
    

    typedef TDBMemory::value_type TValue;
    

    TDBMemory DBMemory; 
    

    TDBMemory::iterator index; 


    enum {LogOK, LogCORRUPTION, LogNOFILE} OpenLogStatus;
    

    enum {CDBOK, CDBCORRUPTION, CDBNOFILE} OpenCDBStatus;


    int ReadBytes;

    enum TFunction{ INSERT, UPDATE, DELETE };
    
    

    class TAction{
    private:

        TFunction   Function;   

        string      Key;
        
        string      Data;
                
    public:
    
        TAction(): Function(UPDATE), Key(""), Data("") { }
        
        TAction(TFunction f, string k, string d): Function(f), Key(k), Data(d) 
        { }
        
        TAction(const TAction& arg){
            Function=arg.Function;
            Key=arg.Key;
            Data=arg.Data;
        }
            
        ~TAction() { }
        
        void operator=(const TAction &copy){
            if (this == &copy) return;
            Function=copy.Function;
            Key=copy.Key;
            Data=copy.Data;
        }
        
        bool operator==(const TAction& arg) const {
            return (Function == arg.Function) && 
                        (Key == arg.Key) && 
                        (Data == arg.Data);
        }
        
        bool operator<(const TAction& arg) const {
            return (Function < arg.Function) && 
                        (Key < arg.Key) && 
                        (Data < arg.Data);
        }
        
        TFunction GetFunction(){ return Function;}
        
        string &GetKey(){ return Key;}
        
        string &GetData(){ return Data;}
    };

        

    stack <TAction, vector<TAction> > RollBack;


    queue <TAction, list<TAction> > RedoLog;


    bool Getcdbline(ifstream &in, TAction &action, bool &final);


    bool Getlogline(ifstream &in, TAction &action, bool &commit, int &size, bool & final);
        

    bool Getline(ifstream &in, TAction &action, int &size);
        

    bool ParserLineOut(string &line, TAction &action);
    

    bool ParserLineDeleteOut(string &line, TAction &action); //Parser line Delete Out


    bool ReorganizeNecessary();


public:

    Tstdb(  const char *TCDBName, 
            const char *TCDBLogName, 
            const int ParMaxLogSize, 
            const int ParMaxTime);


    void Initialize(void);
    

    bool Insert(char *key,unsigned int lkey, char *data, unsigned int ldata);


    bool Update(char *key,unsigned int lkey, char *data, unsigned int ldata);
    

    bool Fetch(char *key,unsigned int lkey, const char **data, unsigned int *ldata);
            

    bool Delete(char *key,unsigned int lkey);


    bool Commit(void);
    

    bool Reorganize();


    bool Rollback(void);
    

    bool Firstkey(const char **key,unsigned int *lkey, const char **data, unsigned int *ldata);


    bool Nextkey(const char **key,unsigned int *lkey, const char **data, unsigned int *ldata);


    bool Getstatus(int *LogStatus, int *CDBStatus);
    

    void Finalize(void);
    
    ~Tstdb();
};

#endif // STDB_H

---