Adding the CONNECT storage engine sources.

1 files changed, 427 insertions, 0 deletions

diff --git a/storage/connect/table.cpp b/storage/connect/table.cpp
new file mode 100644
index 00000000000..db603513458
--- /dev/null
+++ b/storage/connect/table.cpp
@@ -0,0 +1,427 @@
+/************** 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