Adding upstream version 1:10.11.6.upstream/1%10.11.6upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 323 insertions, 0 deletions

diff --git a/storage/connect/tabjson.h b/storage/connect/tabjson.h
new file mode 100644
index 00000000..dcf40620
--- /dev/null
+++ b/storage/connect/tabjson.h
@@ -0,0 +1,323 @@
+/*************** tabjson H Declares Source Code File (.H) **************/
+/*  Name: tabjson.h   Version 1.3                                      */
+/*                                                                     */
+/*  (C) Copyright to the author Olivier BERTRAND          2014 - 2021  */
+/*                                                                     */
+/*  This file contains the JSON classes declares.                      */
+/***********************************************************************/
+#pragma once
+//#include "osutil.h"				// Unuseful and bad for OEM
+#include "block.h"
+#include "colblk.h"
+#include "json.h"
+
+enum JMODE {MODE_OBJECT, MODE_ARRAY, MODE_VALUE};
+
+typedef class JSONDEF *PJDEF;
+typedef class TDBJSON *PJTDB;
+typedef class JSONCOL *PJCOL;
+class TDBJSN;
+DllExport PQRYRES JSONColumns(PGLOBAL, PCSZ, PCSZ, PTOS, bool);
+
+/***********************************************************************/
+/*  The JSON tree node. Can be an Object or an Array.           	  	 */
+/***********************************************************************/
+typedef struct _jnode {
+  PSZ   Key;                    // The key used for object
+  OPVAL Op;                     // Operator used for this node
+  PVAL  CncVal;                 // To cont value used for OP_CNC
+  PVAL  Valp;                   // The internal array VALUE
+  int   Rank;                   // The rank in array
+  int   Rx;                     // Read row number
+  int   Nx;                     // Next to read row number
+} JNODE, *PJNODE;
+
+typedef struct _jncol {
+	struct _jncol *Next;
+	char *Name;
+	char *Fmt;
+	JTYP  Type;
+	int   Len;
+	int   Scale;
+	bool  Cbn;
+	bool  Found;
+} JCOL, *PJCL;
+
+/***********************************************************************/
+/*  Class used to get the columns of a mongo collection.               */
+/***********************************************************************/
+class JSONDISC : public BLOCK {
+public:
+	// Constructor
+	JSONDISC(PGLOBAL g, uint *lg);
+
+	// Functions
+	int  GetColumns(PGLOBAL g, PCSZ db, PCSZ dsn, PTOS topt);
+	bool Find(PGLOBAL g, PJVAL jvp, PCSZ key, int j);
+	void AddColumn(PGLOBAL g);
+
+	// Members
+	JCOL    jcol;
+	PJCL    jcp, fjcp, pjcp;
+//PVL     vlp;
+	PJDEF   tdp;
+	TDBJSN *tjnp;
+	PJTDB   tjsp;
+	PJPR    jpp;
+	PJSON   jsp;
+	PJOB    row;
+	PCSZ    sep;
+  PCSZ    strfy;
+	char    colname[65], fmt[129], buf[16];
+	uint   *length;
+	int     i, n, bf, ncol, lvl, sz, limit;
+	bool    all;
+}; // end of JSONDISC
+
+/***********************************************************************/
+/*  JSON table.                                                        */
+/***********************************************************************/
+class DllExport JSONDEF : public DOSDEF {         /* Table description */
+  friend class TDBJSON;
+  friend class TDBJSN;
+  friend class TDBJCL;
+	friend class JSONDISC;
+#if defined(CMGO_SUPPORT)
+	friend class CMGFAM;
+#endif   // CMGO_SUPPORT
+#if defined(JAVA_SUPPORT)
+	friend class JMGFAM;
+#endif   // JAVA_SUPPORT
+public:
+  // Constructor
+  JSONDEF(void);
+
+  // Implementation
+  virtual const char *GetType(void) {return "JSON";}
+
+  // Methods
+  virtual bool DefineAM(PGLOBAL g, LPCSTR am, int poff);
+  virtual PTDB GetTable(PGLOBAL g, MODE m);
+
+ protected:
+  // Members
+  JMODE Jmode;                  /* MODE_OBJECT by default              */
+	PCSZ  Objname;                /* Name of first level object          */
+	PCSZ  Xcol;                   /* Name of expandable column           */
+  int   Limit;                  /* Limit of multiple values            */
+  int   Pretty;                 /* Depends on file structure           */
+  int   Base;                   /* The array index base                */
+  bool  Strict;                 /* Strict syntax checking              */
+	char  Sep;                    /* The Jpath separator                 */
+	const char *Uri;							/* MongoDB connection URI              */
+	PCSZ  Collname;               /* External collection name            */
+	PSZ   Options;                /* Colist ; Pipe                       */
+	PSZ   Filter;                 /* Filter                              */
+	PSZ   Driver;									/* MongoDB Driver (C or JAVA)          */
+	bool  Pipe;							      /* True if Colist is a pipeline        */
+	int   Version;							  /* Driver version                      */
+	PSZ   Wrapname;								/* MongoDB java wrapper name           */
+  }; // end of JSONDEF
+
+/* -------------------------- TDBJSN class --------------------------- */
+
+/***********************************************************************/
+/*  This is the JSN Access Method class declaration.                   */
+/*  The table is a DOS file, each record being a JSON object.          */
+/***********************************************************************/
+class DllExport TDBJSN : public TDBDOS {
+  friend class JSONCOL;
+	friend class JSONDEF;
+	friend class JSONDISC;
+#if defined(CMGO_SUPPORT)
+	friend class CMGFAM;
+#endif   // CMGO_SUPPORT
+#if defined(JAVA_SUPPORT)
+	friend class JMGFAM;
+#endif   // JAVA_SUPPORT
+public:
+  // Constructor
+   TDBJSN(PJDEF tdp, PTXF txfp);
+   TDBJSN(TDBJSN *tdbp);
+
+  // Implementation
+  virtual AMT   GetAmType(void) {return TYPE_AM_JSN;}
+  virtual bool  SkipHeader(PGLOBAL g);
+  virtual PTDB  Duplicate(PGLOBAL g) {return (PTDB)new(g) TDBJSN(this);}
+          PJSON GetRow(void) {return Row;}
+					void  SetG(PGLOBAL g) {G = g;}
+
+  // Methods
+  virtual PTDB  Clone(PTABS t);
+  virtual PCOL  MakeCol(PGLOBAL g, PCOLDEF cdp, PCOL cprec, int n);
+  virtual PCOL  InsertSpecialColumn(PCOL colp);
+  virtual int   RowNumber(PGLOBAL g, bool b = FALSE)
+                 {return (b) ? M : N;}
+	virtual bool  CanBeFiltered(void) 
+	              {return Txfp->GetAmType() == TYPE_AM_MGO || !Xcol;}
+
+  // Database routines
+  //virtual int   Cardinality(PGLOBAL g);
+  //virtual int   GetMaxSize(PGLOBAL g);
+  virtual bool  OpenDB(PGLOBAL g);
+  virtual int   ReadDB(PGLOBAL g);
+	virtual bool  PrepareWriting(PGLOBAL g);
+	virtual int   WriteDB(PGLOBAL g);
+  virtual void  CloseDB(PGLOBAL g);
+
+	// Specific routine
+	virtual int   EstimatedLength(void);
+
+protected:
+          PJSON FindRow(PGLOBAL g);
+          bool  MakeTopTree(PGLOBAL g, PJSON jsp);
+
+  // Members
+	PGLOBAL G;											 // Support of parse memory
+	PJSON   Top;                     // The top JSON tree
+	PJSON   Row;                     // The current row
+	PJVAL   Val;                     // The value of the current row
+	PJCOL   Colp;                    // The multiple column
+	JMODE   Jmode;                   // MODE_OBJECT by default
+	PCSZ    Objname;                 // The table object name
+	PCSZ    Xcol;                    // Name of expandable column
+	int     Fpos;                    // The current row index
+	int     N;                       // The current Rownum
+	int     M;                       // Index of multiple value
+	int     Limit;		    				   // Limit of multiple values
+	int     Pretty;                  // Depends on file structure
+	int     NextSame;                // Same next row
+	int     SameRow;                 // Same row nb
+	int     Xval;                    // Index of expandable array
+	int     B;                       // Array index base
+	char    Sep;                     // The Jpath separator
+	bool    Strict;                  // Strict syntax checking
+	bool    Comma;                   // Row has final comma
+  bool    Xpdable;                 // False: expandable columns are NULL
+}; // end of class TDBJSN
+
+/* -------------------------- JSONCOL class -------------------------- */
+
+/***********************************************************************/
+/*  Class JSONCOL: JSON access method column descriptor.               */
+/***********************************************************************/
+class DllExport JSONCOL : public DOSCOL {
+  friend class TDBJSN;
+  friend class TDBJSON;
+#if defined(CMGO_SUPPORT)
+	friend class CMGFAM;
+#endif   // CMGO_SUPPORT
+#if defined(JAVA_SUPPORT)
+	friend class JMGFAM;
+#endif   // JAVA_SUPPORT
+public:
+  // Constructors
+  JSONCOL(PGLOBAL g, PCOLDEF cdp, PTDB tdbp, PCOL cprec, int i);
+  JSONCOL(JSONCOL *colp, PTDB tdbp); // Constructor used in copy process
+
+  // Implementation
+  virtual int   GetAmType(void) {return Tjp->GetAmType();}
+  virtual bool  Stringify(void) { return Sgfy; }
+
+  // Methods
+  virtual bool  SetBuffer(PGLOBAL g, PVAL value, bool ok, bool check);
+          bool  ParseJpath(PGLOBAL g);
+	virtual PSZ   GetJpath(PGLOBAL g, bool proj);
+	virtual void  ReadColumn(PGLOBAL g);
+  virtual void  WriteColumn(PGLOBAL g);
+
+ protected:
+  bool  CheckExpand(PGLOBAL g, int i, PSZ nm, bool b);
+  bool  SetArrayOptions(PGLOBAL g, char *p, int i, PSZ nm);
+  PVAL  GetColumnValue(PGLOBAL g, PJSON row, int i);
+  PVAL  ExpandArray(PGLOBAL g, PJAR arp, int n);
+  PVAL  CalculateArray(PGLOBAL g, PJAR arp, int n);
+  PVAL  MakeJson(PGLOBAL g, PJSON jsp, int n);
+  PJVAL GetRowValue(PGLOBAL g, PJSON row, int i);
+  void  SetJsonValue(PGLOBAL g, PVAL vp, PJVAL val);
+	PJSON GetRow(PGLOBAL g);
+
+  // Default constructor not to be used
+  JSONCOL(void) = default;
+
+  // Members
+	PGLOBAL G;										// Support of parse memory
+	TDBJSN *Tjp;                  // To the JSN table block
+  PVAL    MulVal;               // To value used by multiple column
+  char   *Jpath;                // The json path
+  JNODE  *Nodes;                // The intermediate objects
+  int     Nod;                  // The number of intermediate objects
+  int     Xnod;                 // Index of multiple values
+	char    Sep;                  // The Jpath separator
+	bool    Xpd;                  // True for expandable column
+  bool    Parsed;               // True when parsed
+  bool    Warned;               // True when warning issued
+  bool    Sgfy;									// True if stringified
+}; // end of class JSONCOL
+
+/* -------------------------- TDBJSON class -------------------------- */
+
+/***********************************************************************/
+/*  This is the JSON Access Method class declaration.                  */
+/***********************************************************************/
+class DllExport TDBJSON : public TDBJSN {
+	friend class JSONDEF;
+	friend class JSONCOL;
+ public:
+  // Constructor
+   TDBJSON(PJDEF tdp, PTXF txfp);
+   TDBJSON(PJTDB tdbp);
+
+  // Implementation
+  virtual AMT  GetAmType(void) {return TYPE_AM_JSON;}
+  virtual PTDB Duplicate(PGLOBAL g) {return (PTDB)new(g) TDBJSON(this);}
+          PJAR GetDoc(void) {return Doc;} 
+
+  // Methods
+  virtual PTDB Clone(PTABS t);
+
+  // Database routines
+  virtual int  Cardinality(PGLOBAL g);
+  virtual int  GetMaxSize(PGLOBAL g);
+  virtual void ResetSize(void);
+  virtual int  GetProgCur(void) {return N;}
+	virtual int  GetRecpos(void);
+  virtual bool SetRecpos(PGLOBAL g, int recpos);
+  virtual bool OpenDB(PGLOBAL g);
+  virtual int  ReadDB(PGLOBAL g);
+  virtual bool PrepareWriting(PGLOBAL g) {return false;}
+  virtual int  WriteDB(PGLOBAL g);
+  virtual int  DeleteDB(PGLOBAL g, int irc);
+  virtual void CloseDB(PGLOBAL g);
+          int  MakeDocument(PGLOBAL g);
+
+  // Optimization routines
+  virtual int  MakeIndex(PGLOBAL g, PIXDEF pxdf, bool add);
+
+ protected:
+          int  MakeNewDoc(PGLOBAL g);
+
+  // Members
+  PJAR  Doc;                       // The document array
+  int   Multiple;                  // 0: No 1: DIR 2: Section 3: filelist
+  bool  Done;                      // True when document parsing is done
+  bool  Changed;                   // After Update, Insert or Delete
+  }; // end of class TDBJSON
+
+/***********************************************************************/
+/*  This is the class declaration for the JSON catalog table.          */
+/***********************************************************************/
+class DllExport TDBJCL : public TDBCAT {
+ public:
+  // Constructor
+  TDBJCL(PJDEF tdp);
+
+ protected:
+  // Specific routines
+  virtual PQRYRES GetResult(PGLOBAL g);
+
+  // Members
+  PTOS Topt;
+  PCSZ Db;
+	PCSZ Dsn;
+  }; // end of class TDBJCL