path: root/storage/connect/table.cpp

/************** Table C++ Functions Source Code File (.CPP) ************/
/*  Name: TABLE.CPP  Version 2.5                                       */
/*                                                                     */
/*  (C) Copyright to the author Olivier BERTRAND          1999-2012    */
/*                                                                     */
/*  This file contains the TBX, TDB and OPJOIN classes functions.      */
/***********************************************************************/

/***********************************************************************/
/*  Include relevant MariaDB header file.                  */
/***********************************************************************/
#include "my_global.h"

/***********************************************************************/
/*  Include required application header files                          */
/*  global.h    is header containing all global Plug declarations.     */
/*  plgdbsem.h  is header containing the DB applic. declarations.      */
/*  xobject.h   is header containing XOBJECT derived classes declares. */
/***********************************************************************/
#include "global.h"
#include "plgdbsem.h"
#include "xtable.h"
#include "tabcol.h"
#include "filamtxt.h"
#include "tabdos.h"
//#include "catalog.h"
#include "reldef.h"

int TDB::Tnum = 0;

extern "C" int trace;			 // The general trace value

/***********************************************************************/
/*  Utility routines.                                                  */
/***********************************************************************/
void NewPointer(PTABS, void *, void *);
void AddPointer(PTABS, void *);

/* ---------------------------- class TBX ---------------------------- */

/***********************************************************************/
/*  TBX public constructors.                                           */
/***********************************************************************/
TBX::TBX(void)
  {
  Use = USE_NO;
  To_Orig = NULL;
  To_Filter = NULL;
  } // end of TBX constructor

TBX::TBX(PTBX txp)
  {
  Use = txp->Use;
  To_Orig = txp;
  To_Filter = NULL;
  } // end of TBX copy constructor

// Methods

/* ---------------------------- class TDB ---------------------------- */

/***********************************************************************/
/*  TDB public constructors.                                           */
/***********************************************************************/
TDB::TDB(PTABDEF tdp) : Tdb_No(++Tnum)
  {
  Next = NULL;
  Name = (tdp) ? tdp->GetName() : NULL;
	To_Table = NULL;
  Columns = NULL;
  Degree = (tdp) ? tdp->GetDegree() : 0;
  Mode = MODE_READ;
  } // end of TDB standard constructor

TDB::TDB(PTDB tdbp) : TBX(tdbp), Tdb_No(++Tnum)
  {
  Next = NULL;
  Name = tdbp->Name;
	To_Table = tdbp->To_Table;
  Columns = NULL;
  Degree = tdbp->Degree;
  Mode = tdbp->Mode;
  } // end of TDB copy constructor

/***********************************************************************/
/*  OpenTable: Call AM open routine.                                   */
/***********************************************************************/
bool TDB::OpenTable(PGLOBAL g, PSQL sqlp, MODE mode)
  {
  if (trace)
		htrc("Open Tdb_No=%d use=%d type=%d tdb.Mode=%d mode=%d\n",
						   Tdb_No, Use, GetAmType(), Mode, mode);

  switch (Use) {
    case USE_LIN:
      /*****************************************************************/
      /*  If table is read/only, only MODE_READ is allowed.            */
      /*****************************************************************/
			if (IsReadOnly() && mode != MODE_READ) {
				strcpy(g->Message, MSG(READ_ONLY));
				return true;
				} // endif ReadOnly

      /*****************************************************************/
      /*  This could be done in any order.                             */
      /*  Note: for not Read only first table in open in that mode.    */
      /*****************************************************************/
      if (Next)
        Next->OpenTable(g, sqlp, MODE_READ);

      Mode = mode;

      /*****************************************************************/
      /*  Pre-opening is done, allocate select buffers now.            */
      /*****************************************************************/
      Use = USE_READY;
      break;

    case USE_READY:
      /*****************************************************************/
      /*  This is to open files in reverse order.                      */
      /*****************************************************************/
      if (Next)
        if (Next->OpenTable(g, sqlp, mode))
					return true;

      /*****************************************************************/
      /*  This was moved after filter conversion so filtering can be   */
      /*  done when making index tables for DOS files.                 */
      /*  Also it was moved after allocating select buffers so some    */
      /*  data can be pre-read during open to allow storage sorting.   */
      /*****************************************************************/
      if (OpenDB(g))                       // Do open the table file
				return true;

      Use = USE_OPEN;
      break;

    case USE_OPEN:
      /*****************************************************************/
      /*  Table is already open.                                       */
      /*  Call open routine that will just "rewind" the files.         */
      /*****************************************************************/
      if (OpenDB(g))                       // Rewind the table file
				return true;

      break;

    default:
      sprintf(g->Message, MSG(TDB_USE_ERROR), Use);
      return true;
    } // endswitch Use

	return false;
  } // end of OpenTable

