DbTable.H

Go to the documentation of this file.

/* DbTable.H */
/* $Id: DbTable.H,v 1.31 2004/02/26 12:34:36 vlad Exp $ */

/*********************************************************************
 *
 * UNIVERS
 * (C) ¾¾¾ "³µ¾²µÀÁ", 2001
 *
 * ²áÕ ßàÐÒÐ ×ÐéØéÕÝë *
 * ¸áßÞÛì×ÞÒÐÝØÕ, ÚÞßØàÞÒÐÝØÕ ØÛØ ßÕàÕÔÐçÐ àÕÓãÛØàãîâáï ×ÐÚÞÝÐÜØ
 * ÀÞááØÙáÚÞÙ ÄÕÔÕàÐæØØ "¾Ñ ÐÒâÞàáÚÞÜ ßàÐÒÕ Ø áÜÕÖÝëå ßàÐÒÐå", "¾
 * ßàÐÒÞÒÞÙ ÞåàÐÝÕ ßàÞÓàÐÜÜ ÔÛï íÛÕÚâàÞÝÝëå ÒëçØáÛØâÕÛìÝëå ÜÐèØÝ Ø ÑÐ×
 * ÔÐÝÝëå"
 *
 * Encoding: ISO-8859-5 (GOST)
 *
 *********************************************************************/

#ifndef __DbTable_H
#define __DbTable_H

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

#ifndef NO_HASH
#include <map>
#include <string>
#endif /* NO_HASH */

#include <mix/mutex.h>
#include <mix/wenv.h>
#include <ldb/DbTableTypes.H>
#include <ldb/DbBufStorage.H>
#include <ldb/DbFileStorage.H>

/** ²ÚÛîçØâì ÕáÛØ âàÕÑãÕâáï ØÜÕâì áâÐâØáâØÚã ßÞ çØáÛã
   ×ÐßØáÐÝÝëå/ßàÞçØâÐÝÝëå áâàÞÚ. */
//#define DB_RW_LOG_ENABLED

/** ºÞÛØçÕáâÒÞ ßÐÜïâØ Ò áâàÞÚÐå âÐÑÛØæë ÝÐ ÚÞâÞàÞÕ ÑãÔÕâ ãÒÕÛØçØÒÐâìáï
   áÕÓÜÕÝâ ßÐÜïâØ ßàØ àÞáâÕ àÐ×ÜÕàÐ âÐÑÛØæë.  ·ÝÐçÕÝØÕ ßÞ ãÜÞÛçÐÝØî. */
#define DB_QUANT        200

/** ºÞÛØçÕáâÒÞ ßÐÜïâØ Ò áâàÞÚÐå ÒëÔÕÛïÕÜÞÕ ßÞ ãÜÞÛçÐÝØî ßÞÔ ßãáâãî
   âÐÑÛØæã.  ·ÝÐçÕÝØÕ ßÞ ãÜÞÛçÐÝØî. */
#define DB_START_VOLUME     500

/** ÁâÐÝÔÐàâÝëÙ àÐ×ÜÕà ÑãäÕàØ×ÐæØØ ßàØ çâÕÝØØ Ò ÑÐÙâÐå. */
#define DB_NORMAL_PREREAD   (500*1024)

/** ±ÞÛìèÞÙ àÐ×ÜÕà ÑãäÕàØ×ÐæØØ ßàØ çâÕÝØØ Ò ÑÐÙâÐå. */
#define DB_LARGE_PREREAD    (10*1024*1024)

/** ¼ÐÛëÙ àÐ×ÜÕà ÑãäÕàØ×ÐæØØ ßàØ çâÕÝØØ Ò ÑÐÙâÐå. */
#define DB_SMALL_PREREAD    (50*1024)


/**
 ***********************************************************************
 * ºÛÐáá ßÞ àÐÑÞâÕ á âÐÑÛØæÕÙ »±´ ÝÐ ÝØÖÝÕÜ ãàÞÒÝÕ.  ¾ÑÕáßÕçØÒÐÕâ
 * ÞâÞÑàÐÖÕÝØÕ äÐÙÛÐ âÐÑÛØæë »±´ Ò ßÐÜïâì.
 *
 * ½ÞÜÕà áâàÞÚØ Ò âÐÑÛØæÕ ±´ ÞâáçØâëÒÐÕâáï Þâ 0 Ø ÔÞÛÖÕÝ Ñëâì
 * ßÞÛÞÖØâÕÛìÝëÜ.  ´ÞßãáÚÐÕâáï ØáßÞÛì×ÞÒÐâì _last_ Ø× DynAr.H ÔÛï
 * ÔÞáâãßÐ Ú ßÞáÛÕÔÝÕÙ áâàÞÚÕ âÐÑÛØæë.
 *
 * ´Ûï ÜÐááØÒÞÒ Ø× N áØÜÒÞÛÞÒ (âØßë CHAR_1, CHAR_EBCDIC) ØáßÞÛì×ãîâáï
 * áßÕæØÐÛìÝëÕ ßàÐÒØÛÐ ÔÞáâãßÐ.  ¿àØ ×ÐßØáØ Ò âÐÑÛØæã ßÞ set_value()
 * ÚÞßØàãîâáï ÔÞ N áØÜÒÞÛÞÒ ÒÚÛîçØâÕÛìÝÞ ßÞÚÐ ÝÕ ÒáâàÕâØâáï ßàØ×ÝÐÚ
 * ÚÞÝæÐ áâàÞÚØ '\0'.  ² âÐÑÛØæÕ ±´ ÒáÕÓÔÐ åàÐÝØâáï N áØÜÒÞÛÞÒ (ÚÞÝæÕÒÞÙ
 * '\0' ÜÞÖÕâ ÝÕ ãÜÕáâØâìáï).  ¿àØ çâÕÝØØ Ø× âÐÑÛØæë ßÞ get_value()
 * ßàØÕÜÝëÙ ÑãäÕà ÔÞÛÖÕÝ ØÜÕâì ÝÐ ÞÔØÝ ÑÐÙâ ÑÞÛìèÕ ÔÛØÝë áâàÞÚØ, âÐÚ ÚÐÚ
 * ßàØ×ÝÐÚ ÚÞÝæÐ áâàÞÚØ äÞàÜØàãÕâáï ÐÒâÞÜÐâØçÕáÚØ.  ÂÞ Õáâì, ÔÛï
 * ÓÐàÐÝâØØ ßÞÔ ßàØÕÜÝëÙ ÑãäÕà ÔÞÛÖÝÞ Ñëâì ÒëÔÕÛÕÝÞ N+1 ÑÐÙâÞÒ ßÐÜïâØ.
 * ¼ÐááØÒë ÞáâÐÛìÝëå âØßÞÒ ÚÞßØàãÕâáï ÑÐÙâ Ò ÑÐÙâ.
 ***********************************************************************/

class DbTable
{
public:

  /** ÁÞ×ÔÐâì ßãáâãî âÐÑÛØæã ãÚÐ×ÐÝÝÞÙ áâàãÚâãàë Ò ßÐÜïâØ. */
  DbTable (const DbTTDesc& dbtt,
       DbIndex quant = DB_QUANT,
       DbIndex start_volume = DB_START_VOLUME);

  /** ÁÞ×ÔÐâì ÚÞßØî ãÚÐ×ÐÝÝÞÙ âÐÑÛØæë Ò ßÐÜïâØ. */
  DbTable (DbTable& dbt);

  /** ¾áÒÞÑÞÔØâì ßÐÜïâì Ø×-ßÞÔ âÐÑÛØæë Ø àÐ×àãèØâì ÞÑêÕÚâ. */
  virtual ~DbTable ();

  /*
   * ¸ÝäÞàÜÐæØÞÝÝëÕ ÜÕâÞÔë.
   */

  /** ²ÕàÝãâì ááëÛÚã ÝÐ ÞßØáÐÝØÕ âÐÑÛØæë. */
  const DbTTDesc&   table_format () const;

  /** ²ÕàÝãâì ÚÞÛØçÕáâÒÞ áâàÞÚ Ò âÐÑÛØæÕ. */
  virtual DbIndex   lines_count () const;

  /** ²ÕàÝãâì ÚÞÛØçÕáâÒÞ áâàÞÚ Ò ÔØÐßÐ×ÞÝÕ, ãÑàÐâì _last_ Ø ÒÕàÝãâì Ò
     line[] ßÐàã ãßÞàïÔÞçÕÝÝëå ßÞ ÒÞ×àÐáâÐÝØî ØÝÔÕÚáÞÒ áâàÞÚ - ßÕàÒÞÙ
     Ø ßÞáÛÕÔÝÕÙ. */
  virtual DbIndex   lines_range (DbIndex line1, DbIndex line2,
                     DbIndex* line = NULL) const;

  /** ¿ÞÛãçØâì ÔÞáâãß Ú ãÚÐ×ÐÝÝÞÜã áâÞÛÑæã-áâàÞÚÕ âÐÑÛØæë */
  virtual void  get_value (const char* column, DbIndex line,
               void* ptr);

  /** ³àãßßÞÒÐï ÞßÕàÐæØï ßÞ çâÕÝØî ÚÞÛÞÝÚØ ×ÝÐçÕÝØÙ Ø× ãÚÐ×ÐÝÝÞÓÞ
     áâÞÛÑæÐ.  ·ÝÐçÕÝØï áçØâëÒÐîâáï ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ áâàÞÚØ Ò
     ãÚÐ×ÐÝÝÞÜ ÚÞÛØçÕáâÒÕ.  */
  virtual void  get_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, void* ptr);

  /** ¿àÞÒÕàØâì, ïÒÛïÕâáï ÛØ ãÚÐ×ÐÝÝÐï ïçÕÙÚÐ ßãáâÞÙ */
  virtual Logic check_empty_value (const char* column, DbIndex line);

  /** ¿ÞÛãçØâì ×ÝÐçÕÝØÕ äØ×ØçÕáÚÞÙ ÒÕÛØçØÝë áâÞÛÑæÐ */
  virtual UnitId    get_unit (const char* column) const;

  /** ²ÕàÝãâì ááëÛÚã ÝÐ ÜÐááØÒ ÞßØáÐâÕÛÕÙ ÔÞÜÕÝÞÒ. */
  virtual const DmnDescAr&  get_domains ();

  /** ²ÕàÝãâì áâàãÚâãàã-ÞßØáÐâÕÛì ãÚÐ×ÐÝÝÞÓÞ ÔÞÜÕÝÐ. */
  virtual DbDomainDesc  get_domain (const char* column) const;

  /** ÁàÐÒÝØâì ×ÝÐçÕÝØï Ò ïçÕÙÚÐå ãÚÐ×ÐÝÝÞÓÞ ÔÞÜÕÝÐ. */
  virtual Compar    compare_lines (const char* column,
                       DbIndex line1, DbIndex line2);

  /** ¿ÞÛãçØâì ØÜï âØßÐ âÐÑÛØæë. */
  const char*   tt_name () const;

  /** ²ÕàÝãâì TRUE ÕáÛØ âÐÑÛØæÐ ÑëÛÐ ÜÞÔØäØæØàÞÒÐÝÐ Ø FALSE Ò ßàÞâØÒÝÞÜ
     áÛãçÐÕ. */
  Logic     is_modified () const;

  /** ²ÕàÝãâì TRUE ÕáÛØ âÐÑÛØæÐ ÜÞÖÕâ Ñëâì ÜÞÔØäØæØàÞÒÐÝÐ Ò ßÐÜïâØ Ø
     FALSE Ò ßàÞâØÒÝÞÜ áÛãçÐÕ. */
  Logic     is_modifiable () const;


  /*
   * ¾ßÕàÐæØØ ÝÐÔ âÐÑÛØæÕÙ Ò ßÐÜïâØ.
   */

  /** ¾çØáâØâì âÐÑÛØæã Ò ßÐÜïâØ (äÞàÜÐâ ÞáâÐÕâáï, áÞÔÕàÖØÜÞÕ ßàÞßÐÔÐÕâ). */
  virtual void  clean ();

  /** ·ÐßØáÐâì ×ÝÐçÕÝØÕ ãÚÐ×ÐÝÝÞÓÞ áâÞÛÑæÐ-áâàÞÚØ âÐÑÛØæë */
  virtual void  set_value (const char* column, DbIndex line,
               const void* ptr);

  /** ³àãßßÞÒÐï ÞßÕàÐæØï ßÞ ×ÐßØáØ ÚÞÛÞÝÚØ ×ÝÐçÕÝØÙ Ò ãÚÐ×ÐÝÝëÙ
     áâÞÛÑÕæ.  ·ÝÐçÕÝØï ×ÐßØáëÒÐîâáï ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ áâàÞÚØ Ò
     ãÚÐ×ÐÝÝÞÜ ÚÞÛØçÕáâÒÕ. */
  virtual void  set_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, const void* ptr);

  /** ÁÔÕÛÐâì ïçÕÙÚã ßãáâÞÙ. */
  virtual void  set_empty_value (const char* column, DbIndex line);

  /** ¸×ÜÕÝØâì ×ÝÐçÕÝØÕ äØ×ØçÕáÚÞÙ ÒÕÛØçØÝë áâÞÛÑæÐ ÝÐ ãÚÐ×ÐÝÝÞÕ */
  virtual void  set_unit (const char* column, UnitId unid);

  /** ²áâÐÒØâì Ò âÐÑÛØæã áâàÞÚã (áâàÞÚØ) ßÕàÕÔ ãÚÐ×ÐÝÝÞÙ line.
     µáÛØ ãÚÐ×ÐÝÐ áâàÞÚÐ _last_, âÞ ßÞáÛÕ ßÞáÛÕÔÝÕÙ.
     µáÛØ ÐàÓãÜÕÝâ bInit TRUE, âÞ âàÕÑãÕâáï ØÝØæØÐÛØ×ÐæØï áâàÞÚ. */
  virtual void  insert_line (DbIndex line, DbIndex lines_cnt = 1,
                 Logic bInit = TRUE);

  /** ÃÔÐÛØâì Ø× âÐÑÛØæë ãÚÐ×ÐÝÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ [line1..line2] */
  virtual void  remove_lines (DbIndex line1, DbIndex line2);

  /** ¾ÑÜÕÝïâì ÜÕáâÐÜØ ÔÒÕ áâàÞÚØ âÐÑÛØæë */
  virtual void  exchange_lines (DbIndex line1, DbIndex line2);

  /** ´ÞÑÐÒØâì áâàÞÚØ ãÚÐ×ÐÝÝÞÙ âÐÑÛØæë Ò ÚÞÝÕæ íâÞÙ. */
  virtual void  merge (DbTable& src);

  /** ´ÞÑÐÒØâì ãÚÐ×ÐÝÝëÕ áâàÞÚØ âÐÑÛØæë Ò ãÚÐ×ÐÝÝÞÕ ÜÕáâÞ íâÞÙ.
      ·ÐßàÕéÕÝÞ ØáßÞÛì×ÞÒÐÝØÕ _last_ Ò ÚÐçÕáâÒÕ ØÝÔÕÚáÐ.  */
  virtual void  copy_lines (DbIndex iWhere, DbTable& src,
                DbIndex iFrom, DbIndex nLines);

  /** ²ëßÞÛÝÕÝØÕ ÞßÕàÐæØØ ßàØÒÕÔÕâ Ú âÞÜã, çâÞ âÐÑÛØæÐ ÑãÔÕâ áçØâÐâìáï
     Ø×ÜÕÝØÒèÕÙáï.  ÍâÞâ ÜÕâÞÔ Òë×ëÒÐÕâáï ÒÞ ÒáÕå ÜÞÔØäØæØàãîéØå
     ÞßÕàÐæØïå. */
  virtual void  modify ();

  /** ²ëßÞÛÝÕÝØÕ ÞßÕàÐæØØ ßàØÒÕÔÕâ Ú âÞÜã, çâÞ âÐÑÛØæÐ ÑãÔÕâ áçØâÐâìáï
     ÝÕ Ø×ÜÕÝØÒèÕÙáï ÝÕáÜÞâàï ÝÐ ßàÕÔëÔãéØÕ ÞßÕàÐæØØ á ÝÕÙ. */
  virtual void  not_modified ();

  /** ÃáâÐÝÞÒØâì ßàØ×ÝÐÚ ÜÞÔØäØæØàãÕÜÞáâØ âÐÑÛØæë.  µáÛØ ãáâÐÝÞÒØâì
     FALSE, âÞ ÛîÑÐï ÞßÕàÐæØï Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë ×ÐÒÕàèØâáï
     á ÞèØÑÚÞÙ.  ¿Þ ãÜÞÛçÐÝØî äÛÐÓ TRUE. */
  virtual void  set_modifiability (Logic bFlag);


  /*
   * ¾ßÕàÐæØØ äÐÙÛÞÒÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ.
   * ¸ÜÕîâáï ÔÒÐ áßÞáÞÑÐ ÒÒÞÔÐ/ÒëÒÞÔÐ:
   * 1) ßÞáÛÕÔÞÒÐâÕÛìÝëÙ (ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * 2) ßàÞØ×ÒÞÛìÝëÙ (ÝÕ ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * ÁßÞáÞÑ #1 ÒÚÛîçÐÕâ Ò áÕÑï ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ×ÐÓÞÛÞÒÚÐ,
   * ÐâàØÑãâÞÒ Ø áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   * ÁßÞáÞÑ #2 ÒÚÛîçÐÕâ Ò áÕÑï âÞÛìÚÞ ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ÔØÐßÐ×ÞÝÞÒ
   * áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   */

  /*
   * ¿ÞáÛÕÔÞÒÐâÕÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ¿àÞçØâÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
      ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ÁÚÞààÕÚâØàÞÒÐâì
      çØáÛÞ ÔÞÜÕÝÞÒ Ø àÐ×ÜÕà ×ÐßØáØ ÔÞ áÞÒßÐÔÐîéÕÓÞ á äÐÙÛÞÜ ±´.
      ²Þ×ÒàÐâØâì çØáÛÞ áâàÞÚ Ò âÐÑÛØæÕ, çØáÛÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÜÞÖÕâ
      ÞâÛØçÐâìáï Þâ ftm.dmns->count()!) Ø äÞàÜÐâ åàÐÝÕÝØï.  ¼ÞÖÕâ
      àÐÑÞâÐâì á ÚÐÝÐÛÞÜ.  */
  void      read_leader (int fd, ByteOrder& eBO, DbIndex& nLineCnt,
                 unsigned& nDmnsCnt);

  /** ¿àÞçØâÐâì áÞÑáâÒÕÝÝÞ áâàÞÚØ âÐÑÛØæë »±´ Ø× äÐÙÛÐ Ò ÚÞÛØçÕáâÒÕ
     nLineCnt èâãÚ á ßàØÒÕÔÕÝØÕÜ Ø× äÞàÜÐâÐ eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      append_table (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ¿àÞçØâÐâì Ò ßÐÜïâì áÞÔÕàÖØÜÞÕ ãÚÐ×ÐÝÝÞÓÞ äÐÙÛÐ (Ò ÚÞÝÕæ
     ØÜÕîéÕÓÞáï áÞÔÕàÖØÜÞÓÞ).  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      read (int fd);

  /** ·ÐßØáÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
     ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ² ×ÐÓÞÛÞÒÚÕ
     ×ÐßØáëÒÐÕâáï ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ âàÐáá, çâÞ ßÞ×ÒÞÛïÕâ ×ÐßØáëÒÐâì
     Ò äÐÙÛ ßàÞØ×ÒÞÛìÝÞÕ Øå çØáÛÞ.  ·ÐÔÐÕâáï âÐÚÖÕ äÞàÜÐâ åàÐÝÕÝØï Ò
     äÐÙÛÕ.  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      write_leader (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ·ÐßØáÐâì ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ áâàÞÚ ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ Ò äÐÙÛ
     âÐÑÛØæë »±´.  ´ÐÝÝëÕ ßàØÒÞÔïâáï Ú äÞàÜÐâã eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      record_table (int fd, ByteOrder eBO,
                  DbIndex iStartLine, DbIndex nLineCnt);

  /** ·ÐßØáÐâì Ò ãÚÐ×ÐÝÝëÙ äÐÙÛ áÞÔÕàÖØÜÞÕ âÐÑÛØæë.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      write (int fd);

  /*
   * ¿àÞØ×ÒÞÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ÃáâÐÝÞÒØâì àÐ×ÜÕà ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå ßàØ ßàÞØ×ÒÞÛìÝÞÜ
      ÔÞáâãßÕ Ú äÐÙÛã. */
  void      set_preread_size (size_t nSize);

  /** ¿ÞÛãçØâì ØÝäÞàÜÐæØî Þ àÐ×ÜÕàÕ ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå. */
  size_t    get_preread_size () const;


  /** ·ÐßØáÐâì Ò äÐÙÛ áÞÔÕàÖØÜÞÕ Ø×ÜÕÝØÒèØåáï áâàÞÚ. */
  void      write_changed ();

  /** ·ÐÓàã×Øâì Ò ßÐÜïâì ÒáÕ áâàÞÚØ äÐÙÛÐ âÐÑÛØæë. */
  void      load_all_lines ();


  /** Mutex to use in MT applications */
  MutexId*  mutex () const;

