/*************** Tabjdbc H Declares Source Code File (.H) **************/ /* Name: TABJDBC.H Version 1.1 */ /* */ /* (C) Copyright to the author Olivier BERTRAND 2016-2017 */ /* */ /* This file contains the TDBJDBC classes declares. */ /***********************************************************************/ #include "colblk.h" #include "resource.h" #include "jdbccat.h" typedef class JDBCDEF *PJDBCDEF; typedef class TDBJDBC *PTDBJDBC; typedef class JDBCCOL *PJDBCCOL; typedef class TDBXJDC *PTDBXJDC; typedef class JSRCCOL *PJSRCCOL; /***********************************************************************/ /* JDBC table. */ /***********************************************************************/ class DllExport JDBCDEF : public EXTDEF { /* Logical table description */ friend class TDBJDBC; friend class TDBXJDC; friend class TDBJDRV; friend class TDBJTB; friend class TDBJDBCL; public: // Constructor JDBCDEF(void); // Implementation virtual const char *GetType(void) { return "JDBC"; } // Methods virtual bool DefineAM(PGLOBAL g, LPCSTR am, int poff); virtual PTDB GetTable(PGLOBAL g, MODE m); int ParseURL(PGLOBAL g, char *url, bool b = true); bool SetParms(PJPARM sjp); protected: // Members PSZ Driver; /* JDBC driver */ PSZ Url; /* JDBC driver URL */ PSZ Wrapname; /* Java driver name */ }; // end of JDBCDEF #if !defined(NJDBC) #include "jdbconn.h" /***********************************************************************/ /* This is the JDBC Access Method class declaration for files from */ /* other DB drivers to be accessed via JDBC. */ /***********************************************************************/ class TDBJDBC : public TDBEXT { friend class JDBCCOL; friend class JDBConn; public: // Constructor TDBJDBC(PJDBCDEF tdp = NULL); TDBJDBC(PTDBJDBC tdbp); // Implementation virtual AMT GetAmType(void) {return TYPE_AM_JDBC;} virtual PTDB Duplicate(PGLOBAL g) {return (PTDB)new(g) TDBJDBC(this);} // Methods virtual PTDB Clone(PTABS t); virtual bool SetRecpos(PGLOBAL g, int recpos); virtual void ResetSize(void); virtual PCSZ GetServer(void) { return "JDBC"; } virtual int Indexable(void) { return 2; } // Database routines virtual PCOL MakeCol(PGLOBAL g, PCOLDEF cdp, PCOL cprec, int n); virtual int Cardinality(PGLOBAL g); virtual bool OpenDB(PGLOBAL g); virtual int ReadDB(PGLOBAL g); virtual int WriteDB(PGLOBAL g); virtual int DeleteDB(PGLOBAL g, int irc); virtual void CloseDB(PGLOBAL g); virtual bool ReadKey(PGLOBAL g, OPVAL op, const key_range *kr); protected: // Internal functions bool MakeInsert(PGLOBAL g); bool SetParameters(PGLOBAL g); // Members JDBConn *Jcp; // Points to a JDBC connection class JDBCCOL *Cnp; // Points to count(*) column JDBCPARM Ops; // Additional parameters PSZ Wrapname; // Points to Java wrapper name bool Prepared; // True when using prepared statement bool Werr; // Write error bool Rerr; // Rewind error }; // end of class TDBJDBC /***********************************************************************/ /* Class JDBCCOL: JDBC access method column descriptor. */ /* This A.M. is used for JDBC tables. */ /***********************************************************************/ class JDBCCOL : public EXTCOL { friend class TDBJDBC; friend class JDBConn; public: // Constructors JDBCCOL(PCOLDEF cdp, PTDB tdbp, PCOL cprec, int i, PCSZ am = "JDBC"); JDBCCOL(JDBCCOL *colp, PTDB tdbp); // Constructor used in copy process // Implementation virtual int GetAmType(void) { return TYPE_AM_JDBC; } // Methods //virtual bool SetBuffer(PGLOBAL g, PVAL value, bool ok, bool check); virtual void ReadColumn(PGLOBAL g); virtual void WriteColumn(PGLOBAL g); protected: // Constructor for count(*) column JDBCCOL(void); // Members bool uuid; // For PostgreSQL }; // end of class JDBCCOL /***********************************************************************/ /* This is the JDBC Access Method class declaration that send */ /* commands to be executed by other DB JDBC drivers. */ /***********************************************************************/ class TDBXJDC : public TDBJDBC { friend class JSRCCOL; friend class JDBConn; public: // Constructors TDBXJDC(PJDBCDEF tdp = NULL); // Implementation virtual AMT GetAmType(void) {return TYPE_AM_XDBC;} // Methods // Database routines virtual PCOL MakeCol(PGLOBAL g, PCOLDEF cdp, PCOL cprec, int n); //virtual int GetProgMax(PGLOBAL g); virtual int GetMaxSize(PGLOBAL g); virtual bool OpenDB(PGLOBAL g); virtual int ReadDB(PGLOBAL g); virtual int WriteDB(PGLOBAL g); virtual int DeleteDB(PGLOBAL g, int irc); //virtual void CloseDB(PGLOBAL g); protected: // Internal functions PCMD MakeCMD(PGLOBAL g); // Members PCMD Cmdlist; // The commands to execute char *Cmdcol; // The name of the Xsrc command column int Mxr; // Maximum errors before closing int Nerr; // Number of errors so far }; // end of class TDBXJDC /***********************************************************************/ /* Used by table in source execute mode. */ /***********************************************************************/ class JSRCCOL : public JDBCCOL { friend class TDBXJDC; public: // Constructors JSRCCOL(PCOLDEF cdp, PTDB tdbp, PCOL cprec, int i, PCSZ am = "JDBC"); // Implementation virtual int GetAmType(void) {return TYPE_AM_JDBC;} // Methods virtual void ReadColumn(PGLOBAL g); virtual void WriteColumn(PGLOBAL g); protected: // Members char *Buffer; // To get returned message int Flag; // Column content desc }; // end of class JSRCCOL /***********************************************************************/ /* This is the class declaration for the Drivers catalog table. */ /***********************************************************************/ class TDBJDRV : public TDBCAT { public: // Constructor TDBJDRV(PJDBCDEF tdp) : TDBCAT(tdp) {Maxres = tdp->Maxres;} protected: // Specific routines virtual PQRYRES GetResult(PGLOBAL g); // Members int Maxres; // Returned lines limit }; // end of class TDBJDRV /***********************************************************************/ /* This is the class declaration for the tables catalog table. */ /***********************************************************************/ class TDBJTB : public TDBJDRV { public: // Constructor TDBJTB(PJDBCDEF tdp); protected: // Specific routines virtual PQRYRES GetResult(PGLOBAL g); // Members PCSZ Schema; // Points to schema name or NULL PCSZ Tab; // Points to JDBC table name or pattern PCSZ Tabtype; // Points to JDBC table type JDBCPARM Ops; // Additional parameters }; // end of class TDBJTB /***********************************************************************/ /* This is the class declaration for the columns catalog table. */ /***********************************************************************/ class TDBJDBCL : public TDBJTB { public: // Constructor TDBJDBCL(PJDBCDEF tdp); protected: // Specific routines virtual PQRYRES GetResult(PGLOBAL g); // Members PCSZ Colpat; // Points to catalog column pattern }; // end of class TDBJDBCL #endif // !NJDBC