/***********************************************************************/
/*  CloseTable: Close a table of any AM type.                          */
/***********************************************************************/
void TDB::CloseTable(PGLOBAL g)
  {
  if (trace)
		htrc("CloseTable: tdb_no %d use=%d amtype=%d am.Mode=%d\n",
										  Tdb_No, Use, GetAmType(), Mode);

  CloseDB(g);
  Use = USE_READY;              // x'7FFD'
  Mode = MODE_ANY;
  } // end of CloseTable

// Methods

/***********************************************************************/
/*  RowNumber: returns the current row ordinal number.                 */
/***********************************************************************/
int TDB::RowNumber(PGLOBAL g, bool b)
  {
  sprintf(g->Message, MSG(ROWID_NOT_IMPL), GetAmName(g, GetAmType()));
	return 0;
  } // end of RowNumber

PTBX TDB::Copy(PTABS t)
  {
  PTDB    tp, tdb1, tdb2 = NULL, outp = NULL;
//PGLOBAL g = t->G;        // Is this really useful ???

  for (tdb1 = this; tdb1; tdb1 = tdb1->Next) {
    tp = tdb1->CopyOne(t);

    if (!outp)
      outp = tp;
    else
      tdb2->Next = tp;

    tdb2 = tp;
    NewPointer(t, tdb1, tdb2);
    } // endfor tdb1

  return outp;
  } // end of Copy

void TDB::Print(PGLOBAL g, FILE *f, uint n)
  {
  PCOL cp;
  char m[64];

  memset(m, ' ', n);                    // Make margin string
  m[n] = '\0';

  for (PTDB tp = this; tp; tp = tp->Next) {
    fprintf(f, "%sTDB (%p) %s no=%d use=%d type=%d\n", m,
            tp, tp->Name, tp->Tdb_No, tp->Use, tp->GetAmType());

    tp->PrintAM(f, m);
    fprintf(f, "%s Columns (deg=%d):\n", m, tp->Degree);

    for (cp = tp->Columns; cp; cp = cp->GetNext())
      cp->Print(g, f, n);

    } /* endfor tp */

  } // end of Print

void TDB::Print(PGLOBAL g, char *ps, uint z)
  {
  sprintf(ps, "R%d.%s", Tdb_No, Name);
  } // end of Print

/* -------------------------- class TDBASE --------------------------- */

/***********************************************************************/
/*  Implementation of the TDBASE class. This is the base class to all  */
/*  classes for tables that can be joined together.                    */
/***********************************************************************/
TDBASE::TDBASE(PTABDEF tdp) : TDB(tdp)
  {
  To_Def = tdp;
  To_Link = NULL;
	To_Key_Col = NULL;
  To_Kindex = NULL;
	To_SetCols = NULL;
  MaxSize = -1;
	Knum = 0;
	Read_Only = (tdp) ? tdp->IsReadOnly() : false;
  } // end of TDBASE constructor

TDBASE::TDBASE(PTDBASE tdbp) : TDB(tdbp)
  {
  To_Def = tdbp->To_Def;
  To_SetCols = tdbp->To_SetCols;				  // ???
  MaxSize = tdbp->MaxSize;
	Read_Only = tdbp->Read_Only;
  } // end of TDBASE copy constructor

/***********************************************************************/
/*  Return the pointer on the DB catalog this table belongs to.        */
/***********************************************************************/
PCATLG TDBASE::GetCat(void)
	{
	return (To_Def) ? To_Def->GetCat() : NULL;
	}	// end of GetCat

/***********************************************************************/
/*  Return the datapath of the DB this table belongs to.               */
/***********************************************************************/
PSZ TDBASE::GetPath(void)
	{
	return To_Def->GetPath();
	}	// end of GetPath