protected:/* methods */

  /*
   * ¾ßÕàÐæØØ ßÕàÕÞßàÕÔÕÛïÕÜÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ (no _last_ support).
   */

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  read_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  write_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  read_line_seq (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  write_line_seq (DbIndex line1, DbIndex line2);


  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¾ÔÝÐÖÔë ×ÐÓàãÖÕÝÝëÕ áâàÞçÚØ ÝÕ âàÞÓÐîâáï. _last_ support. */
  virtual void  load_lines (DbIndex line1, DbIndex line2);

  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¿ÞÜÕâØâì áâàÞçÚØ ÚÐÚ Ø×ÜÕÝØÒèØÕáï. _last_ support. */
  virtual void  change_lines (DbIndex line1, DbIndex line2);

  /*
   * ½ÐÒØÓÐæØÞÝÝëÕ ÞßÕàÐæØØ.
   */

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ.  ²Þ×ÜÞÖÝÞ, äÐÚâØçÕáÚÐï âÐÑÛØæÐ
      ±´ ÜÞÖÕâ Ø ÝÕ áÞÔÕàÖÐâì áâÞÛÑæÐ á âÐÚØÜ ØÝÔÕÚáÞÜ Ò áØÛã âÞÓÞ,
      çâÞ ÞÝÐ áÞ×ÔÐÝÐ ßÞ áâÐàÞÜã ÞßØáÐâÕÛî. */
  unsigned  n2i (const char* column) const;

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ Ø ßàÞÒÕàØâì ÕÓÞ ÝÐ áÞÞâÒÕâáâÒØÕ
      äÞàÜÐâã ÚÞÝÚàÕâÝÞÙ âÐÑÛØæë ±´ - ÚØÔÐÕâ ERROR__DB_DMN_NOT_FOUND */
  virtual unsigned  valid_n2i (const char* column) const;

  /** ¿ÞÛãçØâì ÐÔàÕá ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÐÜØ áâÞÛÑæÐ Ø áâàÞÚØ.
     ÁâàÞÚÐ ÜÞÖÕâ ÞÚÐ×Ðâìáï ÝÕ×ÐÓàãÖÕÝÝÞÙ Ò ßÐÜïâì! */
  void*     i2ptr (unsigned dmn_i, DbIndex line) const
    {
      DbIndex   line_i = (_last_ == line)? lines_count() - 1: line;
      return (char*)dtable.line_pointer(line_i)
    + fmt.dmns->fetch(dmn_i).offset;
    }

  /** ¿ÞÛãçØâì àÐ×ÜÕà ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÞÜ ÔÞÜÕÝÐ. */
  size_t    i2size (unsigned dmn_i) const
    {
      DbDomainDesc& dd = fmt.dmns->fetch(dmn_i);
      return dd.dim * AtomTypeToSize[dd.atype];
    }

protected:/* data */

  /** ÄÞàÜÐâ âÐÑÛØæë. */
  DbTTDesc  fmt;

  /** ±ãäÕà åàÐÝÕÝØï ÔÐÝÝëå âÐÑÛØæë. */
  DbBufStorage  dtable;

  /** ¼ÐááØÒ ÐâàØÑãâÞÒ áâÞÛÑæÞÒ. */
  DbFileDomainAttr  *dmn_attrs;

  /** ºÞÛØçÕáâÒÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÒÞ×ÜÞÖÝÞ, ÞâÛØçÐÕâáï Þâ
      fmt.dmns->count()) */
  unsigned  nFileDmnsCnt;

private:

  /** ¿àØ×ÝÐÚ Ø×ÜÕÝÕÝÕÝÝÞÓÞ áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë. */
  Logic     bModified;

  /** ¿àØ×ÝÐÚ ÒÞ×ÜÞÖÝÞáâØ Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë.  ½Õ ÒÛØïÕâ ÝÐ
     áâÐàÞÕ áÞáâÞïÝØÕ bModified, ÝÞ ×ÐßàÕéÐÕâ ÕÓÞ Ø×ÜÕÝÕÝØÕ. */
  Logic     bModifiable;

  /** ¿àØ×ÝÐÚØ Òë×ÞÒÐ ÝÕßÕàÕÚàëâëå ÜÕâÞÔÞÒ, ÔÛï âÞÓÞ, çâÞÑë ÝÕ
     ßÞÒâÞàïâì ÜÝÞÓÞÚàÐâÝÞ áÞÞÑéÕÝØÕ ÞÑ ÞèØÑÚÕ. */
  Logic     bLoadErrorSaid, bSaveErrorSaid;

#ifdef DB_RW_LOG_ENABLED
  /** ÁßØáÚØ àÕÐÛìÝÞ ßàÞçØâÐÝÝëå Ø ×ÐßØáÐÝÝëå áâàÞÚ Ò âÐÑÛØæÕ Ú ÜÞÜÕÝâã
     ÕÕ ×ÐÚàëâØï. */
  DbIndexAr rlines;     /**< ßàÞçØâÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */
  DbIndexAr wlines;     /**< ×ÐßØáÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */

#endif /* DB_RW_LOG_ENABLED */

#ifndef NO_HASH
  /** Hash to make n2i() faster: map string to index of domain in fmt */
  std::map<std::string,unsigned>    mHash;
#endif /* NO_HASH */

  /** Mutex id to provide MT safe access. */
  MutexId   *pMutexId;

  /** Size of preread buffer in bytes. */
  size_t    nPreReadSize;

};


inline const DbTTDesc&
DbTable::table_format () const
{
  return fmt;
}


#endif /* DbTable.H */

 *
 * ¸áßÞÛì×ÞÒÐÝØÕ, ÚÞßØàÞÒÐÝØÕ ØÛØ ßÕàÕÔÐçÐ àÕÓãÛØàãîâáï ×ÐÚÞÝÐÜØ
 * ÀÞááØÙáÚÞÙ ÄÕÔÕàÐæØØ "¾Ñ ÐÒâÞàáÚÞÜ ßàÐÒÕ Ø áÜÕÖÝëå ßàÐÒÐå", "¾ * ßàÐÒÞÒÞÙ ÞåàÐÝÕ ßàÞÓàÐÜÜ ÔÛï íÛÕÚâàÞÝÝëå ÒëçØáÛØâÕÛìÝëå ÜÐèØÝ Ø ÑÐ×
 * ÔÐÝÝëå"
 *
 * Encoding: ISO-8859-5 (GOST)
 *
 *********************************************************************/

#ifndef __DbTable_H
#define __DbTable_H

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

#ifndef NO_HASH
#include <map>
#include <string>
#endif /* NO_HASH */

#include <mix/mutex.h>
#include <mix/wenv.h>
#include <ldb/DbTableTypes.H>
#include <ldb/DbBufStorage.H>
#include <ldb/DbFileStorage.H>

/** ²ÚÛîçØâì ÕáÛØ âàÕÑãÕâáï ØÜÕâì áâÐâØáâØÚã ßÞ çØáÛã
   ×ÐßØáÐÝÝëå/ßàÞçØâÐÝÝëå áâàÞÚ. */
//#define DB_RW_LOG_ENABLED

/** ºÞÛØçÕáâÒÞ ßÐÜïâØ Ò áâàÞÚÐå âÐÑÛØæë ÝÐ ÚÞâÞàÞÕ ÑãÔÕâ ãÒÕÛØçØÒÐâìáï
   áÕÓÜÕÝâ ßÐÜïâØ ßàØ àÞáâÕ àÐ×ÜÕàÐ âÐÑÛØæë.  ·ÝÐçÕÝØÕ ßÞ ãÜÞÛçÐÝØî. */
#define DB_QUANT        200

/** ºÞÛØçÕáâÒÞ ßÐÜïâØ Ò áâàÞÚÐå ÒëÔÕÛïÕÜÞÕ ßÞ ãÜÞÛçÐÝØî ßÞÔ ßãáâãî
   âÐÑÛØæã.  ·ÝÐçÕÝØÕ ßÞ ãÜÞÛçÐÝØî. */
#define DB_START_VOLUME     500

/** ÁâÐÝÔÐàâÝëÙ àÐ×ÜÕà ÑãäÕàØ×ÐæØØ ßàØ çâÕÝØØ Ò ÑÐÙâÐå. */
#define DB_NORMAL_PREREAD   (500*1024)

/** ±ÞÛìèÞÙ àÐ×ÜÕà ÑãäÕàØ×ÐæØØ ßàØ çâÕÝØØ Ò ÑÐÙâÐå. */
#define DB_LARGE_PREREAD    (10*1024*1024)

/** ¼ÐÛëÙ àÐ×ÜÕà ÑãäÕàØ×ÐæØØ ßàØ çâÕÝØØ Ò ÑÐÙâÐå. */
#define DB_SMALL_PREREAD    (50*1024)


/**
 ***********************************************************************
 * ºÛÐáá ßÞ àÐÑÞâÕ á âÐÑÛØæÕÙ »±´ ÝÐ ÝØÖÝÕÜ ãàÞÒÝÕ.  ¾ÑÕáßÕçØÒÐÕâ
 * ÞâÞÑàÐÖÕÝØÕ äÐÙÛÐ âÐÑÛØæë »±´ Ò ßÐÜïâì.
 *
 * ½ÞÜÕà áâàÞÚØ Ò âÐÑÛØæÕ ±´ ÞâáçØâëÒÐÕâáï Þâ 0 Ø ÔÞÛÖÕÝ Ñëâì
 * ßÞÛÞÖØâÕÛìÝëÜ.  ´ÞßãáÚÐÕâáï ØáßÞÛì×ÞÒÐâì _last_ Ø× DynAr.H ÔÛï
 * ÔÞáâãßÐ Ú ßÞáÛÕÔÝÕÙ áâàÞÚÕ âÐÑÛØæë.
 *
 * ´Ûï ÜÐááØÒÞÒ Ø× N áØÜÒÞÛÞÒ (âØßë CHAR_1, CHAR_EBCDIC) ØáßÞÛì×ãîâáï
 * áßÕæØÐÛìÝëÕ ßàÐÒØÛÐ ÔÞáâãßÐ.  ¿àØ ×ÐßØáØ Ò âÐÑÛØæã ßÞ set_value()
 * ÚÞßØàãîâáï ÔÞ N áØÜÒÞÛÞÒ ÒÚÛîçØâÕÛìÝÞ ßÞÚÐ ÝÕ ÒáâàÕâØâáï ßàØ×ÝÐÚ
 * ÚÞÝæÐ áâàÞÚØ '\0'.  ² âÐÑÛØæÕ ±´ ÒáÕÓÔÐ åàÐÝØâáï N áØÜÒÞÛÞÒ (ÚÞÝæÕÒÞÙ
 * '\0' ÜÞÖÕâ ÝÕ ãÜÕáâØâìáï).  ¿àØ çâÕÝØØ Ø× âÐÑÛØæë ßÞ get_value()
 * ßàØÕÜÝëÙ ÑãäÕà ÔÞÛÖÕÝ ØÜÕâì ÝÐ ÞÔØÝ ÑÐÙâ ÑÞÛìèÕ ÔÛØÝë áâàÞÚØ, âÐÚ ÚÐÚ
 * ßàØ×ÝÐÚ ÚÞÝæÐ áâàÞÚØ äÞàÜØàãÕâáï ÐÒâÞÜÐâØçÕáÚØ.  ÂÞ Õáâì, ÔÛï
 * ÓÐàÐÝâØØ ßÞÔ ßàØÕÜÝëÙ ÑãäÕà ÔÞÛÖÝÞ Ñëâì ÒëÔÕÛÕÝÞ N+1 ÑÐÙâÞÒ ßÐÜïâØ.
 * ¼ÐááØÒë ÞáâÐÛìÝëå âØßÞÒ ÚÞßØàãÕâáï ÑÐÙâ Ò ÑÐÙâ.
 ***********************************************************************/

class DbTable
{
public:

  /** ÁÞ×ÔÐâì ßãáâãî âÐÑÛØæã ãÚÐ×ÐÝÝÞÙ áâàãÚâãàë Ò ßÐÜïâØ. */
  DbTable (const DbTTDesc& dbtt,
       DbIndex quant = DB_QUANT,
       DbIndex start_volume = DB_START_VOLUME);

  /** ÁÞ×ÔÐâì ÚÞßØî ãÚÐ×ÐÝÝÞÙ âÐÑÛØæë Ò ßÐÜïâØ. */
  DbTable (DbTable& dbt);

  /** ¾áÒÞÑÞÔØâì ßÐÜïâì Ø×-ßÞÔ âÐÑÛØæë Ø àÐ×àãèØâì ÞÑêÕÚâ. */
  virtual ~DbTable ();

  /*
   * ¸ÝäÞàÜÐæØÞÝÝëÕ ÜÕâÞÔë.
   */

  /** ²ÕàÝãâì ááëÛÚã ÝÐ ÞßØáÐÝØÕ âÐÑÛØæë. */
  const DbTTDesc&   table_format () const;

  /** ²ÕàÝãâì ÚÞÛØçÕáâÒÞ áâàÞÚ Ò âÐÑÛØæÕ. */
  virtual DbIndex   lines_count () const;

  /** ²ÕàÝãâì ÚÞÛØçÕáâÒÞ áâàÞÚ Ò ÔØÐßÐ×ÞÝÕ, ãÑàÐâì _last_ Ø ÒÕàÝãâì Ò
     line[] ßÐàã ãßÞàïÔÞçÕÝÝëå ßÞ ÒÞ×àÐáâÐÝØî ØÝÔÕÚáÞÒ áâàÞÚ - ßÕàÒÞÙ
     Ø ßÞáÛÕÔÝÕÙ. */
  virtual DbIndex   lines_range (DbIndex line1, DbIndex line2,
                     DbIndex* line = NULL) const;

  /** ¿ÞÛãçØâì ÔÞáâãß Ú ãÚÐ×ÐÝÝÞÜã áâÞÛÑæã-áâàÞÚÕ âÐÑÛØæë */
  virtual void  get_value (const char* column, DbIndex line,
               void* ptr);

  /** ³àãßßÞÒÐï ÞßÕàÐæØï ßÞ çâÕÝØî ÚÞÛÞÝÚØ ×ÝÐçÕÝØÙ Ø× ãÚÐ×ÐÝÝÞÓÞ
     áâÞÛÑæÐ.  ·ÝÐçÕÝØï áçØâëÒÐîâáï ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ áâàÞÚØ Ò
     ãÚÐ×ÐÝÝÞÜ ÚÞÛØçÕáâÒÕ.  */
  virtual void  get_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, void* ptr);

  /** ¿àÞÒÕàØâì, ïÒÛïÕâáï ÛØ ãÚÐ×ÐÝÝÐï ïçÕÙÚÐ ßãáâÞÙ */
  virtual Logic check_empty_value (const char* column, DbIndex line);

  /** ¿ÞÛãçØâì ×ÝÐçÕÝØÕ äØ×ØçÕáÚÞÙ ÒÕÛØçØÝë áâÞÛÑæÐ */
  virtual UnitId    get_unit (const char* column) const;

  /** ²ÕàÝãâì ááëÛÚã ÝÐ ÜÐááØÒ ÞßØáÐâÕÛÕÙ ÔÞÜÕÝÞÒ. */
  virtual const DmnDescAr&  get_domains ();

  /** ²ÕàÝãâì áâàãÚâãàã-ÞßØáÐâÕÛì ãÚÐ×ÐÝÝÞÓÞ ÔÞÜÕÝÐ. */
  virtual DbDomainDesc  get_domain (const char* column) const;

  /** ÁàÐÒÝØâì ×ÝÐçÕÝØï Ò ïçÕÙÚÐå ãÚÐ×ÐÝÝÞÓÞ ÔÞÜÕÝÐ. */
  virtual Compar    compare_lines (const char* column,
                       DbIndex line1, DbIndex line2);

  /** ¿ÞÛãçØâì ØÜï âØßÐ âÐÑÛØæë. */
  const char*   tt_name () const;

  /** ²ÕàÝãâì TRUE ÕáÛØ âÐÑÛØæÐ ÑëÛÐ ÜÞÔØäØæØàÞÒÐÝÐ Ø FALSE Ò ßàÞâØÒÝÞÜ
     áÛãçÐÕ. */
  Logic     is_modified () const;

  /** ²ÕàÝãâì TRUE ÕáÛØ âÐÑÛØæÐ ÜÞÖÕâ Ñëâì ÜÞÔØäØæØàÞÒÐÝÐ Ò ßÐÜïâØ Ø
     FALSE Ò ßàÞâØÒÝÞÜ áÛãçÐÕ. */
  Logic     is_modifiable () const;


  /*
   * ¾ßÕàÐæØØ ÝÐÔ âÐÑÛØæÕÙ Ò ßÐÜïâØ.
   */

  /** ¾çØáâØâì âÐÑÛØæã Ò ßÐÜïâØ (äÞàÜÐâ ÞáâÐÕâáï, áÞÔÕàÖØÜÞÕ ßàÞßÐÔÐÕâ). */
  virtual void  clean ();

  /** ·ÐßØáÐâì ×ÝÐçÕÝØÕ ãÚÐ×ÐÝÝÞÓÞ áâÞÛÑæÐ-áâàÞÚØ âÐÑÛØæë */
  virtual void  set_value (const char* column, DbIndex line,
               const void* ptr);

  /** ³àãßßÞÒÐï ÞßÕàÐæØï ßÞ ×ÐßØáØ ÚÞÛÞÝÚØ ×ÝÐçÕÝØÙ Ò ãÚÐ×ÐÝÝëÙ
     áâÞÛÑÕæ.  ·ÝÐçÕÝØï ×ÐßØáëÒÐîâáï ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ áâàÞÚØ Ò
     ãÚÐ×ÐÝÝÞÜ ÚÞÛØçÕáâÒÕ. */
  virtual void  set_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, const void* ptr);

  /** ÁÔÕÛÐâì ïçÕÙÚã ßãáâÞÙ. */
  virtual void  set_empty_value (const char* column, DbIndex line);

  /** ¸×ÜÕÝØâì ×ÝÐçÕÝØÕ äØ×ØçÕáÚÞÙ ÒÕÛØçØÝë áâÞÛÑæÐ ÝÐ ãÚÐ×ÐÝÝÞÕ */
  virtual void  set_unit (const char* column, UnitId unid);

  /** ²áâÐÒØâì Ò âÐÑÛØæã áâàÞÚã (áâàÞÚØ) ßÕàÕÔ ãÚÐ×ÐÝÝÞÙ line.
     µáÛØ ãÚÐ×ÐÝÐ áâàÞÚÐ _last_, âÞ ßÞáÛÕ ßÞáÛÕÔÝÕÙ.
     µáÛØ ÐàÓãÜÕÝâ bInit TRUE, âÞ âàÕÑãÕâáï ØÝØæØÐÛØ×ÐæØï áâàÞÚ. */
  virtual void  insert_line (DbIndex line, DbIndex lines_cnt = 1,
                 Logic bInit = TRUE);

  /** ÃÔÐÛØâì Ø× âÐÑÛØæë ãÚÐ×ÐÝÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ [line1..line2] */
  virtual void  remove_lines (DbIndex line1, DbIndex line2);

  /** ¾ÑÜÕÝïâì ÜÕáâÐÜØ ÔÒÕ áâàÞÚØ âÐÑÛØæë */
  virtual void  exchange_lines (DbIndex line1, DbIndex line2);

  /** ´ÞÑÐÒØâì áâàÞÚØ ãÚÐ×ÐÝÝÞÙ âÐÑÛØæë Ò ÚÞÝÕæ íâÞÙ. */
  virtual void  merge (DbTable& src);

  /** ´ÞÑÐÒØâì ãÚÐ×ÐÝÝëÕ áâàÞÚØ âÐÑÛØæë Ò ãÚÐ×ÐÝÝÞÕ ÜÕáâÞ íâÞÙ.
      ·ÐßàÕéÕÝÞ ØáßÞÛì×ÞÒÐÝØÕ _last_ Ò ÚÐçÕáâÒÕ ØÝÔÕÚáÐ.  */
  virtual void  copy_lines (DbIndex iWhere, DbTable& src,
                DbIndex iFrom, DbIndex nLines);

  /** ²ëßÞÛÝÕÝØÕ ÞßÕàÐæØØ ßàØÒÕÔÕâ Ú âÞÜã, çâÞ âÐÑÛØæÐ ÑãÔÕâ áçØâÐâìáï
     Ø×ÜÕÝØÒèÕÙáï.  ÍâÞâ ÜÕâÞÔ Òë×ëÒÐÕâáï ÒÞ ÒáÕå ÜÞÔØäØæØàãîéØå
     ÞßÕàÐæØïå. */
  virtual void  modify ();

  /** ²ëßÞÛÝÕÝØÕ ÞßÕàÐæØØ ßàØÒÕÔÕâ Ú âÞÜã, çâÞ âÐÑÛØæÐ ÑãÔÕâ áçØâÐâìáï
     ÝÕ Ø×ÜÕÝØÒèÕÙáï ÝÕáÜÞâàï ÝÐ ßàÕÔëÔãéØÕ ÞßÕàÐæØØ á ÝÕÙ. */
  virtual void  not_modified ();

  /** ÃáâÐÝÞÒØâì ßàØ×ÝÐÚ ÜÞÔØäØæØàãÕÜÞáâØ âÐÑÛØæë.  µáÛØ ãáâÐÝÞÒØâì
     FALSE, âÞ ÛîÑÐï ÞßÕàÐæØï Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë ×ÐÒÕàèØâáï
     á ÞèØÑÚÞÙ.  ¿Þ ãÜÞÛçÐÝØî äÛÐÓ TRUE. */
  virtual void  set_modifiability (Logic bFlag);


  /*
   * ¾ßÕàÐæØØ äÐÙÛÞÒÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ.
   * ¸ÜÕîâáï ÔÒÐ áßÞáÞÑÐ ÒÒÞÔÐ/ÒëÒÞÔÐ:
   * 1) ßÞáÛÕÔÞÒÐâÕÛìÝëÙ (ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * 2) ßàÞØ×ÒÞÛìÝëÙ (ÝÕ ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * ÁßÞáÞÑ #1 ÒÚÛîçÐÕâ Ò áÕÑï ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ×ÐÓÞÛÞÒÚÐ,
   * ÐâàØÑãâÞÒ Ø áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   * ÁßÞáÞÑ #2 ÒÚÛîçÐÕâ Ò áÕÑï âÞÛìÚÞ ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ÔØÐßÐ×ÞÝÞÒ
   * áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   */

  /*
   * ¿ÞáÛÕÔÞÒÐâÕÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ¿àÞçØâÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
      ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ÁÚÞààÕÚâØàÞÒÐâì
      çØáÛÞ ÔÞÜÕÝÞÒ Ø àÐ×ÜÕà ×ÐßØáØ ÔÞ áÞÒßÐÔÐîéÕÓÞ á äÐÙÛÞÜ ±´.
      ²Þ×ÒàÐâØâì çØáÛÞ áâàÞÚ Ò âÐÑÛØæÕ, çØáÛÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÜÞÖÕâ
      ÞâÛØçÐâìáï Þâ ftm.dmns->count()!) Ø äÞàÜÐâ åàÐÝÕÝØï.  ¼ÞÖÕâ
      àÐÑÞâÐâì á ÚÐÝÐÛÞÜ.  */
  void      read_leader (int fd, ByteOrder& eBO, DbIndex& nLineCnt,
                 unsigned& nDmnsCnt);

  /** ¿àÞçØâÐâì áÞÑáâÒÕÝÝÞ áâàÞÚØ âÐÑÛØæë »±´ Ø× äÐÙÛÐ Ò ÚÞÛØçÕáâÒÕ
     nLineCnt èâãÚ á ßàØÒÕÔÕÝØÕÜ Ø× äÞàÜÐâÐ eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      append_table (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ¿àÞçØâÐâì Ò ßÐÜïâì áÞÔÕàÖØÜÞÕ ãÚÐ×ÐÝÝÞÓÞ äÐÙÛÐ (Ò ÚÞÝÕæ
     ØÜÕîéÕÓÞáï áÞÔÕàÖØÜÞÓÞ).  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      read (int fd);

  /** ·ÐßØáÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
     ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ² ×ÐÓÞÛÞÒÚÕ
     ×ÐßØáëÒÐÕâáï ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ âàÐáá, çâÞ ßÞ×ÒÞÛïÕâ ×ÐßØáëÒÐâì
     Ò äÐÙÛ ßàÞØ×ÒÞÛìÝÞÕ Øå çØáÛÞ.  ·ÐÔÐÕâáï âÐÚÖÕ äÞàÜÐâ åàÐÝÕÝØï Ò
     äÐÙÛÕ.  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      write_leader (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ·ÐßØáÐâì ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ áâàÞÚ ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ Ò äÐÙÛ
     âÐÑÛØæë »±´.  ´ÐÝÝëÕ ßàØÒÞÔïâáï Ú äÞàÜÐâã eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      record_table (int fd, ByteOrder eBO,
                  DbIndex iStartLine, DbIndex nLineCnt);

  /** ·ÐßØáÐâì Ò ãÚÐ×ÐÝÝëÙ äÐÙÛ áÞÔÕàÖØÜÞÕ âÐÑÛØæë.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      write (int fd);

  /*
   * ¿àÞØ×ÒÞÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ÃáâÐÝÞÒØâì àÐ×ÜÕà ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå ßàØ ßàÞØ×ÒÞÛìÝÞÜ
      ÔÞáâãßÕ Ú äÐÙÛã. */
  void      set_preread_size (size_t nSize);

  /** ¿ÞÛãçØâì ØÝäÞàÜÐæØî Þ àÐ×ÜÕàÕ ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå. */
  size_t    get_preread_size () const;


  /** ·ÐßØáÐâì Ò äÐÙÛ áÞÔÕàÖØÜÞÕ Ø×ÜÕÝØÒèØåáï áâàÞÚ. */
  void      write_changed ();

  /** ·ÐÓàã×Øâì Ò ßÐÜïâì ÒáÕ áâàÞÚØ äÐÙÛÐ âÐÑÛØæë. */
  void      load_all_lines ();


  /** Mutex to use in MT applications */
  MutexId*  mutex () const;

