campo-sirio/include/files.cpp

#include <stdio.h>
#include <memory.h>
#include <string.h>
#include <strings.h>
#include <stdlib.h>

#include <files.h>
#include <expr.h>
#ifndef __EXTCDECL_H
#include <extcdecl.h>
#endif
#include <utility.h>

#define BLOCKLEN 512
#define INVFLD    255

HIDDEN char _files_tmp_string[128];

TFile ::TFile (int lenrec, int base)

{
  _file = new SecDef;
  if (_file == NULL)
    fatal_box ("Can't allocate record file ");
  _file->IOR = NOERR;
  _len = lenrec;
  _base = base;
  _file->LockMode = _manulock;
  _file->lpos = -1;
  _file->name[0] = '\0';
}

TFile ::~TFile ()

{
  delete _file;
}

void TFile ::
open (const char *name, TFilelock lockmode)

{
  COpen (_file, (char *) name, _len, _base, lockmode);
}

bool TFile ::
verify (const char *name)

{
  CVerify (_file, (char *) name);
  return _file->IOR == NOERR;
}

void TFile ::
create (const char *name, TRecnotype nrecord)

{
  CCreate (_file, (char *) name, _len, _base, (nrecord * _len) / BLOCKLEN + 1);
}

void TFile ::
chsize (const char *name, TRecnotype nrecord)

{
  CChsize (_file, (char *) name, _len, _base, (nrecord * _len) / BLOCKLEN + 1);
}

void TFile ::
close ()

{
  CClose (_file);
}

void TFile ::
unlink (const char *name)

{
  CDelete (_file, (char *) name);
}

void TFile ::
read (char *record, TRecnotype recnum, TReclock lock)

{
  _file->LenRec = _len;
  _file->BaseFil = _base;
  CRead (_file, record, recnum, lock);
}

void TFile ::
write (char *record, TRecnotype recnum, TReclock lock)

{
  _file->LenRec = _len;
  _file->BaseFil = _base;
  CWrite (_file, record, recnum, lock);
}

int TFile ::
status ()
     const

     {
       return _file->IOR;
     }

TDir ::
TDir ()

{
  _dir = new FileDes;
  if (_dir == NULL)
    fatal_box ("Can't allocate dir");
  zero ();
  _num = -1;
}

TDir ::~TDir ()

{
  delete _dir;
}

const char *TDir ::
name ()
     const

     {
       return _dir->SysName;
     }

     const char *TDir ::des ()
     const

     {
       return _dir->Des;
     }

     const char *TDir ::expr ()
     const

     {
       return _dir->FCalc;
     }

TRecnotype & TDir ::
eod ()
     const

     {
       return _dir->EOD;
     }

TRecnotype & TDir ::
eox ()
     const

     {
       return _dir->EOX;
     }

TRecnotype & TDir ::
flags ()
     const

     {
       return _dir->Flags;
     }

word & TDir ::
len ()

{
  return (word &) _dir->LenR;
}

int TDir ::
status (TDirtype dirop)
     const

     {
       return fdir[dirop].IOR;
     }

     void TDir ::set_len (const UINT16 len)
{
  _dir->LenR = len;
}

void TDir ::
set_eox (const RecNoType eox)
{
  _dir->EOX = eox;
}

void TDir ::
set (const char *name, const RecNoType eod, const RecNoType flag, const char *des, const char *calc)
{
  strncpy (_dir->SysName, name, sizeof (_dir->SysName));
  _dir->EOD = eod;
  _dir->Flags = flag;
  strncpy (_dir->Des, des, sizeof (_dir->Des));
  strncpy (_dir->FCalc, calc, sizeof (_dir->FCalc));
}

void TDir ::
get (int nfile, TReclock lock, TDirtype dirtype, TDirop op)

{
  int _whichdir = (dirtype == _nordir ? NORDIR : COMDIR);

  if (op == _nordirop)
    COpenFile (nfile, _dir, int (lock), _whichdir);
  else
    CGetFile (nfile, _dir, int (lock), _whichdir);
  _num = nfile;
}

void TDir ::
put (int nfile, TDirtype dirtype, TDirop op)

{
  int _whichdir = (dirtype == _nordir ? NORDIR : COMDIR);

  if (nfile <= 0)
    fatal_box ("Bad file number %d", nfile);
  if (op == _nordirop)
    CCloseFile (nfile, _dir, _whichdir);
  else
    CPutFile (nfile, _dir, _whichdir);
}

void TDir ::
zero ()

{
  zerofdes (_dir);
}

int TDir ::
items (TDirtype dirtype)
     const

     {
       FileDes f;
       int _whichdir = (dirtype == _nordir ? NORDIR : COMDIR);

         CGetFile (1, &f, _nolock, _whichdir);
         return (int) f.EOD;
     }

TTrec ::
TTrec ()

{
  _rec = new RecDes;
  if (_rec == NULL)
    fatal_box ("Can't allocate record description");
  zero ();
  _num = -1;
}

TTrec ::~TTrec ()

{
  delete _rec;
}

int TTrec ::
compare (const TSortable & a)
     const

     {
       const TTrec & r = (const TTrec &) a;
       const int res = memcmp ((const void *) _rec, (const void *) r._rec, sizeof (*_rec));
         return res;
     }

     void TTrec ::rehash ()

{
  setrdes (_rec);
}

TTrec & TTrec ::operator = (const TTrec & b)

{
  _num = b._num;
  memcpy (_rec, b._rec, sizeof (*_rec));
  return *this;
}

void TTrec ::
get (int nfile, TDirtype dirtype)

