source: tags/0.55/stopos_pool.h @ 9

#ifndef STOPOS_POOL_H
#define STOPOS_POOL_H
#include <string>
#include "stopos.h"
#include "stopos_key.h"
#include <iostream>
 
class datarecord
{
  public:
    datarecord();
    datarecord(const std::string &s,char sep);
    stopos_key prev;
    stopos_key next;
    longuint retrieved;
    std::string value;
    std::string str(char dbsep);
} ;
class statusrecord
{
  public:
  stopos_key next;      // points to first line for the 'next' command
  stopos_key first;     // points to first record
  stopos_key last;      // points to last record
  stopos_key nextd;     // points to record to be dumped
  longuint count;       // total number of records added
  longuint present;     // total number of records now availabe
  longuint present0;    // ditto, but uncommitted

  statusrecord(void);
  statusrecord(const std::string &s,char dbsep);
  std::string str(char dbsep);
  void init(void);
};

class stopos_pool
{
  protected:
    char* db_name;        // name for database
    std::string sdb_name; // idem
    static const unsigned int reclen = 256; // 1024;
    bool kvp; //true if Koot-Vermin paradigm is to be used
    bool db_open;
    
    stopos_key statuskey;
    stopos_key nextkey;
    statusrecord status;

    virtual int get_record(datarecord &r,const stopos_key &k)=0;
    virtual int put_record(datarecord &r,const stopos_key &k)=0;
    virtual int remove_record(const stopos_key &k)=0;
    virtual int get_status(void)=0;
    virtual int put_status(void)=0;

  public:

    stopos_pool();
    ~stopos_pool();

    virtual int create_db(void) = 0;
    virtual int purge_db(void)  = 0;
    virtual int open_db(void)   = 0;
    virtual int close_db(void)  = 0;
    virtual void dump_db(void)  = 0;

    virtual void set_db_name(std::string filename);
    virtual std::string get_db_name(void);

    virtual int add_line(const std::string line,std::string &key);
    virtual int get_line(std::string &line,longuint &retrieved,std::string &key);
    virtual int remove_line(const std::string &key);

    virtual void set_kvp(const bool v);
    virtual bool get_kvp(void);

    int get_counts(longuint &count, 
                   longuint &present, 
                   longuint &present0);

    int dump_line(std::string  &line,
                  longuint     &retrieved,
                  std::string  &key);

    const static int NOFILENAME        =  1;
    const static int OPENERROR         =  2;
    const static int STOREERROR        =  3;
    const static int FETCHERROR        =  4;
    const static int NOTFOUND          =  5;
    const static int NOTIMPLEMENTED    =  6;
    const static int REMOVEERROR       =  7;
    const static int LOCKERROR         =  8;
    const static int CLOSEERROR        =  9;
    const static int UNLOCKERROR       = 10;
    const static int DBNOTOPEN         = 11;
    const static int CREATEERROR       = 12;
    const static int PURGEERROR        = 13;

};
#endif