protected:/* methods */

  /*
   * ¾ßÕàÐæØØ ßÕàÕÞßàÕÔÕÛïÕÜÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ (no _last_ support).
   */

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  read_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  write_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  read_line_seq (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  write_line_seq (DbIndex line1, DbIndex line2);


  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¾ÔÝÐÖÔë ×ÐÓàãÖÕÝÝëÕ áâàÞçÚØ ÝÕ âàÞÓÐîâáï. _last_ support. */
  virtual void  load_lines (DbIndex line1, DbIndex line2);

  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¿ÞÜÕâØâì áâàÞçÚØ ÚÐÚ Ø×ÜÕÝØÒèØÕáï. _last_ support. */
  virtual void  change_lines (DbIndex line1, DbIndex line2);

  /*
   * ½ÐÒØÓÐæØÞÝÝëÕ ÞßÕàÐæØØ.
   */

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ.  ²Þ×ÜÞÖÝÞ, äÐÚâØçÕáÚÐï âÐÑÛØæÐ
      ±´ ÜÞÖÕâ Ø ÝÕ áÞÔÕàÖÐâì áâÞÛÑæÐ á âÐÚØÜ ØÝÔÕÚáÞÜ Ò áØÛã âÞÓÞ,
      çâÞ ÞÝÐ áÞ×ÔÐÝÐ ßÞ áâÐàÞÜã ÞßØáÐâÕÛî. */
  unsigned  n2i (const char* column) const;

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ Ø ßàÞÒÕàØâì ÕÓÞ ÝÐ áÞÞâÒÕâáâÒØÕ
      äÞàÜÐâã ÚÞÝÚàÕâÝÞÙ âÐÑÛØæë ±´ - ÚØÔÐÕâ ERROR__DB_DMN_NOT_FOUND */
  virtual unsigned  valid_n2i (const char* column) const;

  /** ¿ÞÛãçØâì ÐÔàÕá ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÐÜØ áâÞÛÑæÐ Ø áâàÞÚØ.
     ÁâàÞÚÐ ÜÞÖÕâ ÞÚÐ×Ðâìáï ÝÕ×ÐÓàãÖÕÝÝÞÙ Ò ßÐÜïâì! */
  void*     i2ptr (unsigned dmn_i, DbIndex line) const
    {
      DbIndex   line_i = (_last_ == line)? lines_count() - 1: line;
      return (char*)dtable.line_pointer(line_i)
    + fmt.dmns->fetch(dmn_i).offset;
    }

  /** ¿ÞÛãçØâì àÐ×ÜÕà ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÞÜ ÔÞÜÕÝÐ. */
  size_t    i2size (unsigned dmn_i) const
    {
      DbDomainDesc& dd = fmt.dmns->fetch(dmn_i);
      return dd.dim * AtomTypeToSize[dd.atype];
    }

protected:/* data */

  /** ÄÞàÜÐâ âÐÑÛØæë. */
  DbTTDesc  fmt;

  /** ±ãäÕà åàÐÝÕÝØï ÔÐÝÝëå âÐÑÛØæë. */
  DbBufStorage  dtable;

  /** ¼ÐááØÒ ÐâàØÑãâÞÒ áâÞÛÑæÞÒ. */
  DbFileDomainAttr  *dmn_attrs;

  /** ºÞÛØçÕáâÒÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÒÞ×ÜÞÖÝÞ, ÞâÛØçÐÕâáï Þâ
      fmt.dmns->count()) */
  unsigned  nFileDmnsCnt;

private:

  /** ¿àØ×ÝÐÚ Ø×ÜÕÝÕÝÕÝÝÞÓÞ áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë. */
  Logic     bModified;

  /** ¿àØ×ÝÐÚ ÒÞ×ÜÞÖÝÞáâØ Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë.  ½Õ ÒÛØïÕâ ÝÐ
     áâÐàÞÕ áÞáâÞïÝØÕ bModified, ÝÞ ×ÐßàÕéÐÕâ ÕÓÞ Ø×ÜÕÝÕÝØÕ. */
  Logic     bModifiable;

  /** ¿àØ×ÝÐÚØ Òë×ÞÒÐ ÝÕßÕàÕÚàëâëå ÜÕâÞÔÞÒ, ÔÛï âÞÓÞ, çâÞÑë ÝÕ
     ßÞÒâÞàïâì ÜÝÞÓÞÚàÐâÝÞ áÞÞÑéÕÝØÕ ÞÑ ÞèØÑÚÕ. */
  Logic     bLoadErrorSaid, bSaveErrorSaid;

#ifdef DB_RW_LOG_ENABLED
  /** ÁßØáÚØ àÕÐÛìÝÞ ßàÞçØâÐÝÝëå Ø ×ÐßØáÐÝÝëå áâàÞÚ Ò âÐÑÛØæÕ Ú ÜÞÜÕÝâã
     ÕÕ ×ÐÚàëâØï. */
  DbIndexAr rlines;     /**< ßàÞçØâÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */
  DbIndexAr wlines;     /**< ×ÐßØáÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */

#endif /* DB_RW_LOG_ENABLED */

#ifndef NO_HASH
  /** Hash to make n2i() faster: map string to index of domain in fmt */
  std::map<std::string,unsigned>    mHash;
#endif /* NO_HASH */

  /** Mutex id to provide MT safe access. */
  MutexId   *pMutexId;

  /** Size of preread buffer in bytes. */
  size_t    nPreReadSize;

};


inline const DbTTDesc&
DbTable::table_format () const
{
  return fmt;
}


#endif /* DbTable.H */

 * ßàÐÒÞÒÞÙ ÞåàÐÝÕ ßàÞÓàÐÜÜ ÔÛï íÛÕÚâàÞÝÝëå ÒëçØáÛØâÕÛìÝëå ÜÐèØÝ Ø ÑÐ× * ÔÐÝÝëå"
 *
 * Encoding: ISO-8859-5 (GOST)
 *
 *********************************************************************/

#ifndef __DbTable_H
#define __DbTable_H

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

#ifndef NO_HASH
#include <map>
#include <string>
#endif /* NO_HASH */

#include <mix/mutex.h>
#include <mix/wenv.h>
#include <ldb/DbTableTypes.H>
#include <ldb/DbBufStorage.H>
#include <ldb/DbFileStorage.H>

/** ²ÚÛîçØâì ÕáÛØ âàÕÑãÕâáï ØÜÕâì áâÐâØáâØÚã ßÞ çØáÛã
   ×ÐßØáÐÝÝëå/ßàÞçØâÐÝÝëå áâàÞÚ. */
//#define DB_RW_LOG_ENABLED

/** ºÞÛØçÕáâÒÞ ßÐÜïâØ Ò áâàÞÚÐå âÐÑÛØæë ÝÐ ÚÞâÞàÞÕ ÑãÔÕâ ãÒÕÛØçØÒÐâìáï
   áÕÓÜÕÝâ ßÐÜïâØ ßàØ àÞáâÕ àÐ×ÜÕàÐ âÐÑÛØæë.  ·ÝÐçÕÝØÕ ßÞ ãÜÞÛçÐÝØî. */
#define DB_QUANT        200

/** ºÞÛØçÕáâÒÞ ßÐÜïâØ Ò áâàÞÚÐå ÒëÔÕÛïÕÜÞÕ ßÞ ãÜÞÛçÐÝØî ßÞÔ ßãáâãî
   âÐÑÛØæã.  ·ÝÐçÕÝØÕ ßÞ ãÜÞÛçÐÝØî. */
#define DB_START_VOLUME     500

/** ÁâÐÝÔÐàâÝëÙ àÐ×ÜÕà ÑãäÕàØ×ÐæØØ ßàØ çâÕÝØØ Ò ÑÐÙâÐå. */
#define DB_NORMAL_PREREAD   (500*1024)

/** ±ÞÛìèÞÙ àÐ×ÜÕà ÑãäÕàØ×ÐæØØ ßàØ çâÕÝØØ Ò ÑÐÙâÐå. */
#define DB_LARGE_PREREAD    (10*1024*1024)

/** ¼ÐÛëÙ àÐ×ÜÕà ÑãäÕàØ×ÐæØØ ßàØ çâÕÝØØ Ò ÑÐÙâÐå. */
#define DB_SMALL_PREREAD    (50*1024)


/**
 ***********************************************************************
 * ºÛÐáá ßÞ àÐÑÞâÕ á âÐÑÛØæÕÙ »±´ ÝÐ ÝØÖÝÕÜ ãàÞÒÝÕ.  ¾ÑÕáßÕçØÒÐÕâ
 * ÞâÞÑàÐÖÕÝØÕ äÐÙÛÐ âÐÑÛØæë »±´ Ò ßÐÜïâì.
 *
 * ½ÞÜÕà áâàÞÚØ Ò âÐÑÛØæÕ ±´ ÞâáçØâëÒÐÕâáï Þâ 0 Ø ÔÞÛÖÕÝ Ñëâì
 * ßÞÛÞÖØâÕÛìÝëÜ.  ´ÞßãáÚÐÕâáï ØáßÞÛì×ÞÒÐâì _last_ Ø× DynAr.H ÔÛï
 * ÔÞáâãßÐ Ú ßÞáÛÕÔÝÕÙ áâàÞÚÕ âÐÑÛØæë.
 *
 * ´Ûï ÜÐááØÒÞÒ Ø× N áØÜÒÞÛÞÒ (âØßë CHAR_1, CHAR_EBCDIC) ØáßÞÛì×ãîâáï
 * áßÕæØÐÛìÝëÕ ßàÐÒØÛÐ ÔÞáâãßÐ.  ¿àØ ×ÐßØáØ Ò âÐÑÛØæã ßÞ set_value()
 * ÚÞßØàãîâáï ÔÞ N áØÜÒÞÛÞÒ ÒÚÛîçØâÕÛìÝÞ ßÞÚÐ ÝÕ ÒáâàÕâØâáï ßàØ×ÝÐÚ
 * ÚÞÝæÐ áâàÞÚØ '\0'.  ² âÐÑÛØæÕ ±´ ÒáÕÓÔÐ åàÐÝØâáï N áØÜÒÞÛÞÒ (ÚÞÝæÕÒÞÙ
 * '\0' ÜÞÖÕâ ÝÕ ãÜÕáâØâìáï).  ¿àØ çâÕÝØØ Ø× âÐÑÛØæë ßÞ get_value()
 * ßàØÕÜÝëÙ ÑãäÕà ÔÞÛÖÕÝ ØÜÕâì ÝÐ ÞÔØÝ ÑÐÙâ ÑÞÛìèÕ ÔÛØÝë áâàÞÚØ, âÐÚ ÚÐÚ
 * ßàØ×ÝÐÚ ÚÞÝæÐ áâàÞÚØ äÞàÜØàãÕâáï ÐÒâÞÜÐâØçÕáÚØ.  ÂÞ Õáâì, ÔÛï
 * ÓÐàÐÝâØØ ßÞÔ ßàØÕÜÝëÙ ÑãäÕà ÔÞÛÖÝÞ Ñëâì ÒëÔÕÛÕÝÞ N+1 ÑÐÙâÞÒ ßÐÜïâØ.
 * ¼ÐááØÒë ÞáâÐÛìÝëå âØßÞÒ ÚÞßØàãÕâáï ÑÐÙâ Ò ÑÐÙâ.
 ***********************************************************************/

class DbTable
{
public:

  /** ÁÞ×ÔÐâì ßãáâãî âÐÑÛØæã ãÚÐ×ÐÝÝÞÙ áâàãÚâãàë Ò ßÐÜïâØ. */
  DbTable (const DbTTDesc& dbtt,
       DbIndex quant = DB_QUANT,
       DbIndex start_volume = DB_START_VOLUME);

  /** ÁÞ×ÔÐâì ÚÞßØî ãÚÐ×ÐÝÝÞÙ âÐÑÛØæë Ò ßÐÜïâØ. */
  DbTable (DbTable& dbt);

  /** ¾áÒÞÑÞÔØâì ßÐÜïâì Ø×-ßÞÔ âÐÑÛØæë Ø àÐ×àãèØâì ÞÑêÕÚâ. */
  virtual ~DbTable ();

  /*
   * ¸ÝäÞàÜÐæØÞÝÝëÕ ÜÕâÞÔë.
   */

  /** ²ÕàÝãâì ááëÛÚã ÝÐ ÞßØáÐÝØÕ âÐÑÛØæë. */
  const DbTTDesc&   table_format () const;

  /** ²ÕàÝãâì ÚÞÛØçÕáâÒÞ áâàÞÚ Ò âÐÑÛØæÕ. */
  virtual DbIndex   lines_count () const;

  /** ²ÕàÝãâì ÚÞÛØçÕáâÒÞ áâàÞÚ Ò ÔØÐßÐ×ÞÝÕ, ãÑàÐâì _last_ Ø ÒÕàÝãâì Ò
     line[] ßÐàã ãßÞàïÔÞçÕÝÝëå ßÞ ÒÞ×àÐáâÐÝØî ØÝÔÕÚáÞÒ áâàÞÚ - ßÕàÒÞÙ
     Ø ßÞáÛÕÔÝÕÙ. */
  virtual DbIndex   lines_range (DbIndex line1, DbIndex line2,
                     DbIndex* line = NULL) const;

  /** ¿ÞÛãçØâì ÔÞáâãß Ú ãÚÐ×ÐÝÝÞÜã áâÞÛÑæã-áâàÞÚÕ âÐÑÛØæë */
  virtual void  get_value (const char* column, DbIndex line,
               void* ptr);