{
  int _whichdir = (dirtype == _nordir ? NORDIR : COMDIR);

  CGetRec (nfile, _rec, _whichdir);
  _num = nfile;
}

void TTrec ::
put (int nfile, TDirtype dirtype)

{
  int _whichdir = (dirtype == _nordir ? NORDIR : COMDIR);

  if (nfile <= 0)
    fatal_box ("Bad file number %d", nfile);
  CPutRec (nfile, _rec, _whichdir);
}

void TTrec ::
zero ()

{
  zerordes (_rec);
}

int TTrec ::
status (TDirtype dirop)
     const

     {
       return rdir[dirop].IOR;
     }

     int TTrec ::field (const char *name)
     const

     {
       return findfld (_rec, (char *) name);

     }

     const char *TTrec ::fielddef (int fld)
     const

     {
       sprintf (_files_tmp_string, "%s|%d|%d|%d", _rec->Fd[fld].Name,
		(int) _rec->Fd[fld].TypeF, (int) _rec->Fd[fld].Len,
		(int) _rec->Fd[fld].Dec);
       return _files_tmp_string;
     }

     const char *TTrec ::keydef (int key)
     const

     {
       TFixed_string s (_files_tmp_string, 128);

         s = "";
       for (int j = 0; j < _rec->Ky[key].NkFields; j++)
	 {
	   const bool upper = _rec->Ky[key].FieldSeq[j] > MaxFields;
	   const int nfld = _rec->Ky[key].FieldSeq[j] - (upper ? MaxFields : 0);

	   if (j)
	       s << "+";
	   if (upper)
	       s << "UPPER(";
	     s << _rec->Fd[nfld].Name;
	   if (_rec->Ky[key].FromCh[j] < INVFLD)
	       s << format ("[%d,%d]", _rec->Ky[key].FromCh[j] + 1,
			    _rec->Ky[key].ToCh[j] + 1);
	   if (upper)
	       s << ")";
	 }
       s << (_rec->Ky[key].DupKeys ? "|X" : "| ");
       return (const char *) s;
     }

void TTrec ::
update_fielddef (int nfld, const char *desc)

{
  TToken_string s (desc);
  strcpy (_rec->Fd[nfld].Name, s.get ());
  _rec->Fd[nfld].TypeF = s.get_int ();
  _rec->Fd[nfld].Len = s.get_int ();
  _rec->Fd[nfld].Dec = s.get_int ();
}

void TTrec ::
update_keydef (int key, const char *desc)

{
  TExpression expr ("", _strexpr);
  TToken_string s (desc);
  TString ke (s.get ());

  if (expr.set ((const char *) ke, _strexpr))
    {
      _rec->Ky[key].DupKeys = (*s.get () != ' ');
      TCodearray & c = expr.code ();
      c.begin ();
      int n = 0;
      while (!c.end ())
	{
	  TCode & inst = c.step ();
	  TCodesym sym = inst.getsym ();

	  if (sym == _variable)
	    {
	      const char *s = inst.string ();

	      for (int i = 0; i < _rec->NFields; i++)
		if (strcmp (_rec->Fd[i].Name, s) == 0)
		  break;

	      _rec->Ky[key].FieldSeq[n] = i;
	      _rec->Ky[key].FromCh[n] = INVFLD;
	      _rec->Ky[key].FromCh[n] = INVFLD;
	      inst = c.step ();
	      sym = inst.getsym ();
	      if (sym == _upper)
		_rec->Ky[key].FieldSeq[n] += MaxFields;
	      else if (sym == _number)
		{
		  _rec->Ky[key].FromCh[n] = inst.number ().integer () - 1;
		  inst = c.step ();
		  _rec->Ky[key].ToCh[n] = _rec->Ky[key].FromCh[n] + inst.number ().integer () - 1;
		  inst = c.step ();
		}
	      else
		c.backtrace ();
	      n++;
	    }
	}
      _rec->Ky[key].NkFields = n;
    }
}

void TTrec ::
print_on (ostream & out)
     const

     {
       out << num () << '\n';
       const int nfields = fields ();
       TToken_string s (80);

         out << nfields << '\n';
       for (int i = 0; i < nfields; i++)
	 {
	   s = fielddef (i);
	   out << s << '\n';
	 }
       const int nkeys = keys ();

       out << nkeys << '\n';
       for (i = 0; i < nkeys; i++)
	 {
	   s = keydef (i);
	   out << s << '\n';
	 }
     }

void TTrec ::
read_from (istream & in)

{
  int ln;

  in.getline (_files_tmp_string, sizeof (_files_tmp_string), '\n');
  ln = atoi (_files_tmp_string);
  if (ln != num () && !yesno_box ("Descrizione relativa al file n.ro %d.\n Continuo ?", ln))
    return;
  int nfields;

  in.getline (_files_tmp_string, sizeof (_files_tmp_string), '\n');
  nfields = atoi (_files_tmp_string);
  set_fields (nfields);
  for (int i = 0; i < nfields; i++)
    {
      in.getline (_files_tmp_string, sizeof (_files_tmp_string), '\n');
      update_fielddef (i, _files_tmp_string);
    }
  int nkeys;

  in.getline (_files_tmp_string, sizeof (_files_tmp_string), '\n');
  nkeys = atoi (_files_tmp_string);
  set_keys (nkeys);
  for (i = 0; i < nkeys; i++)
    {
      in.getline (_files_tmp_string, sizeof (_files_tmp_string), '\n');
      update_keydef (i, _files_tmp_string);
    }
  rehash ();
}