Quelle  tabcmg.h   Sprache: C

/**************** tabcmg H Declares Source Code File (.H) **************/
/*  Name: tabcmg.h   Version 1.3                                       */
/*                                                                     */
/*  (C) Copyright to the author Olivier BERTRAND          2017 - 2021  */
/*                                                                     */
/*  This file contains the MongoDB classes declares.                   */
/***********************************************************************/
#include "mongo.h"
#include "cmgoconn.h"

/***********************************************************************/
/*  Class used to get the columns of a mongo collection.               */
/***********************************************************************/
class CMGDISC : public MGODISC {
public:
 // Constructor
 CMGDISC(PGLOBAL g, int *lg) : MGODISC(g, lg) { drv = "C"; }

 // Methods
 void GetDoc(void) override;
//bool Find(PGLOBAL g, int i, int k, bool b) override;
 bool Find(PGLOBAL g) override;

 // BSON Function
//bool FindInDoc(PGLOBAL g, bson_iter_t *iter, const bson_t *doc,
//              char *pcn, char *pfmt, int i, int k, bool b);
 bool FindInDoc(PGLOBAL g, bson_iter_t *iter, const bson_t *doc,
               char *pcn, char *pfmt, int k, bool b);

 // Members
 bson_iter_t   iter;
 const bson_t *doc;
}; // end of CMGDISC

/* -------------------------- TDBCMG class --------------------------- */

/***********************************************************************/
/*  This is the MongoDB Table Type class declaration.                  */
/*  The table is a collection, each record being a document.           */
/***********************************************************************/
class DllExport TDBCMG : public TDBEXT {
 friend class MGOCOL;
 friend class MGODEF;
 friend class CMGDISC;
 friend PQRYRES MGOColumns(PGLOBAL, PCSZ, PCSZ, PTOS, bool);
public:
 // Constructor
 TDBCMG(MGODEF *tdp);
 TDBCMG(TDBCMG *tdbp);

 // Implementation
 AMT  GetAmType(void) override {return TYPE_AM_MGO;}
 PTDB Duplicate(PGLOBAL g) {return (PTDB)new(g) TDBCMG(this);}

 // Methods
 PTDB Clone(PTABS t) override;
 PCOL MakeCol(PGLOBAL g, PCOLDEF cdp, PCOL cprec, int n) override;
 PCOL InsertSpecialColumn(PCOL colp) override;
 int  RowNumber(PGLOBAL g, bool b = FALSE) override {return N;}

 // Database routines
 int  Cardinality(PGLOBAL g) override;
 int  GetMaxSize(PGLOBAL g) override;
 bool OpenDB(PGLOBAL g) override;
 int  ReadDB(PGLOBAL g) override;
 int  WriteDB(PGLOBAL g) override;
 int  DeleteDB(PGLOBAL g, int irc) override;
 void CloseDB(PGLOBAL g) override;
 bool ReadKey(PGLOBAL g, OPVAL op, const key_range *kr) override;

protected:
 bool Init(PGLOBAL g);

 // Members
 CMgoConn             *Cmgp;       // Points to a C Mongo connection class
 CMGOPARM       Pcg;    // Parms passed to Cmgp
 const Item           *Cnd;     // The first condition
 PCSZ         Strfy;   // The stringified columns
 int                   Fpos;       // The current row index
 int                   N;          // The current Rownum
 int                   B;          // Array index base
 bool                  Done;     // Init done
}; // end of class TDBCMG

/* --------------------------- MGOCOL class -------------------------- */

/***********************************************************************/
/*  Class MGOCOL: MongoDB access method column descriptor.             */
/***********************************************************************/
class DllExport MGOCOL : public EXTCOL {
 friend class TDBCMG;
 friend class FILTER;
public:
 // Constructors
 MGOCOL(PGLOBAL g, PCOLDEF cdp, PTDB tdbp, PCOL cprec, int i);
 MGOCOL(MGOCOL *colp, PTDB tdbp); // Constructor used in copy process

 // Implementation
 int   GetAmType(void) override { return Tmgp->GetAmType(); }
 bool  Stringify(void) override { return Sgfy; }

 // Methods
 PSZ   GetJpath(PGLOBAL g, bool proj) override;
 void  ReadColumn(PGLOBAL g) override;
 void  WriteColumn(PGLOBAL g) override;

protected:
 // Default constructor not to be used
 MGOCOL(void) {}

 // Members
 TDBCMG *Tmgp;                 // To the MGO table block
 char   *Jpath;                // The json path
 bool    Sgfy;         // True if stringified
}; // end of class MGOCOL

/***********************************************************************/
/*  This is the class declaration for the MONGO catalog table.         */
/***********************************************************************/
class DllExport TDBGOL : public TDBCAT {
public:
 // Constructor
 TDBGOL(PMGODEF tdp);

protected:
 // Specific routines
 virtual PQRYRES GetResult(PGLOBAL g) override;

 // Members
 PTOS Topt;
 PCSZ Uri;
 PCSZ Db;
}; // end of class TDBGOL