  /** ³àãßßÞÒÐï ÞßÕàÐæØï ßÞ çâÕÝØî ÚÞÛÞÝÚØ ×ÝÐçÕÝØÙ Ø× ãÚÐ×ÐÝÝÞÓÞ
     áâÞÛÑæÐ.  ·ÝÐçÕÝØï áçØâëÒÐîâáï ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ áâàÞÚØ Ò
     ãÚÐ×ÐÝÝÞÜ ÚÞÛØçÕáâÒÕ.  */
  virtual void  get_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, void* ptr);

  /** ¿àÞÒÕàØâì, ïÒÛïÕâáï ÛØ ãÚÐ×ÐÝÝÐï ïçÕÙÚÐ ßãáâÞÙ */
  virtual Logic check_empty_value (const char* column, DbIndex line);

  /** ¿ÞÛãçØâì ×ÝÐçÕÝØÕ äØ×ØçÕáÚÞÙ ÒÕÛØçØÝë áâÞÛÑæÐ */
  virtual UnitId    get_unit (const char* column) const;

  /** ²ÕàÝãâì ááëÛÚã ÝÐ ÜÐááØÒ ÞßØáÐâÕÛÕÙ ÔÞÜÕÝÞÒ. */
  virtual const DmnDescAr&  get_domains ();

  /** ²ÕàÝãâì áâàãÚâãàã-ÞßØáÐâÕÛì ãÚÐ×ÐÝÝÞÓÞ ÔÞÜÕÝÐ. */
  virtual DbDomainDesc  get_domain (const char* column) const;

  /** ÁàÐÒÝØâì ×ÝÐçÕÝØï Ò ïçÕÙÚÐå ãÚÐ×ÐÝÝÞÓÞ ÔÞÜÕÝÐ. */
  virtual Compar    compare_lines (const char* column,
                       DbIndex line1, DbIndex line2);

  /** ¿ÞÛãçØâì ØÜï âØßÐ âÐÑÛØæë. */
  const char*   tt_name () const;

  /** ²ÕàÝãâì TRUE ÕáÛØ âÐÑÛØæÐ ÑëÛÐ ÜÞÔØäØæØàÞÒÐÝÐ Ø FALSE Ò ßàÞâØÒÝÞÜ
     áÛãçÐÕ. */
  Logic     is_modified () const;

  /** ²ÕàÝãâì TRUE ÕáÛØ âÐÑÛØæÐ ÜÞÖÕâ Ñëâì ÜÞÔØäØæØàÞÒÐÝÐ Ò ßÐÜïâØ Ø
     FALSE Ò ßàÞâØÒÝÞÜ áÛãçÐÕ. */
  Logic     is_modifiable () const;


  /*
   * ¾ßÕàÐæØØ ÝÐÔ âÐÑÛØæÕÙ Ò ßÐÜïâØ.
   */

  /** ¾çØáâØâì âÐÑÛØæã Ò ßÐÜïâØ (äÞàÜÐâ ÞáâÐÕâáï, áÞÔÕàÖØÜÞÕ ßàÞßÐÔÐÕâ). */
  virtual void  clean ();

  /** ·ÐßØáÐâì ×ÝÐçÕÝØÕ ãÚÐ×ÐÝÝÞÓÞ áâÞÛÑæÐ-áâàÞÚØ âÐÑÛØæë */
  virtual void  set_value (const char* column, DbIndex line,
               const void* ptr);

  /** ³àãßßÞÒÐï ÞßÕàÐæØï ßÞ ×ÐßØáØ ÚÞÛÞÝÚØ ×ÝÐçÕÝØÙ Ò ãÚÐ×ÐÝÝëÙ
     áâÞÛÑÕæ.  ·ÝÐçÕÝØï ×ÐßØáëÒÐîâáï ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ áâàÞÚØ Ò
     ãÚÐ×ÐÝÝÞÜ ÚÞÛØçÕáâÒÕ. */
  virtual void  set_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, const void* ptr);

  /** ÁÔÕÛÐâì ïçÕÙÚã ßãáâÞÙ. */
  virtual void  set_empty_value (const char* column, DbIndex line);

  /** ¸×ÜÕÝØâì ×ÝÐçÕÝØÕ äØ×ØçÕáÚÞÙ ÒÕÛØçØÝë áâÞÛÑæÐ ÝÐ ãÚÐ×ÐÝÝÞÕ */
  virtual void  set_unit (const char* column, UnitId unid);

  /** ²áâÐÒØâì Ò âÐÑÛØæã áâàÞÚã (áâàÞÚØ) ßÕàÕÔ ãÚÐ×ÐÝÝÞÙ line.
     µáÛØ ãÚÐ×ÐÝÐ áâàÞÚÐ _last_, âÞ ßÞáÛÕ ßÞáÛÕÔÝÕÙ.
     µáÛØ ÐàÓãÜÕÝâ bInit TRUE, âÞ âàÕÑãÕâáï ØÝØæØÐÛØ×ÐæØï áâàÞÚ. */
  virtual void  insert_line (DbIndex line, DbIndex lines_cnt = 1,
                 Logic bInit = TRUE);

  /** ÃÔÐÛØâì Ø× âÐÑÛØæë ãÚÐ×ÐÝÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ [line1..line2] */
  virtual void  remove_lines (DbIndex line1, DbIndex line2);

  /** ¾ÑÜÕÝïâì ÜÕáâÐÜØ ÔÒÕ áâàÞÚØ âÐÑÛØæë */
  virtual void  exchange_lines (DbIndex line1, DbIndex line2);

  /** ´ÞÑÐÒØâì áâàÞÚØ ãÚÐ×ÐÝÝÞÙ âÐÑÛØæë Ò ÚÞÝÕæ íâÞÙ. */
  virtual void  merge (DbTable& src);

  /** ´ÞÑÐÒØâì ãÚÐ×ÐÝÝëÕ áâàÞÚØ âÐÑÛØæë Ò ãÚÐ×ÐÝÝÞÕ ÜÕáâÞ íâÞÙ.
      ·ÐßàÕéÕÝÞ ØáßÞÛì×ÞÒÐÝØÕ _last_ Ò ÚÐçÕáâÒÕ ØÝÔÕÚáÐ.  */
  virtual void  copy_lines (DbIndex iWhere, DbTable& src,
                DbIndex iFrom, DbIndex nLines);

  /** ²ëßÞÛÝÕÝØÕ ÞßÕàÐæØØ ßàØÒÕÔÕâ Ú âÞÜã, çâÞ âÐÑÛØæÐ ÑãÔÕâ áçØâÐâìáï
     Ø×ÜÕÝØÒèÕÙáï.  ÍâÞâ ÜÕâÞÔ Òë×ëÒÐÕâáï ÒÞ ÒáÕå ÜÞÔØäØæØàãîéØå
     ÞßÕàÐæØïå. */
  virtual void  modify ();

  /** ²ëßÞÛÝÕÝØÕ ÞßÕàÐæØØ ßàØÒÕÔÕâ Ú âÞÜã, çâÞ âÐÑÛØæÐ ÑãÔÕâ áçØâÐâìáï
     ÝÕ Ø×ÜÕÝØÒèÕÙáï ÝÕáÜÞâàï ÝÐ ßàÕÔëÔãéØÕ ÞßÕàÐæØØ á ÝÕÙ. */
  virtual void  not_modified ();

  /** ÃáâÐÝÞÒØâì ßàØ×ÝÐÚ ÜÞÔØäØæØàãÕÜÞáâØ âÐÑÛØæë.  µáÛØ ãáâÐÝÞÒØâì
     FALSE, âÞ ÛîÑÐï ÞßÕàÐæØï Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë ×ÐÒÕàèØâáï
     á ÞèØÑÚÞÙ.  ¿Þ ãÜÞÛçÐÝØî äÛÐÓ TRUE. */
  virtual void  set_modifiability (Logic bFlag);


  /*
   * ¾ßÕàÐæØØ äÐÙÛÞÒÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ.
   * ¸ÜÕîâáï ÔÒÐ áßÞáÞÑÐ ÒÒÞÔÐ/ÒëÒÞÔÐ:
   * 1) ßÞáÛÕÔÞÒÐâÕÛìÝëÙ (ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * 2) ßàÞØ×ÒÞÛìÝëÙ (ÝÕ ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * ÁßÞáÞÑ #1 ÒÚÛîçÐÕâ Ò áÕÑï ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ×ÐÓÞÛÞÒÚÐ,
   * ÐâàØÑãâÞÒ Ø áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   * ÁßÞáÞÑ #2 ÒÚÛîçÐÕâ Ò áÕÑï âÞÛìÚÞ ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ÔØÐßÐ×ÞÝÞÒ
   * áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   */

  /*
   * ¿ÞáÛÕÔÞÒÐâÕÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ¿àÞçØâÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
      ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ÁÚÞààÕÚâØàÞÒÐâì
      çØáÛÞ ÔÞÜÕÝÞÒ Ø àÐ×ÜÕà ×ÐßØáØ ÔÞ áÞÒßÐÔÐîéÕÓÞ á äÐÙÛÞÜ ±´.
      ²Þ×ÒàÐâØâì çØáÛÞ áâàÞÚ Ò âÐÑÛØæÕ, çØáÛÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÜÞÖÕâ
      ÞâÛØçÐâìáï Þâ ftm.dmns->count()!) Ø äÞàÜÐâ åàÐÝÕÝØï.  ¼ÞÖÕâ
      àÐÑÞâÐâì á ÚÐÝÐÛÞÜ.  */
  void      read_leader (int fd, ByteOrder& eBO, DbIndex& nLineCnt,
                 unsigned& nDmnsCnt);

  /** ¿àÞçØâÐâì áÞÑáâÒÕÝÝÞ áâàÞÚØ âÐÑÛØæë »±´ Ø× äÐÙÛÐ Ò ÚÞÛØçÕáâÒÕ
     nLineCnt èâãÚ á ßàØÒÕÔÕÝØÕÜ Ø× äÞàÜÐâÐ eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      append_table (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ¿àÞçØâÐâì Ò ßÐÜïâì áÞÔÕàÖØÜÞÕ ãÚÐ×ÐÝÝÞÓÞ äÐÙÛÐ (Ò ÚÞÝÕæ
     ØÜÕîéÕÓÞáï áÞÔÕàÖØÜÞÓÞ).  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      read (int fd);

  /** ·ÐßØáÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
     ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ² ×ÐÓÞÛÞÒÚÕ
     ×ÐßØáëÒÐÕâáï ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ âàÐáá, çâÞ ßÞ×ÒÞÛïÕâ ×ÐßØáëÒÐâì
     Ò äÐÙÛ ßàÞØ×ÒÞÛìÝÞÕ Øå çØáÛÞ.  ·ÐÔÐÕâáï âÐÚÖÕ äÞàÜÐâ åàÐÝÕÝØï Ò
     äÐÙÛÕ.  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      write_leader (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ·ÐßØáÐâì ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ áâàÞÚ ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ Ò äÐÙÛ
     âÐÑÛØæë »±´.  ´ÐÝÝëÕ ßàØÒÞÔïâáï Ú äÞàÜÐâã eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      record_table (int fd, ByteOrder eBO,
                  DbIndex iStartLine, DbIndex nLineCnt);

  /** ·ÐßØáÐâì Ò ãÚÐ×ÐÝÝëÙ äÐÙÛ áÞÔÕàÖØÜÞÕ âÐÑÛØæë.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      write (int fd);

  /*
   * ¿àÞØ×ÒÞÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ÃáâÐÝÞÒØâì àÐ×ÜÕà ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå ßàØ ßàÞØ×ÒÞÛìÝÞÜ
      ÔÞáâãßÕ Ú äÐÙÛã. */
  void      set_preread_size (size_t nSize);

  /** ¿ÞÛãçØâì ØÝäÞàÜÐæØî Þ àÐ×ÜÕàÕ ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå. */
  size_t    get_preread_size () const;


  /** ·ÐßØáÐâì Ò äÐÙÛ áÞÔÕàÖØÜÞÕ Ø×ÜÕÝØÒèØåáï áâàÞÚ. */
  void      write_changed ();

  /** ·ÐÓàã×Øâì Ò ßÐÜïâì ÒáÕ áâàÞÚØ äÐÙÛÐ âÐÑÛØæë. */
  void      load_all_lines ();


  /** Mutex to use in MT applications */
  MutexId*  mutex () const;

protected:/* methods */

  /*
   * ¾ßÕàÐæØØ ßÕàÕÞßàÕÔÕÛïÕÜÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ (no _last_ support).
   */

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  read_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  write_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  read_line_seq (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  write_line_seq (DbIndex line1, DbIndex line2);


  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¾ÔÝÐÖÔë ×ÐÓàãÖÕÝÝëÕ áâàÞçÚØ ÝÕ âàÞÓÐîâáï. _last_ support. */
  virtual void  load_lines (DbIndex line1, DbIndex line2);

  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¿ÞÜÕâØâì áâàÞçÚØ ÚÐÚ Ø×ÜÕÝØÒèØÕáï. _last_ support. */
  virtual void  change_lines (DbIndex line1, DbIndex line2);

  /*
   * ½ÐÒØÓÐæØÞÝÝëÕ ÞßÕàÐæØØ.
   */

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ.  ²Þ×ÜÞÖÝÞ, äÐÚâØçÕáÚÐï âÐÑÛØæÐ
      ±´ ÜÞÖÕâ Ø ÝÕ áÞÔÕàÖÐâì áâÞÛÑæÐ á âÐÚØÜ ØÝÔÕÚáÞÜ Ò áØÛã âÞÓÞ,
      çâÞ ÞÝÐ áÞ×ÔÐÝÐ ßÞ áâÐàÞÜã ÞßØáÐâÕÛî. */
  unsigned  n2i (const char* column) const;

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ Ø ßàÞÒÕàØâì ÕÓÞ ÝÐ áÞÞâÒÕâáâÒØÕ
      äÞàÜÐâã ÚÞÝÚàÕâÝÞÙ âÐÑÛØæë ±´ - ÚØÔÐÕâ ERROR__DB_DMN_NOT_FOUND */
  virtual unsigned  valid_n2i (const char* column) const;

  /** ¿ÞÛãçØâì ÐÔàÕá ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÐÜØ áâÞÛÑæÐ Ø áâàÞÚØ.
     ÁâàÞÚÐ ÜÞÖÕâ ÞÚÐ×Ðâìáï ÝÕ×ÐÓàãÖÕÝÝÞÙ Ò ßÐÜïâì! */
  void*     i2ptr (unsigned dmn_i, DbIndex line) const
    {
      DbIndex   line_i = (_last_ == line)? lines_count() - 1: line;
      return (char*)dtable.line_pointer(line_i)
    + fmt.dmns->fetch(dmn_i).offset;
    }

  /** ¿ÞÛãçØâì àÐ×ÜÕà ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÞÜ ÔÞÜÕÝÐ. */
  size_t    i2size (unsigned dmn_i) const
    {
      DbDomainDesc& dd = fmt.dmns->fetch(dmn_i);
      return dd.dim * AtomTypeToSize[dd.atype];
    }

protected:/* data */

  /** ÄÞàÜÐâ âÐÑÛØæë. */
  DbTTDesc  fmt;

  /** ±ãäÕà åàÐÝÕÝØï ÔÐÝÝëå âÐÑÛØæë. */
  DbBufStorage  dtable;

  /** ¼ÐááØÒ ÐâàØÑãâÞÒ áâÞÛÑæÞÒ. */
  DbFileDomainAttr  *dmn_attrs;

  /** ºÞÛØçÕáâÒÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÒÞ×ÜÞÖÝÞ, ÞâÛØçÐÕâáï Þâ
      fmt.dmns->count()) */
  unsigned  nFileDmnsCnt;

private:

  /** ¿àØ×ÝÐÚ Ø×ÜÕÝÕÝÕÝÝÞÓÞ áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë. */
  Logic     bModified;

  /** ¿àØ×ÝÐÚ ÒÞ×ÜÞÖÝÞáâØ Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë.  ½Õ ÒÛØïÕâ ÝÐ
     áâÐàÞÕ áÞáâÞïÝØÕ bModified, ÝÞ ×ÐßàÕéÐÕâ ÕÓÞ Ø×ÜÕÝÕÝØÕ. */
  Logic     bModifiable;

  /** ¿àØ×ÝÐÚØ Òë×ÞÒÐ ÝÕßÕàÕÚàëâëå ÜÕâÞÔÞÒ, ÔÛï âÞÓÞ, çâÞÑë ÝÕ
     ßÞÒâÞàïâì ÜÝÞÓÞÚàÐâÝÞ áÞÞÑéÕÝØÕ ÞÑ ÞèØÑÚÕ. */
  Logic     bLoadErrorSaid, bSaveErrorSaid;

#ifdef DB_RW_LOG_ENABLED
  /** ÁßØáÚØ àÕÐÛìÝÞ ßàÞçØâÐÝÝëå Ø ×ÐßØáÐÝÝëå áâàÞÚ Ò âÐÑÛØæÕ Ú ÜÞÜÕÝâã
     ÕÕ ×ÐÚàëâØï. */
  DbIndexAr rlines;     /**< ßàÞçØâÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */
  DbIndexAr wlines;     /**< ×ÐßØáÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */

#endif /* DB_RW_LOG_ENABLED */

#ifndef NO_HASH
  /** Hash to make n2i() faster: map string to index of domain in fmt */
  std::map<std::string,unsigned>    mHash;
#endif /* NO_HASH */

  /** Mutex id to provide MT safe access. */
  MutexId   *pMutexId;

  /** Size of preread buffer in bytes. */
  size_t    nPreReadSize;

};


inline const DbTTDesc&
DbTable::table_format () const
{
  return fmt;
}


#endif /* DbTable.H */

 * ÔÐÝÝëå"
 *
 * Encoding: ISO-8859-5 (GOST)
 *
 *********************************************************************/

#ifndef __DbTable_H
#define __DbTable_H

#ifndef NO_HASH
#include <map>
#include <string>
#endif /* NO_HASH */

#include <mix/mutex.h>
#include <mix/wenv.h>
#include <ldb/DbTableTypes.H>
#include <ldb/DbBufStorage.H>
#include <ldb/DbFileStorage.H>

//#define DB_RW_LOG_ENABLED

#define DB_QUANT        200

#define DB_START_VOLUME     500

#define DB_NORMAL_PREREAD   (500*1024)

#define DB_LARGE_PREREAD    (10*1024*1024)

#define DB_SMALL_PREREAD    (50*1024)


class DbTable
{
public:

  DbTable (const DbTTDesc& dbtt,
       DbIndex quant = DB_QUANT,
       DbIndex start_volume = DB_START_VOLUME);

  DbTable (DbTable& dbt);

  virtual ~DbTable ();

  /*
   * ¸ÝäÞàÜÐæØÞÝÝëÕ ÜÕâÞÔë.   */

  /** ²ÕàÝãâì ááëÛÚã ÝÐ ÞßØáÐÝØÕ âÐÑÛØæë. */
  const DbTTDesc&   table_format () const;

  /** ²ÕàÝãâì ÚÞÛØçÕáâÒÞ áâàÞÚ Ò âÐÑÛØæÕ. */
  virtual DbIndex   lines_count () const;

  /** ²ÕàÝãâì ÚÞÛØçÕáâÒÞ áâàÞÚ Ò ÔØÐßÐ×ÞÝÕ, ãÑàÐâì _last_ Ø ÒÕàÝãâì Ò
     line[] ßÐàã ãßÞàïÔÞçÕÝÝëå ßÞ ÒÞ×àÐáâÐÝØî ØÝÔÕÚáÞÒ áâàÞÚ - ßÕàÒÞÙ
     Ø ßÞáÛÕÔÝÕÙ. */
  virtual DbIndex   lines_range (DbIndex line1, DbIndex line2,
                     DbIndex* line = NULL) const;

  /** ¿ÞÛãçØâì ÔÞáâãß Ú ãÚÐ×ÐÝÝÞÜã áâÞÛÑæã-áâàÞÚÕ âÐÑÛØæë */
  virtual void  get_value (const char* column, DbIndex line,
               void* ptr);

