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, 254 insertions, 0 deletions

diff --git a/storage/connect/tabmysql.h b/storage/connect/tabmysql.h
new file mode 100644
index 00000000..b5af77de
--- /dev/null
+++ b/storage/connect/tabmysql.h
@@ -0,0 +1,254 @@
+// TDBMYSQL.H     Olivier Bertrand    2007-2017
+#include "myconn.h"               // MySQL connection declares
+
+typedef class MYSQLDEF *PMYDEF;
+typedef class TDBMYSQL *PTDBMY;
+typedef class MYSQLCOL *PMYCOL;
+typedef class TDBMYEXC *PTDBMYX;
+typedef class MYXCOL   *PMYXCOL;
+typedef class MYSQLC   *PMYC;
+
+/* ------------------------- MYSQL classes --------------------------- */
+
+/***********************************************************************/
+/*  MYSQL: table type that are MySQL tables.                           */
+/*  Using embedded MySQL library (or optionally calling a MySQL server)*/
+/***********************************************************************/
+
+/***********************************************************************/
+/*  MYSQL table.                                                       */
+/***********************************************************************/
+class MYSQLDEF : public EXTDEF           {/* Logical table description */
+  friend class TDBMYSQL;
+  friend class TDBMYEXC;
+  friend class TDBMCL;
+  friend class ha_connect;
+ public:
+  // Constructor
+  MYSQLDEF(void);
+
+  // Implementation
+  virtual const char *GetType(void) {return "MYSQL";}
+  inline  PSZ  GetHostname(void) {return Hostname;};
+//inline  PSZ  GetDatabase(void) {return Tabschema;};
+//inline  PSZ  GetTabname(void) {return Tabname;}
+//inline  PSZ  GetSrcdef(void) {return Srcdef;}
+//inline  PSZ  GetUsername(void) {return Username;};
+//inline  PSZ  GetPassword(void) {return Password;};
+  inline  int  GetPortnumber(void) {return Portnumber;}
+
+  // Methods
+//virtual int  Indexable(void) {return 2;}
+  virtual bool DefineAM(PGLOBAL g, LPCSTR am, int poff);
+  virtual PTDB GetTable(PGLOBAL g, MODE m);
+          bool ParseURL(PGLOBAL g, char *url, bool b = true);
+          bool GetServerInfo(PGLOBAL g, const char *server_name);
+
+ protected:
+  // Members
+  PSZ     Hostname;           /* Host machine to use                   */
+//PSZ     Tabschema;          /* Database to be used by server         */
+//PSZ     Tabname;            /* External table name                   */
+//PSZ     Srcdef;             /* The source table SQL definition       */
+//PSZ     Username;           /* User logon name                       */
+//PSZ     Password;           /* Password logon info                   */
+  PSZ     Server;             /* PServerID                             */
+//PSZ     Qrystr;             /* The original query                    */
+  int     Portnumber;         /* MySQL port number (0 = default)       */
+//int     Maxerr;             /* Maxerr for an Exec table              */
+//int     Quoted;             /* Identifier quoting level              */
+  bool    Isview;             /* true if this table is a MySQL view    */
+  bool    Bind;               /* Use prepared statement on insert      */
+  bool    Delayed;            /* Delayed insert                        */
+  bool    Ignored;            /* Use insert IGNORE                     */
+//bool    Xsrc;               /* Execution type                        */
+  bool    Huge;               /* True for big table                    */
+  }; // end of MYSQLDEF
+
+/***********************************************************************/
+/*  This is the class declaration for the MYSQL table.                 */
+/***********************************************************************/
+class TDBMYSQL : public TDBEXT {
+  friend class MYSQLCOL;
+	friend class TDBTBM;
+ public:
+  // Constructor
+  TDBMYSQL(PMYDEF tdp);
+  TDBMYSQL(PTDBMY tdbp);
+
+  // Implementation
+  virtual AMT  GetAmType(void) {return TYPE_AM_MYSQL;}
+  virtual PTDB Duplicate(PGLOBAL g) {return (PTDB)new(g) TDBMYSQL(this);}
+
+  // Methods
+  virtual PTDB Clone(PTABS t);
+//virtual int  GetAffectedRows(void) {return AftRows;}
+  virtual int  GetRecpos(void) {return N;}
+  virtual int  GetProgMax(PGLOBAL g);
+  virtual void ResetDB(void) {N = 0;}
+  virtual int  RowNumber(PGLOBAL g, bool b = false);
+  virtual bool IsView(void) {return Isview;}
+  virtual PCSZ GetServer(void) {return Server;}
+          void SetDatabase(LPCSTR db) {Schema = (char*)db;}
+
+  // Schema routines
+  virtual PCOL MakeCol(PGLOBAL g, PCOLDEF cdp, PCOL cprec, int n);
+  virtual int  Cardinality(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);
+  virtual bool ReadKey(PGLOBAL g, OPVAL op, const key_range *kr);
+
+  // Specific routines
+          bool SetColumnRanks(PGLOBAL g);
+          PCOL MakeFieldColumn(PGLOBAL g, char *name);
+          PSZ  FindFieldColumn(char *name);
+
+ protected:
+  // Internal functions
+  bool MakeSelect(PGLOBAL g, bool mx);
+  bool MakeInsert(PGLOBAL g);
+  int  BindColumns(PGLOBAL g __attribute__((unused)));
+  virtual bool MakeCommand(PGLOBAL g);
+//int  MakeUpdate(PGLOBAL g);  
+//int  MakeDelete(PGLOBAL g);
+  int  SendCommand(PGLOBAL g);
+
+  // Members
+  MYSQLC      Myc;            // MySQL connection class
+  MYSQL_BIND *Bind;           // To the MySQL bind structure array
+//PSTRG       Query;          // Constructed SQL query
+  char       *Host;           // Host machine to use
+//char       *User;           // User logon info
+//char       *Pwd;            // Password logon info
+//char       *Schema;         // Database to be used by server
+//char       *TableName;      // External table name
+//char       *Srcdef;         // The source table SQL definition
+  char       *Server;         // The server ID
+//char       *Qrystr;         // The original query
+  bool        Fetched;        // True when fetch was done
+  bool        Isview;         // True if this table is a MySQL view
+  bool        Prep;           // Use prepared statement on insert
+  bool        Delayed;        // Use delayed insert
+  bool        Ignored;        // Use insert IGNORE
+  int         m_Rc;           // Return code from command
+//int         AftRows;        // The number of affected rows
+  int         N;              // The current table index
+  unsigned    Port;          // MySQL port number (0 = default)
+//int         Nparm;          // The number of statement parameters
+//int         Quoted;         // The identifier quoting level
+  }; // end of class TDBMYSQL
+
+/***********************************************************************/
+/*  Class MYSQLCOL: MySQL table column.                                */
+/***********************************************************************/
+class MYSQLCOL : public COLBLK {
+  friend class TDBMYSQL;
+ public:
+  // Constructors
+  MYSQLCOL(PCOLDEF cdp, PTDB tdbp, PCOL cprec, int i,  PCSZ am = "MYSQL");
+  MYSQLCOL(MYSQL_FIELD *fld, PTDB tdbp, int i,  PCSZ am = "MYSQL");
+  MYSQLCOL(MYSQLCOL *colp, PTDB tdbp); // Constructor used in copy process
+
+  // Implementation
+  virtual int  GetAmType(void) {return TYPE_AM_MYSQL;}
+          void InitBind(PGLOBAL g);
+
+  // Methods
+  virtual bool SetBuffer(PGLOBAL g, PVAL value, bool ok, bool check);
+  virtual void ReadColumn(PGLOBAL g);
+  virtual void WriteColumn(PGLOBAL g);
+          bool FindRank(PGLOBAL g);
+
+ protected:
+  // Members
+  MYSQL_BIND   *Bind;            // This column bind structure pointer
+  PVAL          To_Val;          // To value used for Update/Insert
+  unsigned long Slen;            // Bind string lengh
+  int           Rank;            // Rank (position) number in the query
+  }; // end of class MYSQLCOL
+
+/***********************************************************************/
+/*  This is the class declaration for the exec command MYSQL table.    */
+/***********************************************************************/
+class TDBMYEXC : public TDBMYSQL {
+  friend class MYXCOL;
+ public:
+  // Constructors
+  TDBMYEXC(PMYDEF tdp); 
+  TDBMYEXC(PTDBMYX tdbp);
+
+  // Implementation
+  virtual AMT  GetAmType(void) {return TYPE_AM_MYX;}
+  virtual PTDB Duplicate(PGLOBAL g) {return (PTDB)new(g) TDBMYEXC(this);}
+
+  // Methods
+  virtual PTDB Clone(PTABS t);
+  virtual bool IsView(void) {return Isview;}
+
+  // Database routines
+  virtual PCOL MakeCol(PGLOBAL g, PCOLDEF cdp, PCOL cprec, int n);
+  virtual int  GetMaxSize(PGLOBAL g);
+  virtual bool OpenDB(PGLOBAL g);
+  virtual int  ReadDB(PGLOBAL g);
+  virtual int  WriteDB(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
+  bool     Shw;               // Show warnings
+  bool     Havew;             // True when processing warnings
+  bool     Isw;               // True for warning lines
+  int      Warnings;          // Warnings number
+  int      Mxr;               // Maximum errors before closing
+  int      Nerr;              // Number of errors so far
+  }; // end of class TDBMYEXC
+
+/***********************************************************************/
+/*  Class MYXCOL: MySQL exec command table column.                     */
+/***********************************************************************/
+class MYXCOL : public MYSQLCOL {
+  friend class TDBMYEXC;
+ public:
+  // Constructors
+  MYXCOL(PCOLDEF cdp, PTDB tdbp, PCOL cprec, int i,  PCSZ am = "MYSQL");
+  MYXCOL(MYSQL_FIELD *fld, PTDB tdbp, int i,  PCSZ am = "MYSQL");
+  MYXCOL(MYXCOL *colp, PTDB tdbp);   // Constructor used in copy process
+
+  // 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 MYXCOL
+
+/***********************************************************************/
+/*  This is the class declaration for the MYSQL column catalog table.  */
+/***********************************************************************/
+class TDBMCL : public TDBCAT {
+ public:
+  // Constructor
+  TDBMCL(PMYDEF tdp);
+
+ protected:
+	// Specific routines
+	virtual PQRYRES GetResult(PGLOBAL g);
+
+  // Members
+  PCSZ Host;                      // Host machine to use            
+	PCSZ Db;                        // Database to be used by server  
+	PCSZ Tab;                       // External table name            
+	PCSZ User;                      // User logon name                
+	PCSZ Pwd;                       // Password logon info            
+	int  Port;                      // MySQL port number (0 = default)
+  }; // end of class TDBMCL