DbBufStorage.H

Go to the documentation of this file.

/* DbBufStorage.H */
/* $Id: DbBufStorage.H,v 1.9 2007/02/20 11:30:32 ibadm Exp $ */
#ifndef __DbBufStorage_H
#define __DbBufStorage_H


/***********************************************************************
 *
 * »ÞÚÐÛìÝÐï ±Ð×Ð ´ÐÝÝëå (ÒÕàáØï 4)
 * ÅàÐÝÕÝØÕ âÐÑÛØæë »±´ Ò ßÐÜïâØ Ø ÞßÕàÐæØØ á ÝÕÙ
 *
 ***********************************************************************/

#include <mix/wenv.h>
#include <mix/trans.h>

#include <mix/DynAr.H>
#include <mix/IntAr.H>
#include <mix/LongAr.H>

#include <ldb/DbTableTypes.H>


#define DB_CLUSTER_START_VOLUME     20

#define DB_CLUSTER_DEFAULT_QUANT    20

#define DB_CLUSTER_LIMIT_SIZE       (200*1024)  /* 200K */


class DbDataCluster
{
public:

  DbDataCluster (unsigned nItemSize,
         DbIndex nStartVolume = DB_CLUSTER_START_VOLUME);

  virtual ~DbDataCluster ();

  void*     data_item (DbIndex iLocal) const;

  void      add_items (DbIndex nCount, DbIndex* pLocal,
              Logic* bSequent = NULL);

  void      release_items (DbIndex nCount, const DbIndex* pLocal);

  Logic     is_empty () const;

  DbIndex   empty_slots () const;

  DbIndex   total_slots () const;

  void      print_self () const;

private:

  Logic     slot_is_empty (DbIndex iLocal) const;

  void      slot_usage (DbIndex iLocal, Logic bUsed);

  DynAr     arItemData;

  IntAr     arItemAttr;

  DbIndex   nEmptySlots;

};


class DbLineEntry
{
public:/* methods */

  DbLineEntry ();

  DbLineEntry&  operator= (const DbLineEntry& rLEntry);

  Logic     get_loaded () const;        
  void      set_loaded (Logic bFlag);   
  /* @}*/

  Logic     get_changed () const;       
  void      set_changed (Logic bFlag);  
  /* @}*/

  void      print_self () const;

public:/* data */

  DbDataCluster *pDataClu;

  DbIndex   iLocalIndex;

  unsigned  iAccessId;

private:/* data */

  unsigned  bLoaded:1;  
  unsigned  bChanged:1; 
};


/***********************************************************************
 * INLINES
 ***********************************************************************/

inline Logic
DbLineEntry::get_loaded () const
{
  return bLoaded;
}


inline void
DbLineEntry::set_loaded (Logic bFlag)
{
  bLoaded = !!bFlag;
}


inline Logic
DbLineEntry::get_changed () const
{
  return bChanged;
}


inline void
DbLineEntry::set_changed (Logic bFlag)
{
  bChanged = !!bFlag;
}



#define AnyAr       DbLineEntries
#define AnyType     DbLineEntry
#define AnyFormatSpec   "\n\t%d: %s, %s, data location=(%p %u), access id=%u"
#define AnyPrintList    i, item.get_loaded()? "loaded": "not loaded", \
            item.get_changed()? "changed": "not changed", \
            item.pDataClu, item.iLocalIndex, item.iAccessId
#define AnyPrintf   fprintf(stderr, 
#include <mix/AnyAr.H>


/* ¸×-×Ð ÔãàÐæÚÞÓÞ ÚÞÜßØÛïâÞàÐ AIX 3.2.5 xlC ÝãÖÝÞ ÔÕÛÐâì   ßàÞÜÕÖãâÞçÝëÙ âØß ãÚÐ×ÐâÕÛï. */
typedef DbDataCluster*  DbDataClusterPtr;

#define AnyAr       DbDataClusters
#define AnyType     DbDataClusterPtr
#define AnyPrintItem    item->print_self()
#include <mix/AnyAr.H>


/**
 ***********************************************************************
 * ¼ÐááØÒ ØÝÔÕÚáÞÒ áâàÞÚ.
 ***********************************************************************/
typedef UIntAr      DbIndexAr;


/**
 ***********************************************************************
 * ÅàÐÝØÛØéÕ áâàÞÚ âÐÑÛØæë »±´.  ½Õ ÞáãéÕáâÒÛïÕâ áÞÑáâÒÕÝÝÞ ÞßÕàÐæØØ
 * ×ÐÓàã×ÚØ, Ø×ÜÕÝÕÝØï, áÞåàÐÝÕÝØï áâàÞÚ Ò äÐÙÛÕ.  ½Þ ÞÑÕáßÕçØÒÐÕâ
 * ÒëÔÕÛÕÝØÕ ßÐÜïâØ Ø ãßàÐÒÛÕÝØï Õî.
 ***********************************************************************/