  /** ³àãßßÞÒÐï ÞßÕàÐæØï ßÞ çâÕÝØî ÚÞÛÞÝÚØ ×ÝÐçÕÝØÙ Ø× ãÚÐ×ÐÝÝÞÓÞ
     áâÞÛÑæÐ.  ·ÝÐçÕÝØï áçØâëÒÐîâáï ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ áâàÞÚØ Ò
     ãÚÐ×ÐÝÝÞÜ ÚÞÛØçÕáâÒÕ.  */
  virtual void  get_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, void* ptr);

  /** ¿àÞÒÕàØâì, ïÒÛïÕâáï ÛØ ãÚÐ×ÐÝÝÐï ïçÕÙÚÐ ßãáâÞÙ */
  virtual Logic check_empty_value (const char* column, DbIndex line);

  /** ¿ÞÛãçØâì ×ÝÐçÕÝØÕ äØ×ØçÕáÚÞÙ ÒÕÛØçØÝë áâÞÛÑæÐ */
  virtual UnitId    get_unit (const char* column) const;

  /** ²ÕàÝãâì ááëÛÚã ÝÐ ÜÐááØÒ ÞßØáÐâÕÛÕÙ ÔÞÜÕÝÞÒ. */
  virtual const DmnDescAr&  get_domains ();

  /** ²ÕàÝãâì áâàãÚâãàã-ÞßØáÐâÕÛì ãÚÐ×ÐÝÝÞÓÞ ÔÞÜÕÝÐ. */
  virtual DbDomainDesc  get_domain (const char* column) const;

  /** ÁàÐÒÝØâì ×ÝÐçÕÝØï Ò ïçÕÙÚÐå ãÚÐ×ÐÝÝÞÓÞ ÔÞÜÕÝÐ. */
  virtual Compar    compare_lines (const char* column,
                       DbIndex line1, DbIndex line2);

  /** ¿ÞÛãçØâì ØÜï âØßÐ âÐÑÛØæë. */
  const char*   tt_name () const;

  /** ²ÕàÝãâì TRUE ÕáÛØ âÐÑÛØæÐ ÑëÛÐ ÜÞÔØäØæØàÞÒÐÝÐ Ø FALSE Ò ßàÞâØÒÝÞÜ
     áÛãçÐÕ. */
  Logic     is_modified () const;

  /** ²ÕàÝãâì TRUE ÕáÛØ âÐÑÛØæÐ ÜÞÖÕâ Ñëâì ÜÞÔØäØæØàÞÒÐÝÐ Ò ßÐÜïâØ Ø
     FALSE Ò ßàÞâØÒÝÞÜ áÛãçÐÕ. */
  Logic     is_modifiable () const;


  /*
   * ¾ßÕàÐæØØ ÝÐÔ âÐÑÛØæÕÙ Ò ßÐÜïâØ.
   */

  /** ¾çØáâØâì âÐÑÛØæã Ò ßÐÜïâØ (äÞàÜÐâ ÞáâÐÕâáï, áÞÔÕàÖØÜÞÕ ßàÞßÐÔÐÕâ). */
  virtual void  clean ();

  /** ·ÐßØáÐâì ×ÝÐçÕÝØÕ ãÚÐ×ÐÝÝÞÓÞ áâÞÛÑæÐ-áâàÞÚØ âÐÑÛØæë */
  virtual void  set_value (const char* column, DbIndex line,
               const void* ptr);

  /** ³àãßßÞÒÐï ÞßÕàÐæØï ßÞ ×ÐßØáØ ÚÞÛÞÝÚØ ×ÝÐçÕÝØÙ Ò ãÚÐ×ÐÝÝëÙ
     áâÞÛÑÕæ.  ·ÝÐçÕÝØï ×ÐßØáëÒÐîâáï ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ áâàÞÚØ Ò
     ãÚÐ×ÐÝÝÞÜ ÚÞÛØçÕáâÒÕ. */
  virtual void  set_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, const void* ptr);

  /** ÁÔÕÛÐâì ïçÕÙÚã ßãáâÞÙ. */
  virtual void  set_empty_value (const char* column, DbIndex line);

  /** ¸×ÜÕÝØâì ×ÝÐçÕÝØÕ äØ×ØçÕáÚÞÙ ÒÕÛØçØÝë áâÞÛÑæÐ ÝÐ ãÚÐ×ÐÝÝÞÕ */
  virtual void  set_unit (const char* column, UnitId unid);

  /** ²áâÐÒØâì Ò âÐÑÛØæã áâàÞÚã (áâàÞÚØ) ßÕàÕÔ ãÚÐ×ÐÝÝÞÙ line.
     µáÛØ ãÚÐ×ÐÝÐ áâàÞÚÐ _last_, âÞ ßÞáÛÕ ßÞáÛÕÔÝÕÙ.
     µáÛØ ÐàÓãÜÕÝâ bInit TRUE, âÞ âàÕÑãÕâáï ØÝØæØÐÛØ×ÐæØï áâàÞÚ. */
  virtual void  insert_line (DbIndex line, DbIndex lines_cnt = 1,
                 Logic bInit = TRUE);

  /** ÃÔÐÛØâì Ø× âÐÑÛØæë ãÚÐ×ÐÝÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ [line1..line2] */
  virtual void  remove_lines (DbIndex line1, DbIndex line2);

  /** ¾ÑÜÕÝïâì ÜÕáâÐÜØ ÔÒÕ áâàÞÚØ âÐÑÛØæë */
  virtual void  exchange_lines (DbIndex line1, DbIndex line2);

  /** ´ÞÑÐÒØâì áâàÞÚØ ãÚÐ×ÐÝÝÞÙ âÐÑÛØæë Ò ÚÞÝÕæ íâÞÙ. */
  virtual void  merge (DbTable& src);

  /** ´ÞÑÐÒØâì ãÚÐ×ÐÝÝëÕ áâàÞÚØ âÐÑÛØæë Ò ãÚÐ×ÐÝÝÞÕ ÜÕáâÞ íâÞÙ.
      ·ÐßàÕéÕÝÞ ØáßÞÛì×ÞÒÐÝØÕ _last_ Ò ÚÐçÕáâÒÕ ØÝÔÕÚáÐ.  */
  virtual void  copy_lines (DbIndex iWhere, DbTable& src,
                DbIndex iFrom, DbIndex nLines);

  /** ²ëßÞÛÝÕÝØÕ ÞßÕàÐæØØ ßàØÒÕÔÕâ Ú âÞÜã, çâÞ âÐÑÛØæÐ ÑãÔÕâ áçØâÐâìáï
     Ø×ÜÕÝØÒèÕÙáï.  ÍâÞâ ÜÕâÞÔ Òë×ëÒÐÕâáï ÒÞ ÒáÕå ÜÞÔØäØæØàãîéØå
     ÞßÕàÐæØïå. */
  virtual void  modify ();

  /** ²ëßÞÛÝÕÝØÕ ÞßÕàÐæØØ ßàØÒÕÔÕâ Ú âÞÜã, çâÞ âÐÑÛØæÐ ÑãÔÕâ áçØâÐâìáï
     ÝÕ Ø×ÜÕÝØÒèÕÙáï ÝÕáÜÞâàï ÝÐ ßàÕÔëÔãéØÕ ÞßÕàÐæØØ á ÝÕÙ. */
  virtual void  not_modified ();

  /** ÃáâÐÝÞÒØâì ßàØ×ÝÐÚ ÜÞÔØäØæØàãÕÜÞáâØ âÐÑÛØæë.  µáÛØ ãáâÐÝÞÒØâì
     FALSE, âÞ ÛîÑÐï ÞßÕàÐæØï Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë ×ÐÒÕàèØâáï
     á ÞèØÑÚÞÙ.  ¿Þ ãÜÞÛçÐÝØî äÛÐÓ TRUE. */
  virtual void  set_modifiability (Logic bFlag);


  /*
   * ¾ßÕàÐæØØ äÐÙÛÞÒÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ.
   * ¸ÜÕîâáï ÔÒÐ áßÞáÞÑÐ ÒÒÞÔÐ/ÒëÒÞÔÐ:
   * 1) ßÞáÛÕÔÞÒÐâÕÛìÝëÙ (ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * 2) ßàÞØ×ÒÞÛìÝëÙ (ÝÕ ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * ÁßÞáÞÑ #1 ÒÚÛîçÐÕâ Ò áÕÑï ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ×ÐÓÞÛÞÒÚÐ,
   * ÐâàØÑãâÞÒ Ø áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   * ÁßÞáÞÑ #2 ÒÚÛîçÐÕâ Ò áÕÑï âÞÛìÚÞ ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ÔØÐßÐ×ÞÝÞÒ
   * áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   */

  /*
   * ¿ÞáÛÕÔÞÒÐâÕÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ¿àÞçØâÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
      ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ÁÚÞààÕÚâØàÞÒÐâì
      çØáÛÞ ÔÞÜÕÝÞÒ Ø àÐ×ÜÕà ×ÐßØáØ ÔÞ áÞÒßÐÔÐîéÕÓÞ á äÐÙÛÞÜ ±´.
      ²Þ×ÒàÐâØâì çØáÛÞ áâàÞÚ Ò âÐÑÛØæÕ, çØáÛÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÜÞÖÕâ
      ÞâÛØçÐâìáï Þâ ftm.dmns->count()!) Ø äÞàÜÐâ åàÐÝÕÝØï.  ¼ÞÖÕâ
      àÐÑÞâÐâì á ÚÐÝÐÛÞÜ.  */
  void      read_leader (int fd, ByteOrder& eBO, DbIndex& nLineCnt,
                 unsigned& nDmnsCnt);

  /** ¿àÞçØâÐâì áÞÑáâÒÕÝÝÞ áâàÞÚØ âÐÑÛØæë »±´ Ø× äÐÙÛÐ Ò ÚÞÛØçÕáâÒÕ
     nLineCnt èâãÚ á ßàØÒÕÔÕÝØÕÜ Ø× äÞàÜÐâÐ eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      append_table (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ¿àÞçØâÐâì Ò ßÐÜïâì áÞÔÕàÖØÜÞÕ ãÚÐ×ÐÝÝÞÓÞ äÐÙÛÐ (Ò ÚÞÝÕæ
     ØÜÕîéÕÓÞáï áÞÔÕàÖØÜÞÓÞ).  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      read (int fd);

  /** ·ÐßØáÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
     ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ² ×ÐÓÞÛÞÒÚÕ
     ×ÐßØáëÒÐÕâáï ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ âàÐáá, çâÞ ßÞ×ÒÞÛïÕâ ×ÐßØáëÒÐâì
     Ò äÐÙÛ ßàÞØ×ÒÞÛìÝÞÕ Øå çØáÛÞ.  ·ÐÔÐÕâáï âÐÚÖÕ äÞàÜÐâ åàÐÝÕÝØï Ò
     äÐÙÛÕ.  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      write_leader (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ·ÐßØáÐâì ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ áâàÞÚ ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ Ò äÐÙÛ
     âÐÑÛØæë »±´.  ´ÐÝÝëÕ ßàØÒÞÔïâáï Ú äÞàÜÐâã eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      record_table (int fd, ByteOrder eBO,
                  DbIndex iStartLine, DbIndex nLineCnt);

  /** ·ÐßØáÐâì Ò ãÚÐ×ÐÝÝëÙ äÐÙÛ áÞÔÕàÖØÜÞÕ âÐÑÛØæë.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      write (int fd);

  /*
   * ¿àÞØ×ÒÞÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ÃáâÐÝÞÒØâì àÐ×ÜÕà ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå ßàØ ßàÞØ×ÒÞÛìÝÞÜ
      ÔÞáâãßÕ Ú äÐÙÛã. */
  void      set_preread_size (size_t nSize);

  /** ¿ÞÛãçØâì ØÝäÞàÜÐæØî Þ àÐ×ÜÕàÕ ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå. */
  size_t    get_preread_size () const;


  /** ·ÐßØáÐâì Ò äÐÙÛ áÞÔÕàÖØÜÞÕ Ø×ÜÕÝØÒèØåáï áâàÞÚ. */
  void      write_changed ();

  /** ·ÐÓàã×Øâì Ò ßÐÜïâì ÒáÕ áâàÞÚØ äÐÙÛÐ âÐÑÛØæë. */
  void      load_all_lines ();


  /** Mutex to use in MT applications */
  MutexId*  mutex () const;

protected:/* methods */

  /*
   * ¾ßÕàÐæØØ ßÕàÕÞßàÕÔÕÛïÕÜÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ (no _last_ support).
   */

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  read_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  write_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  read_line_seq (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  write_line_seq (DbIndex line1, DbIndex line2);


  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¾ÔÝÐÖÔë ×ÐÓàãÖÕÝÝëÕ áâàÞçÚØ ÝÕ âàÞÓÐîâáï. _last_ support. */
  virtual void  load_lines (DbIndex line1, DbIndex line2);

  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¿ÞÜÕâØâì áâàÞçÚØ ÚÐÚ Ø×ÜÕÝØÒèØÕáï. _last_ support. */
  virtual void  change_lines (DbIndex line1, DbIndex line2);

  /*
   * ½ÐÒØÓÐæØÞÝÝëÕ ÞßÕàÐæØØ.
   */

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ.  ²Þ×ÜÞÖÝÞ, äÐÚâØçÕáÚÐï âÐÑÛØæÐ
      ±´ ÜÞÖÕâ Ø ÝÕ áÞÔÕàÖÐâì áâÞÛÑæÐ á âÐÚØÜ ØÝÔÕÚáÞÜ Ò áØÛã âÞÓÞ,
      çâÞ ÞÝÐ áÞ×ÔÐÝÐ ßÞ áâÐàÞÜã ÞßØáÐâÕÛî. */
  unsigned  n2i (const char* column) const;

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ Ø ßàÞÒÕàØâì ÕÓÞ ÝÐ áÞÞâÒÕâáâÒØÕ
      äÞàÜÐâã ÚÞÝÚàÕâÝÞÙ âÐÑÛØæë ±´ - ÚØÔÐÕâ ERROR__DB_DMN_NOT_FOUND */
  virtual unsigned  valid_n2i (const char* column) const;

  /** ¿ÞÛãçØâì ÐÔàÕá ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÐÜØ áâÞÛÑæÐ Ø áâàÞÚØ.
     ÁâàÞÚÐ ÜÞÖÕâ ÞÚÐ×Ðâìáï ÝÕ×ÐÓàãÖÕÝÝÞÙ Ò ßÐÜïâì! */
  void*     i2ptr (unsigned dmn_i, DbIndex line) const
    {
      DbIndex   line_i = (_last_ == line)? lines_count() - 1: line;
      return (char*)dtable.line_pointer(line_i)
    + fmt.dmns->fetch(dmn_i).offset;
    }

  /** ¿ÞÛãçØâì àÐ×ÜÕà ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÞÜ ÔÞÜÕÝÐ. */
  size_t    i2size (unsigned dmn_i) const
    {
      DbDomainDesc& dd = fmt.dmns->fetch(dmn_i);
      return dd.dim * AtomTypeToSize[dd.atype];
    }

protected:/* data */

  /** ÄÞàÜÐâ âÐÑÛØæë. */
  DbTTDesc  fmt;

  /** ±ãäÕà åàÐÝÕÝØï ÔÐÝÝëå âÐÑÛØæë. */
  DbBufStorage  dtable;

  /** ¼ÐááØÒ ÐâàØÑãâÞÒ áâÞÛÑæÞÒ. */
  DbFileDomainAttr  *dmn_attrs;

  /** ºÞÛØçÕáâÒÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÒÞ×ÜÞÖÝÞ, ÞâÛØçÐÕâáï Þâ
      fmt.dmns->count()) */
  unsigned  nFileDmnsCnt;

private:

  /** ¿àØ×ÝÐÚ Ø×ÜÕÝÕÝÕÝÝÞÓÞ áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë. */
  Logic     bModified;

  /** ¿àØ×ÝÐÚ ÒÞ×ÜÞÖÝÞáâØ Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë.  ½Õ ÒÛØïÕâ ÝÐ
     áâÐàÞÕ áÞáâÞïÝØÕ bModified, ÝÞ ×ÐßàÕéÐÕâ ÕÓÞ Ø×ÜÕÝÕÝØÕ. */
  Logic     bModifiable;

  /** ¿àØ×ÝÐÚØ Òë×ÞÒÐ ÝÕßÕàÕÚàëâëå ÜÕâÞÔÞÒ, ÔÛï âÞÓÞ, çâÞÑë ÝÕ
     ßÞÒâÞàïâì ÜÝÞÓÞÚàÐâÝÞ áÞÞÑéÕÝØÕ ÞÑ ÞèØÑÚÕ. */
  Logic     bLoadErrorSaid, bSaveErrorSaid;

#ifdef DB_RW_LOG_ENABLED
  /** ÁßØáÚØ àÕÐÛìÝÞ ßàÞçØâÐÝÝëå Ø ×ÐßØáÐÝÝëå áâàÞÚ Ò âÐÑÛØæÕ Ú ÜÞÜÕÝâã
     ÕÕ ×ÐÚàëâØï. */
  DbIndexAr rlines;     /**< ßàÞçØâÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */
  DbIndexAr wlines;     /**< ×ÐßØáÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */

#endif /* DB_RW_LOG_ENABLED */

#ifndef NO_HASH
  /** Hash to make n2i() faster: map string to index of domain in fmt */
  std::map<std::string,unsigned>    mHash;
#endif /* NO_HASH */

  /** Mutex id to provide MT safe access. */
  MutexId   *pMutexId;

  /** Size of preread buffer in bytes. */
  size_t    nPreReadSize;

};


inline const DbTTDesc&
DbTable::table_format () const
{
  return fmt;
}