/***********************************************************************/
/*  Initialize TDBASE based column description block construction.     */
/*        name is used to call columns by name.                        */
/*        num is used by TBL to construct columns by index number.     */
/*  Note: name=Null and num=0 for constructing all columns (select *)  */
/***********************************************************************/
PCOL TDBASE::ColDB(PGLOBAL g, PSZ name, int num)
  {
  int     i;
  PCOLDEF cdp;
  PCOL    cp, colp = NULL, cprec = NULL;

  if (trace)
		htrc("ColDB: am=%d colname=%s tabname=%s num=%d\n",
				  GetAmType(), SVP(name), Name, num);

  for (cdp = To_Def->GetCols(), i = 1; cdp; cdp = cdp->GetNext(), i++)
    if ((!name && !num) ||
         (name && !stricmp(cdp->GetName(), name)) || num == i) {
      /*****************************************************************/
      /*  Check for existence of desired column.                       */
      /*  Also find where to insert the new block.                     */
      /*****************************************************************/
      for (cp = Columns; cp; cp = cp->GetNext())
        if (cp->GetIndex() < i)
          cprec = cp;
        else if (cp->GetIndex() == i)
          break;

		  if (trace)
				htrc("cdp(%d).Name=%s cp=%p\n", i, cdp->GetName(), cp);

      /*****************************************************************/
      /*  Now take care of Column Description Block.                   */
      /*****************************************************************/
      if (cp)
        colp = cp;
      else
        colp = MakeCol(g, cdp, cprec, i);

		  if (trace)
				htrc("colp=%p\n", colp);
			
      if (name || num)
        break;
      else if (colp)
        cprec = colp;

      } // endif Name

  return (colp);
  } // end of ColDB

/***********************************************************************/
/*  InsertSpecialColumn: Put a special column ahead of the column list.*/
/***********************************************************************/
PCOL TDBASE::InsertSpecialColumn(PGLOBAL g, PCOL colp)
	{
	if (!colp->IsSpecial())
		return NULL;

	colp->SetNext(Columns);
	Columns = colp;
	return colp;
	} // end of InsertSpecialColumn

/***********************************************************************/
/*  Make a special COLBLK to insert in a table.                        */
/***********************************************************************/
PCOL TDBASE::InsertSpcBlk(PGLOBAL g, PCOLUMN cp)
  {
  char *name = (char*)cp->GetName();
  PCOL  colp;

	if (!strcmp(name, "FILEID")) {
//    !strcmp(name, "SERVID")) {
    if (!To_Def || !(To_Def->GetPseudo() & 2)) {
      sprintf(g->Message, MSG(BAD_SPEC_COLUMN));
      return NULL;
      } // endif Pseudo

//  if (!strcmp(name, "FILEID"))
      colp = new(g) FIDBLK(cp);
//  else
//    colp = new(g) SIDBLK(cp);

  } else if (!strcmp(name, "TABID")) {
    colp = new(g) TIDBLK(cp);
//} else if (!strcmp(name, "CONID")) {
//  colp = new(g) CIDBLK(cp);
	} else if (!strcmp(name, "ROWID")) {
    colp = new(g) RIDBLK(cp, false);
	} else if (!strcmp(name, "ROWNUM")) {
      colp = new(g) RIDBLK(cp, true);
	} else {
    sprintf(g->Message, MSG(BAD_SPECIAL_COL), name);
    return NULL;
  } // endif's name

  if (!(colp = InsertSpecialColumn(g, colp))) {
    sprintf(g->Message, MSG(BAD_SPECIAL_COL), name);
    return NULL;
    } // endif Insert

  return (colp);
  } // end of InsertSpcBlk

/***********************************************************************/
/*  ResetTableOpt: Wrong for this table type.                          */
/***********************************************************************/
int TDBASE::ResetTableOpt(PGLOBAL g, bool dox)
{
	strcpy(g->Message, "This table is not indexable");
	return RC_INFO;
} // end of ResetTableOpt

/***********************************************************************/
/*  SetKindex: set or reset the index pointer.                         */
/***********************************************************************/
void TDBASE::SetKindex(PKXBASE kxp)
  {
  if (To_Kindex)
    To_Kindex->Close();           // Discard old index

  To_Kindex = kxp;
  } // end of SetKindex

/***********************************************************************/
/*  SetRecpos: Replace the table at the specified position.            */
/***********************************************************************/
bool TDBASE::SetRecpos(PGLOBAL g, int recpos) 
	{
	strcpy(g->Message, MSG(SETRECPOS_NIY));
	return true;
	} // end of SetRecpos

/***********************************************************************/
/*  Methods                                                            */
/***********************************************************************/
void TDBASE::PrintAM(FILE *f, char *m)
  {
  fprintf(f, "%s AM(%d): mode=%d\n", m, GetAmType(), Mode);
  } // end of PrintAM

/***********************************************************************/
/*  Marks DOS/MAP table columns used in internal joins.                */
/*  tdb2 is the top of tree or first tdb in chained tdb's and tdbp     */
/*  points to the currently marked tdb.                                */
/*  Two questions here: exact meaning of U_J_INT ?                     */
/*  Why is the eventual reference to To_Key_Col not marked U_J_EXT ?   */
/***********************************************************************/
void TDBASE::MarkDB(PGLOBAL g, PTDB tdb2)
  {
  if (trace)
		htrc("DOS MarkDB: tdbp=%p tdb2=%p\n", this, tdb2);

  } // end of MarkDB