StRoot: StDbLib/StDbBuffer.h Source File

00001 /***************************************************************************
00002  *
00003  * $Id: StDbBuffer.h,v 1.9 2004/01/15 00:02:25 fisyak Exp $
00004  *
00005  * Author: Laurent Conin
00006  ***************************************************************************
00007  *
00008  * Description: Buffer that negotiates data I/O between mysql database
00009  *
00010  ***************************************************************************
00011  *
00012  * $Log: StDbBuffer.h,v $
00013  * Revision 1.9  2004/01/15 00:02:25  fisyak
00014  * Replace ostringstream => StString, add option for alpha
00015  *
00016  * Revision 1.8  2003/04/11 22:47:36  porter
00017  * Added a fast multi-row write model specifically needed by the daqEventTag
00018  * writer. Speed increased from about 100Hz to ~3000Hz.  It is only invoked if
00019  * the table is marked as Non-Indexed (daqTags & scalers). For non-indexed tables
00020  * which include binary stored data (we don't have any yet), the fast writer  has
00021  * to invoke a slower buffer so that the rates are a bit slower (~500Hz at 50 rows/insert).
00022  *
00023  * Revision 1.7  2001/10/26 20:59:46  porter
00024  * fixed new endtime flag from previous checkin. made StDataBaseI available
00025  * at root-cli.
00026  *
00027  * Revision 1.6  2001/10/24 04:05:19  porter
00028  * added long long type to I/O and got rid of obsolete dataIndex table
00029  *
00030  * Revision 1.5  2000/01/27 05:54:33  porter
00031  * Updated for compiling on CC5 + HPUX-aCC + KCC (when flags are reset)
00032  * Fixed reConnect()+transaction model mismatch
00033  * added some in-code comments
00034  *
00035  * Revision 1.4  1999/10/19 14:30:37  porter
00036  * modifications relevant to use with StDbBroker and future merging with
00037  * "params" database structure + some docs + suppressing diagnostics messages
00038  *
00039  * Revision 1.3  1999/09/30 02:06:01  porter
00040  * add StDbTime to better handle timestamps, modify SQL content (mysqlAccessor)
00041  * allow multiple rows (StDbTable), & Added the comment sections at top of
00042  * each header and src file
00043  *
00044  **************************************************************************/
00045 #ifndef STDBBUFFER_H
00046 #define STDBBUFFER_H
00047 #ifndef __CINT__
00048 #include "mysql.h"
00049 #include "mysql_com.h"
00050 #endif
00051 
00052 #include "StDbBufferI.h"
00053 
00054 enum myctype{_char,_uchar,_short,_ushort,_int,_uint,_long,_ulong,_longlong,_float,_double,_ascii,_string};
00055 
00056 const int mycsize[]={sizeof(char),sizeof(unsigned char),sizeof(short),sizeof(unsigned short),sizeof(int),sizeof(unsigned int),sizeof(long),sizeof(unsigned long),sizeof(long long),sizeof(float),sizeof(double),sizeof(char*),sizeof(char*)};
00057 
00058 #if defined(__sun) && !defined(__i386) || defined(__hpux) || defined(__alpha) && !defined(linux)
00059 const int mycswapl[]={1,1,1,1,4,4,4,4,8,4,8,1,1}; // same swapping than Solaris
00060 #else
00061 const int mycswapl[]={1,1,1,1,1,1,1,1,1,1,1,1};
00062 #endif
00063 
00064 struct column {
00065    char* name;
00066    enum myctype  type;
00067    char *val;
00068    unsigned length; };
00069 
00070 enum BuffMode{Auto,Client,Storage};
00071 
00072 class StDbBuffer : public StDbBufferI  { 
00073 
00074 
00075 private:
00076 
00077   int mMax;
00078   int mCur;
00079   int mLast;
00080   column *mCol;
00081   BuffMode mMode;
00082 
00083   void zeroColumn(int istart, int iend);
00084 
00085 public: 
00086 
00087   StDbBuffer(){
00088     mCur=0;
00089     mLast=-1;
00090     mMax=100;
00091     mCol= new column[mMax+1];
00092     zeroColumn(0,mMax);
00093     mMode=Storage;
00094   };
00095 
00096   StDbBuffer(unsigned int anum_fields, column *acol){
00097     Init( anum_fields,acol);}
00098 
00099   void Init(unsigned int anum_fields, column * acol){
00100     mCur=0;
00101     mLast=anum_fields;
00102     mCol=acol;};
00103 
00104   ~StDbBuffer(){Raz();delete [] mCol;  };  
00105 
00106   virtual void SetClientMode() {mMode=Client;};
00107   virtual void SetStorageMode() {mMode=Storage;};
00108   virtual bool IsClientMode() {return (mMode==Client) ? true : false;};
00109   virtual bool IsStorageMode() {return (mMode==Storage) ? true : false;};  
00110    
00111   void Raz();
00112   void Print();
00113 
00114   virtual char** WhatsIn(); // debug , not to be use
00115 
00116   virtual bool  ReadScalar(char   &c, const char *aName) ;
00117   virtual bool  ReadScalar(unsigned char  &c, const char *) ; 
00118   virtual bool  ReadScalar(short  &h, const char *) ;
00119   virtual bool  ReadScalar(unsigned short &h, const char *) ;
00120   virtual bool  ReadScalar(int    &i, const char *) ;
00121   virtual bool  ReadScalar(unsigned int   &i, const char *) ;
00122   virtual bool  ReadScalar(long   &l, const char *) ;
00123   virtual bool  ReadScalar(unsigned long  &l, const char *) ;
00124   virtual bool  ReadScalar(long long  &l, const char *) ;
00125   virtual bool  ReadScalar(float  &f, const char *) ;
00126   virtual bool  ReadScalar(double &d, const char *) ;
00127   virtual bool  ReadScalar(char   *&c, const char *) ; 
00128   
00129   virtual bool     WriteScalar(const char   c, const char *) ;
00130   virtual bool     WriteScalar(const unsigned char  c, const char *) ;
00131   virtual bool     WriteScalar(const short  h, const char *) ;
00132   virtual bool     WriteScalar(const unsigned short h, const char *) ;
00133   virtual bool     WriteScalar(const int    i, const char *) ;
00134   virtual bool     WriteScalar(const unsigned int   i, const char *) ;
00135   virtual bool     WriteScalar(const long   l, const char *) ;
00136   virtual bool     WriteScalar(const unsigned long  l, const char *) ;
00137   virtual bool     WriteScalar(const long long  l, const char *) ;
00138   virtual bool     WriteScalar(const float  f, const char *) ;
00139   virtual bool     WriteScalar(const double d, const char *) ;
00140   virtual bool     WriteScalar(const char  *c, const char *);
00141 
00142   virtual bool     ReadArray(char    *&c, int &len, const char *);
00143   virtual bool     ReadArray(unsigned char  *&c, int &len, const char *);
00144   virtual bool     ReadArray( short  *&c, int &len, const char *);
00145   virtual bool     ReadArray( unsigned short  *&c, int &len, const char *);
00146   virtual bool     ReadArray(int  *&c, int &len, const char *);
00147   virtual bool     ReadArray(unsigned int   *&c, int &len, const char *);
00148   virtual bool     ReadArray(long  *&c, int &len, const char *);
00149   virtual bool     ReadArray(unsigned long  *&c, int &len, const char *);
00150   virtual bool     ReadArray(long long  *&c, int &len, const char *);
00151   virtual bool     ReadArray(float   *&c, int &len, const char *);
00152   virtual bool     ReadArray(double  *&c, int &len, const char *);
00153   virtual bool     ReadArray(char  **&c, int &len, const char *);
00154 
00155   virtual bool     WriteArray(char    *c, int len, const char *);
00156   virtual bool     WriteArray(unsigned char   *c, int len, const char *);
00157   virtual bool     WriteArray(short   *c, int len, const char *);
00158   virtual bool     WriteArray(unsigned short  *c, int len, const char *);
00159   virtual bool     WriteArray(int     *c, int len, const char *);
00160   virtual bool     WriteArray(unsigned int    *c, int len, const char *);
00161   virtual bool     WriteArray(long    *c, int len, const char *);
00162   virtual bool     WriteArray(unsigned long   *c, int len, const char *);
00163   virtual bool     WriteArray(long long   *c, int len, const char *);
00164   virtual bool     WriteArray(float   *c, int len, const char *);
00165   virtual bool     WriteArray(double  *c, int len, const char *);
00166   virtual bool     WriteArray(char **c, int len, const char *);
00167 
00168 
00169 
00170 protected:
00171   //char* Raw_result (const char *aName);
00172 
00173   bool Find_Col (const   char *aName);
00174   void AddField(const char *aName, const myctype aTpe,const void* aVal,const int aLen);
00175   void ChangeField(const myctype aTpe,const void* aVal,const int aLen);
00176 
00177 //bool WriteMem(char &s,void* aVal, myctype type);
00178 
00179   bool WriteMem(char *s,void* aVal, myctype type);
00180   bool WriteMem(unsigned char *s,void* aVal, myctype type);
00181   bool WriteMem(short *s,void* aVal, myctype type);
00182   bool WriteMem(unsigned short *s,void* aVal, myctype type);
00183   bool WriteMem(int *s,void* aVal, myctype type);
00184   bool WriteMem(unsigned int *s,void* aVal, myctype type);
00185   bool WriteMem(long *s,void* aVal, myctype type);
00186   bool WriteMem(unsigned long *s,void* aVal, myctype type);
00187   bool WriteMem(long long *s,void* aVal, myctype type);
00188   bool WriteMem(float *s,void* aVal, myctype type);
00189   bool WriteMem(double *s,void* aVal, myctype type);
00190   bool WriteMem(char **s,void* aVal, myctype type);
00191 
00192   void StrConv(char* aVal,char &s);
00193   void StrConv(char* aVal,unsigned char &s);
00194   void StrConv(char* aVal,short &s);
00195   void StrConv(char* aVal,unsigned short &s);
00196   void StrConv(char* aVal,int &s);
00197   void StrConv(char* aVal,unsigned int &s);
00198   void StrConv(char* aVal,long &s);
00199   void StrConv(char* aVal,unsigned long &s);
00200   void StrConv(char* aVal,long long &s);
00201   void StrConv(char* aVal,float &s);
00202   void StrConv(char* aVal,double &s); 
00203   void StrConv(char* aVal,char* &s);
00204 
00205   void MemSwapCpy(char* where,char* from,int len,int swaplen,BuffMode mode);
00206 
00207   //ClassDef(StDbBuffer,0)
00208 
00209 
00210 };
00211 
00212 
00213 
00214 #endif
00215 
00216 
00217 
00218 
00219 
00220