#endif /* DbTable.H */

   */

  const DbTTDesc&   table_format () const;

  virtual DbIndex   lines_count () const;

  virtual DbIndex   lines_range (DbIndex line1, DbIndex line2,
                     DbIndex* line = NULL) const;

  virtual void  get_value (const char* column, DbIndex line,
               void* ptr);

  virtual void  get_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, void* ptr);

  virtual Logic check_empty_value (const char* column, DbIndex line);

  virtual UnitId    get_unit (const char* column) const;

  virtual const DmnDescAr&  get_domains ();

  virtual DbDomainDesc  get_domain (const char* column) const;

  virtual Compar    compare_lines (const char* column,
                       DbIndex line1, DbIndex line2);

  const char*   tt_name () const;

  Logic     is_modified () const;

  Logic     is_modifiable () const;


  /*
   * ¾ßÕàÐæØØ ÝÐÔ âÐÑÛØæÕÙ Ò ßÐÜïâØ.
   */

  virtual void  clean ();

  virtual void  set_value (const char* column, DbIndex line,
               const void* ptr);

  virtual void  set_values (const char* column, DbIndex start_line,
                DbIndex lines_cnt, const void* ptr);

  virtual void  set_empty_value (const char* column, DbIndex line);

  virtual void  set_unit (const char* column, UnitId unid);

  virtual void  insert_line (DbIndex line, DbIndex lines_cnt = 1,
                 Logic bInit = TRUE);

  virtual void  remove_lines (DbIndex line1, DbIndex line2);

  virtual void  exchange_lines (DbIndex line1, DbIndex line2);

  virtual void  merge (DbTable& src);

  virtual void  copy_lines (DbIndex iWhere, DbTable& src,
                DbIndex iFrom, DbIndex nLines);

  virtual void  modify ();

  virtual void  not_modified ();

  virtual void  set_modifiability (Logic bFlag);


  /*
   * ¾ßÕàÐæØØ äÐÙÛÞÒÞÓÞ ÒÒÞÔÐÒëÒÞÔÐ.
   * ¸ÜÕîâáï ÔÒÐ áßÞáÞÑÐ ÒÒÞÔÐ/ÒëÒÞÔÐ:
   * 1) ßÞáÛÕÔÞÒÐâÕÛìÝëÙ (ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * 2) ßàÞØ×ÒÞÛìÝëÙ (ÝÕ ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * ÁßÞáÞÑ #1 ÒÚÛîçÐÕâ Ò áÕÑï ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ×ÐÓÞÛÞÒÚÐ,
   * ÐâàØÑãâÞÒ Ø áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   * ÁßÞáÞÑ #2 ÒÚÛîçÐÕâ Ò áÕÑï âÞÛìÚÞ ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ÔØÐßÐ×ÞÝÞÒ
   * áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   */

  /*
   * ¿ÞáÛÕÔÞÒÐâÕÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ¿àÞçØâÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
      ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ÁÚÞààÕÚâØàÞÒÐâì
      çØáÛÞ ÔÞÜÕÝÞÒ Ø àÐ×ÜÕà ×ÐßØáØ ÔÞ áÞÒßÐÔÐîéÕÓÞ á äÐÙÛÞÜ ±´.
      ²Þ×ÒàÐâØâì çØáÛÞ áâàÞÚ Ò âÐÑÛØæÕ, çØáÛÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÜÞÖÕâ
      ÞâÛØçÐâìáï Þâ ftm.dmns->count()!) Ø äÞàÜÐâ åàÐÝÕÝØï.  ¼ÞÖÕâ
      àÐÑÞâÐâì á ÚÐÝÐÛÞÜ.  */
  void      read_leader (int fd, ByteOrder& eBO, DbIndex& nLineCnt,
                 unsigned& nDmnsCnt);

  /** ¿àÞçØâÐâì áÞÑáâÒÕÝÝÞ áâàÞÚØ âÐÑÛØæë »±´ Ø× äÐÙÛÐ Ò ÚÞÛØçÕáâÒÕ
     nLineCnt èâãÚ á ßàØÒÕÔÕÝØÕÜ Ø× äÞàÜÐâÐ eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      append_table (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ¿àÞçØâÐâì Ò ßÐÜïâì áÞÔÕàÖØÜÞÕ ãÚÐ×ÐÝÝÞÓÞ äÐÙÛÐ (Ò ÚÞÝÕæ
     ØÜÕîéÕÓÞáï áÞÔÕàÖØÜÞÓÞ).  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      read (int fd);

  /** ·ÐßØáÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
     ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ² ×ÐÓÞÛÞÒÚÕ
     ×ÐßØáëÒÐÕâáï ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ âàÐáá, çâÞ ßÞ×ÒÞÛïÕâ ×ÐßØáëÒÐâì
     Ò äÐÙÛ ßàÞØ×ÒÞÛìÝÞÕ Øå çØáÛÞ.  ·ÐÔÐÕâáï âÐÚÖÕ äÞàÜÐâ åàÐÝÕÝØï Ò
     äÐÙÛÕ.  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      write_leader (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ·ÐßØáÐâì ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ áâàÞÚ ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ Ò äÐÙÛ
     âÐÑÛØæë »±´.  ´ÐÝÝëÕ ßàØÒÞÔïâáï Ú äÞàÜÐâã eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      record_table (int fd, ByteOrder eBO,
                  DbIndex iStartLine, DbIndex nLineCnt);

  /** ·ÐßØáÐâì Ò ãÚÐ×ÐÝÝëÙ äÐÙÛ áÞÔÕàÖØÜÞÕ âÐÑÛØæë.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      write (int fd);

  /*
   * ¿àÞØ×ÒÞÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ÃáâÐÝÞÒØâì àÐ×ÜÕà ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå ßàØ ßàÞØ×ÒÞÛìÝÞÜ
      ÔÞáâãßÕ Ú äÐÙÛã. */
  void      set_preread_size (size_t nSize);

  /** ¿ÞÛãçØâì ØÝäÞàÜÐæØî Þ àÐ×ÜÕàÕ ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå. */
  size_t    get_preread_size () const;


  /** ·ÐßØáÐâì Ò äÐÙÛ áÞÔÕàÖØÜÞÕ Ø×ÜÕÝØÒèØåáï áâàÞÚ. */
  void      write_changed ();

  /** ·ÐÓàã×Øâì Ò ßÐÜïâì ÒáÕ áâàÞÚØ äÐÙÛÐ âÐÑÛØæë. */
  void      load_all_lines ();


  /** Mutex to use in MT applications */
  MutexId*  mutex () const;

protected:/* methods */

  /*
   * ¾ßÕàÐæØØ ßÕàÕÞßàÕÔÕÛïÕÜÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ (no _last_ support).
   */

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  read_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  write_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  read_line_seq (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  write_line_seq (DbIndex line1, DbIndex line2);


  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¾ÔÝÐÖÔë ×ÐÓàãÖÕÝÝëÕ áâàÞçÚØ ÝÕ âàÞÓÐîâáï. _last_ support. */
  virtual void  load_lines (DbIndex line1, DbIndex line2);

  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¿ÞÜÕâØâì áâàÞçÚØ ÚÐÚ Ø×ÜÕÝØÒèØÕáï. _last_ support. */
  virtual void  change_lines (DbIndex line1, DbIndex line2);

  /*
   * ½ÐÒØÓÐæØÞÝÝëÕ ÞßÕàÐæØØ.
   */

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ.  ²Þ×ÜÞÖÝÞ, äÐÚâØçÕáÚÐï âÐÑÛØæÐ
      ±´ ÜÞÖÕâ Ø ÝÕ áÞÔÕàÖÐâì áâÞÛÑæÐ á âÐÚØÜ ØÝÔÕÚáÞÜ Ò áØÛã âÞÓÞ,
      çâÞ ÞÝÐ áÞ×ÔÐÝÐ ßÞ áâÐàÞÜã ÞßØáÐâÕÛî. */
  unsigned  n2i (const char* column) const;

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ Ø ßàÞÒÕàØâì ÕÓÞ ÝÐ áÞÞâÒÕâáâÒØÕ
      äÞàÜÐâã ÚÞÝÚàÕâÝÞÙ âÐÑÛØæë ±´ - ÚØÔÐÕâ ERROR__DB_DMN_NOT_FOUND */
  virtual unsigned  valid_n2i (const char* column) const;

  /** ¿ÞÛãçØâì ÐÔàÕá ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÐÜØ áâÞÛÑæÐ Ø áâàÞÚØ.
     ÁâàÞÚÐ ÜÞÖÕâ ÞÚÐ×Ðâìáï ÝÕ×ÐÓàãÖÕÝÝÞÙ Ò ßÐÜïâì! */
  void*     i2ptr (unsigned dmn_i, DbIndex line) const
    {
      DbIndex   line_i = (_last_ == line)? lines_count() - 1: line;
      return (char*)dtable.line_pointer(line_i)
    + fmt.dmns->fetch(dmn_i).offset;
    }

  /** ¿ÞÛãçØâì àÐ×ÜÕà ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÞÜ ÔÞÜÕÝÐ. */
  size_t    i2size (unsigned dmn_i) const
    {
      DbDomainDesc& dd = fmt.dmns->fetch(dmn_i);
      return dd.dim * AtomTypeToSize[dd.atype];
    }

protected:/* data */

  /** ÄÞàÜÐâ âÐÑÛØæë. */
  DbTTDesc  fmt;

  /** ±ãäÕà åàÐÝÕÝØï ÔÐÝÝëå âÐÑÛØæë. */
  DbBufStorage  dtable;

  /** ¼ÐááØÒ ÐâàØÑãâÞÒ áâÞÛÑæÞÒ. */
  DbFileDomainAttr  *dmn_attrs;

  /** ºÞÛØçÕáâÒÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÒÞ×ÜÞÖÝÞ, ÞâÛØçÐÕâáï Þâ
      fmt.dmns->count()) */
  unsigned  nFileDmnsCnt;

private:

  /** ¿àØ×ÝÐÚ Ø×ÜÕÝÕÝÕÝÝÞÓÞ áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë. */
  Logic     bModified;

  /** ¿àØ×ÝÐÚ ÒÞ×ÜÞÖÝÞáâØ Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë.  ½Õ ÒÛØïÕâ ÝÐ
     áâÐàÞÕ áÞáâÞïÝØÕ bModified, ÝÞ ×ÐßàÕéÐÕâ ÕÓÞ Ø×ÜÕÝÕÝØÕ. */
  Logic     bModifiable;

  /** ¿àØ×ÝÐÚØ Òë×ÞÒÐ ÝÕßÕàÕÚàëâëå ÜÕâÞÔÞÒ, ÔÛï âÞÓÞ, çâÞÑë ÝÕ
     ßÞÒâÞàïâì ÜÝÞÓÞÚàÐâÝÞ áÞÞÑéÕÝØÕ ÞÑ ÞèØÑÚÕ. */
  Logic     bLoadErrorSaid, bSaveErrorSaid;

#ifdef DB_RW_LOG_ENABLED
  /** ÁßØáÚØ àÕÐÛìÝÞ ßàÞçØâÐÝÝëå Ø ×ÐßØáÐÝÝëå áâàÞÚ Ò âÐÑÛØæÕ Ú ÜÞÜÕÝâã
     ÕÕ ×ÐÚàëâØï. */
  DbIndexAr rlines;     /**< ßàÞçØâÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */
  DbIndexAr wlines;     /**< ×ÐßØáÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */

#endif /* DB_RW_LOG_ENABLED */

#ifndef NO_HASH
  /** Hash to make n2i() faster: map string to index of domain in fmt */
  std::map<std::string,unsigned>    mHash;
#endif /* NO_HASH */

  /** Mutex id to provide MT safe access. */
  MutexId   *pMutexId;

  /** Size of preread buffer in bytes. */
  size_t    nPreReadSize;

};


inline const DbTTDesc&
DbTable::table_format () const
{
  return fmt;
}