class DbBufStorage
{
public:

  /** ÁÞ×ÔÐâì ßãáâÞÕ åàÐÝØÛØéÕ áâàÞÚ ÔÛØÝÞÙ nItemSize ÑÐÙâ. */
  DbBufStorage (unsigned nItemSize);

  /** ÀÐ×àãèØâì åàÐÝØÛØéÕ. */
  virtual   ~DbBufStorage ();

  /** ¸×ÜÕÝØâì àÐ×ÜÕà áâàÞÚØ ÝÐ ãÚÐ×ÐÝÝëÙ.  ÍâÞ ÒÞ×ÜÞÖÝÞ âÞÛìÚÞ Ò
      áÛãçÐÕ ßãáâÞÓÞ åàÐÝØÛØæÐ.  µáÛØ åàÐÝØÛØéÕ ÝÕ ßãáâÞÕ, âÞ
      ßàÞØ×ÞÙÔÕÝ ØáÚÛîçØâÕÛìÝÐï áØâãÐæØï á ÚÞÔÞÜ ERROR__MISMATCH. */
  void  set_item_size (unsigned nItemSize);

  /** ¿ÞÛãçØâì ÜÐÚáØÜÐÛìÝÞ ÔÞßãáâØÜëÙ àÐ×ÜÕà ÚÛÐáâÕàÐ Ò áâàÞÚÐå.  ¿àØ
      íâÞÜ àÐ×ÜÕà ÚÛÐáâÕàÐ ÜÞÖÕâ ßàÕÒëèÐâì ãÚÐ×ÐÝÝëÙ ßàÕÔÕÛ Ò âÞÜ
      áÛãçÐÕ, ÕáÛØ íâÞâ ÚÛÐáâÕà áÞ×ÔÐÝ ×Ð ÞÔÝã ÞßÕàÐæØî ÔÞÑÐÒÛÕÝØï
      áâàÞÚ. */
  DbIndex   max_lines_in_cluster () const;

  /** ¿ÞÔÓÞâÞÒØâì ãÚÐ×ÐÝÝëÕ áâàÞÚØ line1..line2 Ú ×ÐÓàã×ÚÕ Ò ßÐÜïâì. */
  void  preload_lines (DbIndex line1, DbIndex line2);

  /** ¸×ÜÕÝØâì ãÚÐ×ÐÝÝëÕ áâàÞÚØ line1..line2 Ò ßÐÜïâØ. */
  void  change_lines (DbIndex line1, DbIndex line2);

  /** ²áâÐÒØâì ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ áâàÞÚ ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ. */
  void  insert_line (DbIndex line, DbIndex lines_cnt);

  /** ÃÔÐÛØâì ãÚÐ×ÐÝÝëÕ áâàÞÚØ line1..line2 Ò ßÐÜïâØ. */
  void  remove_lines (DbIndex line1, DbIndex line2);

  /** ¿ÞÜÕÝïâì ãÚÐ×ÐÝÝëÕ áâàÞÚØ line1 Ø line2 ÜÕáâÐÜØ. */
  void  exchange_lines (DbIndex line1, DbIndex line2);

  /** ¾çØáâØâì åàÐÝØÛØéÕ. */
  void  clean_storage ();

  /** ²Þ×ÒàÐâØâì ãÚÐ×ÐâÕÛì ÝÐ ÜÕáâÞ åàÐÝÕÝØï ãÚÐ×ÐÝÝÞÙ áâàÞÚØ. */
  void* line_pointer (DbIndex line) const;

  /** ²Þ×ÒàÐâØâì Ò ÜÐááØÒÐå arLine, arCnt ãçÐáâÚØ ÔØÐßÐ×ÞÝÐ áâàÞÚ
      line1..line2, àÐáßÞÛÞÖÕÝÝëÕ Ò ßÐÜïâØ ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  void  sequent_lines (DbIndex line1, DbIndex line2,
               DbIndexAr& arLine, DbIndexAr& arCnt) const;

  /** ÀÐáßÕçÐâÐâì áÞÔÕàÖØÜÞÕ åàÐÝØÛØéÐ. */
  void  print_self ();

  /** ºÞÛØçÕáâÒÞ áâàÞÚ Ò âÐÑÛØæÕ. */
  DbIndex   lines_count () const;

  /** °âàØÑãâë ÚÐÖÔÞÙ áâàÞÚØ. */
  DbLineEntry&  operator[] (DbIndex line) const;


  /** ÃßÞàïÔÞçØâì ×ÐÔÐÝÝãî ßÐàã ØÝÔÕÚáÞÒ áâàÞÚ âÐÚ, çâÞÑë
      line[1]>=line[0] */
  static void   good_line_range (DbIndex line1, DbIndex line2,
                 DbIndex line[2]);

private:

  /** ²ëÔÕÛØâì ßÐÜïâì ÔÛï ãÚÐ×ÐÝÝëå áâàÞÚ. */
  void  allocate_lines (const DbIndex* pIndeces, unsigned nIndeces);

  /** ¼ÐááØÒ ááëÛÞÚ ÝÐ áâàÞÚØ. */
  DbLineEntries     letable;

  /** ÁßØáÞÚ ÚÛÐáâÕàÞÒ ÔÐÝÝëå. */
  DbDataClusters    dclist;

  /** ÀÐ×ÜÕà áâàÞÚØ. */
  unsigned      nLineSize;

  /** ÀÕÚÞÜÕÝÔÞÒÐÝÝÞÕ ÜÐÚáØÜÐÛìÝÞÕ ÚÞÛØçÕáâÒÞ áâàÞÚ Ò ÚÛÐáâÕàÕ. */
  unsigned      nLinesLimit;

  /** ¸ÝÔÕÚá ÞßÕàÐæØÙ ÔÞáâãßÐ. Á ÚÐÖÔÞÙ ÐâÞÜÐàÝÞÙ ÞßÕàÐæØÕÙ
     ãÒÕÛØçØÒÐÕâáï ÝÐ 1. */
  unsigned      nAccessId;

  /** ÁÛãÖÕÑÝëÕ ÜÐááØÒë ØÝÔÕÚáÞÒ, ØáßÞÛì×ãÕÜëÕ ÔÛï ÒàÕÜÕÝÝÞÓÞ åàÐÝÕÝØï
      áßØáÚÐ áâàÞÚ (ÓÛÞÑÐÛìÝëå Ø ÛÞÚÐÛìÝëå ØÝÔÕÚáÞÒ
      áÞÞâÒÕâáâÒÕÝÝÞ). */
  DbIndexAr     arGlobal, arLocal;

};


/***********************************************************************
 * INLINES
 ***********************************************************************/

/**
 * ºÞÛØçÕáâÒÞ áâàÞÚ Ò âÐÑÛØæÕ.
 */
inline DbIndex
DbBufStorage::lines_count () const
{
  return letable.count();
}


/**
 * °âàØÑãâë ÚÐÖÔÞÙ áâàÞÚØ.
 */
inline DbLineEntry&
DbBufStorage::operator[] (DbIndex line) const
{
  return *(DbLineEntry*)letable.item_ptr(line);
}


#endif /* DbBufStorage.H */

   ßàÞÜÕÖãâÞçÝëÙ âØß ãÚÐ×ÐâÕÛï. */
typedef DbDataCluster*  DbDataClusterPtr;

#define AnyAr       DbDataClusters
#define AnyType     DbDataClusterPtr
#define AnyPrintItem    item->print_self()
#include <mix/AnyAr.H>


typedef UIntAr      DbIndexAr;


class DbBufStorage
{
public:

  DbBufStorage (unsigned nItemSize);

  virtual   ~DbBufStorage ();

  void  set_item_size (unsigned nItemSize);

  DbIndex   max_lines_in_cluster () const;

  void  preload_lines (DbIndex line1, DbIndex line2);

  void  change_lines (DbIndex line1, DbIndex line2);

  void  insert_line (DbIndex line, DbIndex lines_cnt);

  void  remove_lines (DbIndex line1, DbIndex line2);

  void  exchange_lines (DbIndex line1, DbIndex line2);

  void  clean_storage ();

  void* line_pointer (DbIndex line) const;

  void  sequent_lines (DbIndex line1, DbIndex line2,
               DbIndexAr& arLine, DbIndexAr& arCnt) const;

  void  print_self ();

  DbIndex   lines_count () const;

  DbLineEntry&  operator[] (DbIndex line) const;


  static void   good_line_range (DbIndex line1, DbIndex line2,
                 DbIndex line[2]);

private:

  void  allocate_lines (const DbIndex* pIndeces, unsigned nIndeces);

  DbLineEntries     letable;

  DbDataClusters    dclist;

  unsigned      nLineSize;

  unsigned      nLinesLimit;

  unsigned      nAccessId;

  DbIndexAr     arGlobal, arLocal;

};


/***********************************************************************
 * INLINES
 ***********************************************************************/

inline DbIndex
DbBufStorage::lines_count () const
{
  return letable.count();
}


inline DbLineEntry&
DbBufStorage::operator[] (DbIndex line) const
{
  return *(DbLineEntry*)letable.item_ptr(line);
}


#endif /* DbBufStorage.H */