#endif /* DbTable.H */
/ÒëÒÞÔÐ.
   * ¸ÜÕîâáï ÔÒÐ áßÞáÞÑÐ ÒÒÞÔÐÒëÒÞÔÐ:
   * 1) ßÞáÛÕÔÞÒÐâÕÛìÝëÙ (ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * 2) ßàÞØ×ÒÞÛìÝëÙ (ÝÕ ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * ÁßÞáÞÑ #1 ÒÚÛîçÐÕâ Ò áÕÑï ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ×ÐÓÞÛÞÒÚÐ,
   * ÐâàØÑãâÞÒ Ø áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   * ÁßÞáÞÑ #2 ÒÚÛîçÐÕâ Ò áÕÑï âÞÛìÚÞ ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ÔØÐßÐ×ÞÝÞÒ
   * áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   */

  /*
   * ¿ÞáÛÕÔÞÒÐâÕÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ¿àÞçØâÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
      ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ÁÚÞààÕÚâØàÞÒÐâì
      çØáÛÞ ÔÞÜÕÝÞÒ Ø àÐ×ÜÕà ×ÐßØáØ ÔÞ áÞÒßÐÔÐîéÕÓÞ á äÐÙÛÞÜ ±´.
      ²Þ×ÒàÐâØâì çØáÛÞ áâàÞÚ Ò âÐÑÛØæÕ, çØáÛÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÜÞÖÕâ
      ÞâÛØçÐâìáï Þâ ftm.dmns->count()!) Ø äÞàÜÐâ åàÐÝÕÝØï.  ¼ÞÖÕâ
      àÐÑÞâÐâì á ÚÐÝÐÛÞÜ.  */
  void      read_leader (int fd, ByteOrder& eBO, DbIndex& nLineCnt,
                 unsigned& nDmnsCnt);

  /** ¿àÞçØâÐâì áÞÑáâÒÕÝÝÞ áâàÞÚØ âÐÑÛØæë »±´ Ø× äÐÙÛÐ Ò ÚÞÛØçÕáâÒÕ
     nLineCnt èâãÚ á ßàØÒÕÔÕÝØÕÜ Ø× äÞàÜÐâÐ eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      append_table (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ¿àÞçØâÐâì Ò ßÐÜïâì áÞÔÕàÖØÜÞÕ ãÚÐ×ÐÝÝÞÓÞ äÐÙÛÐ (Ò ÚÞÝÕæ
     ØÜÕîéÕÓÞáï áÞÔÕàÖØÜÞÓÞ).  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      read (int fd);

  /** ·ÐßØáÐâì ßàÕÐÜÑãÛã äÐÙÛÐ âÐÑÛØæë »±´ (×ÐÓÞÛÞÒÞÚ + ÐâàØÑãâë
     ÔÞÜÕÝÞÒ).  ´ØÐÓÝÞáâØàÞÒÐâì ÒÞ×ÜÞÖÝëÕ ßàÞÑÛÕÜë.  ² ×ÐÓÞÛÞÒÚÕ
     ×ÐßØáëÒÐÕâáï ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ âàÐáá, çâÞ ßÞ×ÒÞÛïÕâ ×ÐßØáëÒÐâì
     Ò äÐÙÛ ßàÞØ×ÒÞÛìÝÞÕ Øå çØáÛÞ.  ·ÐÔÐÕâáï âÐÚÖÕ äÞàÜÐâ åàÐÝÕÝØï Ò
     äÐÙÛÕ.  ¼ÞÖÕâ àÐÑÞâÐâì á ÚÐÝÐÛÞÜ. */
  void      write_leader (int fd, ByteOrder eBO, DbIndex nLineCnt);

  /** ·ÐßØáÐâì ãÚÐ×ÐÝÝÞÕ ÚÞÛØçÕáâÒÞ áâàÞÚ ÝÐçØÝÐï á ãÚÐ×ÐÝÝÞÙ Ò äÐÙÛ
     âÐÑÛØæë »±´.  ´ÐÝÝëÕ ßàØÒÞÔïâáï Ú äÞàÜÐâã eBO.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      record_table (int fd, ByteOrder eBO,
                  DbIndex iStartLine, DbIndex nLineCnt);

  /** ·ÐßØáÐâì Ò ãÚÐ×ÐÝÝëÙ äÐÙÛ áÞÔÕàÖØÜÞÕ âÐÑÛØæë.  ¼ÞÖÕâ àÐÑÞâÐâì á
     ÚÐÝÐÛÞÜ. */
  void      write (int fd);

  /*
   * ¿àÞØ×ÒÞÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  /** ÃáâÐÝÞÒØâì àÐ×ÜÕà ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå ßàØ ßàÞØ×ÒÞÛìÝÞÜ
      ÔÞáâãßÕ Ú äÐÙÛã. */
  void      set_preread_size (size_t nSize);

  /** ¿ÞÛãçØâì ØÝäÞàÜÐæØî Þ àÐ×ÜÕàÕ ÑãäÕàÐ ßàÕÔçâÕÝØï Ò ÑÐÙâÐå. */
  size_t    get_preread_size () const;


  /** ·ÐßØáÐâì Ò äÐÙÛ áÞÔÕàÖØÜÞÕ Ø×ÜÕÝØÒèØåáï áâàÞÚ. */
  void      write_changed ();

  /** ·ÐÓàã×Øâì Ò ßÐÜïâì ÒáÕ áâàÞÚØ äÐÙÛÐ âÐÑÛØæë. */
  void      load_all_lines ();


  /** Mutex to use in MT applications */
  MutexId*  mutex () const;

protected:/* methods */

  /*
   * ¾ßÕàÐæØØ ßÕàÕÞßàÕÔÕÛïÕÜÞÓÞ ÒÒÞÔÐ/ÒëÒÞÔÐ (no _last_ support).
   */

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  read_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  write_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  read_line_seq (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  write_line_seq (DbIndex line1, DbIndex line2);


  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¾ÔÝÐÖÔë ×ÐÓàãÖÕÝÝëÕ áâàÞçÚØ ÝÕ âàÞÓÐîâáï. _last_ support. */
  virtual void  load_lines (DbIndex line1, DbIndex line2);

  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¿ÞÜÕâØâì áâàÞçÚØ ÚÐÚ Ø×ÜÕÝØÒèØÕáï. _last_ support. */
  virtual void  change_lines (DbIndex line1, DbIndex line2);

  /*
   * ½ÐÒØÓÐæØÞÝÝëÕ ÞßÕàÐæØØ.
   */

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ.  ²Þ×ÜÞÖÝÞ, äÐÚâØçÕáÚÐï âÐÑÛØæÐ
      ±´ ÜÞÖÕâ Ø ÝÕ áÞÔÕàÖÐâì áâÞÛÑæÐ á âÐÚØÜ ØÝÔÕÚáÞÜ Ò áØÛã âÞÓÞ,
      çâÞ ÞÝÐ áÞ×ÔÐÝÐ ßÞ áâÐàÞÜã ÞßØáÐâÕÛî. */
  unsigned  n2i (const char* column) const;

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ Ø ßàÞÒÕàØâì ÕÓÞ ÝÐ áÞÞâÒÕâáâÒØÕ
      äÞàÜÐâã ÚÞÝÚàÕâÝÞÙ âÐÑÛØæë ±´ - ÚØÔÐÕâ ERROR__DB_DMN_NOT_FOUND */
  virtual unsigned  valid_n2i (const char* column) const;

  /** ¿ÞÛãçØâì ÐÔàÕá ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÐÜØ áâÞÛÑæÐ Ø áâàÞÚØ.
     ÁâàÞÚÐ ÜÞÖÕâ ÞÚÐ×Ðâìáï ÝÕ×ÐÓàãÖÕÝÝÞÙ Ò ßÐÜïâì! */
  void*     i2ptr (unsigned dmn_i, DbIndex line) const
    {
      DbIndex   line_i = (_last_ == line)? lines_count() - 1: line;
      return (char*)dtable.line_pointer(line_i)
    + fmt.dmns->fetch(dmn_i).offset;
    }

  /** ¿ÞÛãçØâì àÐ×ÜÕà ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÞÜ ÔÞÜÕÝÐ. */
  size_t    i2size (unsigned dmn_i) const
    {
      DbDomainDesc& dd = fmt.dmns->fetch(dmn_i);
      return dd.dim * AtomTypeToSize[dd.atype];
    }

protected:/* data */

  /** ÄÞàÜÐâ âÐÑÛØæë. */
  DbTTDesc  fmt;

  /** ±ãäÕà åàÐÝÕÝØï ÔÐÝÝëå âÐÑÛØæë. */
  DbBufStorage  dtable;

  /** ¼ÐááØÒ ÐâàØÑãâÞÒ áâÞÛÑæÞÒ. */
  DbFileDomainAttr  *dmn_attrs;

  /** ºÞÛØçÕáâÒÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÒÞ×ÜÞÖÝÞ, ÞâÛØçÐÕâáï Þâ
      fmt.dmns->count()) */
  unsigned  nFileDmnsCnt;

private:

  /** ¿àØ×ÝÐÚ Ø×ÜÕÝÕÝÕÝÝÞÓÞ áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë. */
  Logic     bModified;

  /** ¿àØ×ÝÐÚ ÒÞ×ÜÞÖÝÞáâØ Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë.  ½Õ ÒÛØïÕâ ÝÐ
     áâÐàÞÕ áÞáâÞïÝØÕ bModified, ÝÞ ×ÐßàÕéÐÕâ ÕÓÞ Ø×ÜÕÝÕÝØÕ. */
  Logic     bModifiable;

  /** ¿àØ×ÝÐÚØ Òë×ÞÒÐ ÝÕßÕàÕÚàëâëå ÜÕâÞÔÞÒ, ÔÛï âÞÓÞ, çâÞÑë ÝÕ
     ßÞÒâÞàïâì ÜÝÞÓÞÚàÐâÝÞ áÞÞÑéÕÝØÕ ÞÑ ÞèØÑÚÕ. */
  Logic     bLoadErrorSaid, bSaveErrorSaid;

#ifdef DB_RW_LOG_ENABLED
  /** ÁßØáÚØ àÕÐÛìÝÞ ßàÞçØâÐÝÝëå Ø ×ÐßØáÐÝÝëå áâàÞÚ Ò âÐÑÛØæÕ Ú ÜÞÜÕÝâã
     ÕÕ ×ÐÚàëâØï. */
  DbIndexAr rlines;     /**< ßàÞçØâÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */
  DbIndexAr wlines;     /**< ×ÐßØáÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */

#endif /* DB_RW_LOG_ENABLED */

#ifndef NO_HASH
  /** Hash to make n2i() faster: map string to index of domain in fmt */
  std::map<std::string,unsigned>    mHash;
#endif /* NO_HASH */

  /** Mutex id to provide MT safe access. */
  MutexId   *pMutexId;

  /** Size of preread buffer in bytes. */
  size_t    nPreReadSize;

};


inline const DbTTDesc&
DbTable::table_format () const
{
  return fmt;
}


#endif /* DbTable.H */
/ÒëÒÞÔÐ:
   * 1) ßÞáÛÕÔÞÒÐâÕÛìÝëÙ (ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * 2) ßàÞØ×ÒÞÛìÝëÙ (ÝÕ ÜÞÖÕâ àÐÑÞâÐâì çÕàÕ× ÚÐÝÐÛ (pipe, socket))
   * ÁßÞáÞÑ #1 ÒÚÛîçÐÕâ Ò áÕÑï ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ×ÐÓÞÛÞÒÚÐ,
   * ÐâàØÑãâÞÒ Ø áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   * ÁßÞáÞÑ #2 ÒÚÛîçÐÕâ Ò áÕÑï âÞÛìÚÞ ÞßÕàÐæØØ çâÕÝØï Ø ×ÐßØáØ ÔØÐßÐ×ÞÝÞÒ
   * áâàÞÚ ÔÐÝÝëå âÐÑÛØæë.
   */

  /*
   * ¿ÞáÛÕÔÞÒÐâÕÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  void      read_leader (int fd, ByteOrder& eBO, DbIndex& nLineCnt,
                 unsigned& nDmnsCnt);

  void      append_table (int fd, ByteOrder eBO, DbIndex nLineCnt);

  void      read (int fd);

  void      write_leader (int fd, ByteOrder eBO, DbIndex nLineCnt);

  void      record_table (int fd, ByteOrder eBO,
                  DbIndex iStartLine, DbIndex nLineCnt);

  void      write (int fd);

  /*
   * ¿àÞØ×ÒÞÛìÝëÙ ÔÞáâãß Ú äÐÙÛã.
   */

  void      set_preread_size (size_t nSize);

  size_t    get_preread_size () const;


  void      write_changed ();

  void      load_all_lines ();


  MutexId*  mutex () const;

protected:/* methods */

  /*
   * ¾ßÕàÐæØØ ßÕàÕÞßàÕÔÕÛïÕÜÞÓÞ ÒÒÞÔÐÒëÒÞÔÐ (no _last_ support).
   */

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  read_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ¼ÞÖÝÞ ×ÐÔÐÒÐâì ßàÞØ×ÒÞÛìÝëÙ ÔØÐßÐ×ÞÝ áâàÞÚ. */
  virtual void  write_lines (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ ßàÞçØâÐâì Ø× äÐÙÛÐ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  read_line_seq (DbIndex line1, DbIndex line2);

  /** ±Õ×ãáÛÞÒÝÞ áÞåàÐÝØâì Ò äÐÙÛ ÝÐ ÔØáÚÕ ãÚÐ×ÐÝÝëÕ áâàÞÚØ
     [line1..line2].  ³ÐàÐÝâØàãÕâáï, çâÞ Ò ßÐÜïâØ áâàÞÚØ ØÔãâ
     ßÞáÛÕÔÞÒÐâÕÛìÝÞ. */
  virtual void  write_line_seq (DbIndex line1, DbIndex line2);


  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¾ÔÝÐÖÔë ×ÐÓàãÖÕÝÝëÕ áâàÞçÚØ ÝÕ âàÞÓÐîâáï. _last_ support. */
  virtual void  load_lines (DbIndex line1, DbIndex line2);

  /** ·ÐÓàã×Øâì áâàÞÚØ [line1..line2] Ø× äÐÙÛÐ, ÒëÔÕÛØÒ ÔÛï ÝØå ÜÕáâÞ.
     ¿ÞÜÕâØâì áâàÞçÚØ ÚÐÚ Ø×ÜÕÝØÒèØÕáï. _last_ support. */
  virtual void  change_lines (DbIndex line1, DbIndex line2);

  /*
   * ½ÐÒØÓÐæØÞÝÝëÕ ÞßÕàÐæØØ.
   */

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ.  ²Þ×ÜÞÖÝÞ, äÐÚâØçÕáÚÐï âÐÑÛØæÐ
      ±´ ÜÞÖÕâ Ø ÝÕ áÞÔÕàÖÐâì áâÞÛÑæÐ á âÐÚØÜ ØÝÔÕÚáÞÜ Ò áØÛã âÞÓÞ,
      çâÞ ÞÝÐ áÞ×ÔÐÝÐ ßÞ áâÐàÞÜã ÞßØáÐâÕÛî. */
  unsigned  n2i (const char* column) const;

  /** ¿ÞÛãçØâì ØÝÔÕÚá ÔÞÜÕÝÐ ßÞ ØÜÕÝØ Ø ßàÞÒÕàØâì ÕÓÞ ÝÐ áÞÞâÒÕâáâÒØÕ
      äÞàÜÐâã ÚÞÝÚàÕâÝÞÙ âÐÑÛØæë ±´ - ÚØÔÐÕâ ERROR__DB_DMN_NOT_FOUND */
  virtual unsigned  valid_n2i (const char* column) const;

  /** ¿ÞÛãçØâì ÐÔàÕá ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÐÜØ áâÞÛÑæÐ Ø áâàÞÚØ.
     ÁâàÞÚÐ ÜÞÖÕâ ÞÚÐ×Ðâìáï ÝÕ×ÐÓàãÖÕÝÝÞÙ Ò ßÐÜïâì! */
  void*     i2ptr (unsigned dmn_i, DbIndex line) const
    {
      DbIndex   line_i = (_last_ == line)? lines_count() - 1: line;
      return (char*)dtable.line_pointer(line_i)
    + fmt.dmns->fetch(dmn_i).offset;
    }

  /** ¿ÞÛãçØâì àÐ×ÜÕà ïçÕÙÚØ, ãÚÐ×ÐÝÝÞÙ ØÝÔÕÚáÞÜ ÔÞÜÕÝÐ. */
  size_t    i2size (unsigned dmn_i) const
    {
      DbDomainDesc& dd = fmt.dmns->fetch(dmn_i);
      return dd.dim * AtomTypeToSize[dd.atype];
    }

protected:/* data */

  /** ÄÞàÜÐâ âÐÑÛØæë. */
  DbTTDesc  fmt;

  /** ±ãäÕà åàÐÝÕÝØï ÔÐÝÝëå âÐÑÛØæë. */
  DbBufStorage  dtable;

  /** ¼ÐááØÒ ÐâàØÑãâÞÒ áâÞÛÑæÞÒ. */
  DbFileDomainAttr  *dmn_attrs;

  /** ºÞÛØçÕáâÒÞ ÔÞÜÕÝÞÒ Ò äÐÙÛÕ (ÒÞ×ÜÞÖÝÞ, ÞâÛØçÐÕâáï Þâ
      fmt.dmns->count()) */
  unsigned  nFileDmnsCnt;

private:

  /** ¿àØ×ÝÐÚ Ø×ÜÕÝÕÝÕÝÝÞÓÞ áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë. */
  Logic     bModified;

  /** ¿àØ×ÝÐÚ ÒÞ×ÜÞÖÝÞáâØ Ø×ÜÕÝÕÝØï áÞÔÕàÖØÜÞÓÞ âÐÑÛØæë.  ½Õ ÒÛØïÕâ ÝÐ
     áâÐàÞÕ áÞáâÞïÝØÕ bModified, ÝÞ ×ÐßàÕéÐÕâ ÕÓÞ Ø×ÜÕÝÕÝØÕ. */
  Logic     bModifiable;

  /** ¿àØ×ÝÐÚØ Òë×ÞÒÐ ÝÕßÕàÕÚàëâëå ÜÕâÞÔÞÒ, ÔÛï âÞÓÞ, çâÞÑë ÝÕ
     ßÞÒâÞàïâì ÜÝÞÓÞÚàÐâÝÞ áÞÞÑéÕÝØÕ ÞÑ ÞèØÑÚÕ. */
  Logic     bLoadErrorSaid, bSaveErrorSaid;

#ifdef DB_RW_LOG_ENABLED
  /** ÁßØáÚØ àÕÐÛìÝÞ ßàÞçØâÐÝÝëå Ø ×ÐßØáÐÝÝëå áâàÞÚ Ò âÐÑÛØæÕ Ú ÜÞÜÕÝâã
     ÕÕ ×ÐÚàëâØï. */
  DbIndexAr rlines;     /**< ßàÞçØâÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */
  DbIndexAr wlines;     /**< ×ÐßØáÐÝÝëÕ ßÐàë áâàÞÚ line1..line2 */

#endif /* DB_RW_LOG_ENABLED */

#ifndef NO_HASH
  /** Hash to make n2i() faster: map string to index of domain in fmt */
  std::map<std::string,unsigned>    mHash;
#endif /* NO_HASH */

  /** Mutex id to provide MT safe access. */
  MutexId   *pMutexId;

  /** Size of preread buffer in bytes. */
  size_t    nPreReadSize;

};


inline const DbTTDesc&
DbTable::table_format () const
{
  return fmt;
}


#endif /* DbTable.H */
/ÒëÒÞÔÐ (no _last_ support).
   */

  virtual void  read_lines (DbIndex line1, DbIndex line2);

  virtual void  write_lines (DbIndex line1, DbIndex line2);

  virtual void  read_line_seq (DbIndex line1, DbIndex line2);

  virtual void  write_line_seq (DbIndex line1, DbIndex line2);


  virtual void  load_lines (DbIndex line1, DbIndex line2);

  virtual void  change_lines (DbIndex line1, DbIndex line2);

  /*
   * ½ÐÒØÓÐæØÞÝÝëÕ ÞßÕàÐæØØ.
   */

  unsigned  n2i (const char* column) const;

  virtual unsigned  valid_n2i (const char* column) const;

  void*     i2ptr (unsigned dmn_i, DbIndex line) const
    {
      DbIndex   line_i = (_last_ == line)? lines_count() - 1: line;
      return (char*)dtable.line_pointer(line_i)
    + fmt.dmns->fetch(dmn_i).offset;
    }

  size_t    i2size (unsigned dmn_i) const
    {
      DbDomainDesc& dd = fmt.dmns->fetch(dmn_i);
      return dd.dim * AtomTypeToSize[dd.atype];
    }

protected:/* data */

  DbTTDesc  fmt;

  DbBufStorage  dtable;

  DbFileDomainAttr  *dmn_attrs;

  unsigned  nFileDmnsCnt;

private:

  Logic     bModified;

  Logic     bModifiable;

  Logic     bLoadErrorSaid, bSaveErrorSaid;

#ifdef DB_RW_LOG_ENABLED

  DbIndexAr rlines;     
  DbIndexAr wlines;     
#endif /* DB_RW_LOG_ENABLED */

#ifndef NO_HASH

  std::map<std::string,unsigned>    mHash;
#endif /* NO_HASH */

  MutexId   *pMutexId;

  size_t    nPreReadSize;

};


inline const DbTTDesc&
DbTable::table_format () const
{
  return fmt;
}


#endif /* DbTable.H */