TBufferSQL2.cxx File Reference

#include "TBufferSQL2.h"
#include "TObjArray.h"
#include "TROOT.h"
#include "TDataType.h"
#include "TClass.h"
#include "TClassTable.h"
#include "TMap.h"
#include "TExMap.h"
#include "TMethodCall.h"
#include "TStreamerInfo.h"
#include "TStreamerElement.h"
#include "TProcessID.h"
#include "TFile.h"
#include "TMemberStreamer.h"
#include "TStreamer.h"
#include "Riostream.h"
#include <stdlib.h>
#include "TStreamerInfoActions.h"
#include "TSQLServer.h"
#include "TSQLResult.h"
#include "TSQLRow.h"
#include "TSQLStructure.h"
#include "TSQLObjectData.h"
#include "TSQLFile.h"
#include "TSQLClassInfo.h"

Include dependency graph for TBufferSQL2.cxx:

Macros
#define	FLong64   "%lld"
#define	FULong64   "%llu"
#define	SQLReadArrayCompress(vname, arrsize)
#define	SQLReadArrayContent(vname, arrsize, withsize)
#define	SQLReadArrayUncompress(vname, arrsize)
#define	SQLWriteArrayCompress(vname, arrsize)
#define	SQLWriteArrayContent(vname, arrsize, withsize)
#define	SQLWriteArrayNoncompress(vname, arrsize)
#define	TBufferSQL2_operatorin(vname)
#define	TBufferSQL2_operatorout(vname)
#define	TBufferSQL2_ReadArray(tname, vname)
#define	TBufferSQL2_ReadFastArray(vname)
#define	TBufferSQL2_ReadStaticArray(vname)
#define	TBufferSQL2_WriteArray(vname)
#define	TBufferSQL2_WriteFastArray(vname)

Macro Definition Documentation

FLong64

#define FLong64   "%lld"

Definition at line 59 of file TBufferSQL2.cxx.

FULong64

#define FULong64   "%llu"

Definition at line 60 of file TBufferSQL2.cxx.

SQLReadArrayCompress

#define SQLReadArrayCompress	(		vname,
			arrsize
	)

Value:

{                                                                    \
      while(indx<arrsize) {                                             \
         const char* name = fCurrentData->GetBlobPrefixName();          \
         Int_t first, last, res;                                        \
         if (strstr(name,sqlio::IndexSepar)==0) {                       \
            res = sscanf(name,"[%d", &first); last = first;             \
         } else res = sscanf(name,"[%d..%d", &first, &last);            \
         if (gDebug>5) std::cout << name << " first = " << first << " last = " << last << " res = " << res << std::endl; \
         if ((first!=indx) || (last<first) || (last>=arrsize)) {        \
            Error("SQLReadArrayCompress","Error reading array content %s", name); \
            fErrorFlag = 1;                                             \
            break;                                                      \
         }                                                              \
         SqlReadBasic(vname[indx]); indx++;                             \
         while(indx<=last)                                              \
            vname[indx++] = vname[first];                               \
      }                                                                 \
   }

Definition at line 1017 of file TBufferSQL2.cxx.

SQLReadArrayContent

#define SQLReadArrayContent	(		vname,
			arrsize,
			withsize
	)

Value:

{                                                                    \
      if (gDebug>3) std::cout << "SQLReadArrayContent  " << (arrsize) << std::endl; \
      PushStack()->SetArray(withsize ? arrsize : -1);                   \
      Int_t indx = 0;                                                   \
      if (fCurrentData->IsBlobData())                                   \
         SQLReadArrayCompress(vname, arrsize)                           \
         else                                                           \
            SQLReadArrayUncompress(vname, arrsize)                      \
               PopStack();                                              \
      if (gDebug>3) std::cout << "SQLReadArrayContent done " << std::endl;        \
   }

Definition at line 1039 of file TBufferSQL2.cxx.

SQLReadArrayUncompress

#define SQLReadArrayUncompress	(		vname,
			arrsize
	)

Value:

{                                            \
      while(indx<arrsize)                       \
         SqlReadBasic(vname[indx++]);           \
   }

Definition at line 1010 of file TBufferSQL2.cxx.

SQLWriteArrayCompress

#define SQLWriteArrayCompress	(		vname,
			arrsize
	)

Value:

{                                                                    \
      Int_t indx = 0;                                                   \
      while(indx<arrsize) {                                             \
         Int_t curr = indx; indx++;                                     \
         while ((indx<arrsize) && (vname[indx]==vname[curr])) indx++;   \
         SqlWriteBasic(vname[curr]);                                    \
         Stack()->ChildArrayIndex(curr, indx-curr);                     \
      }                                                                 \
   }

Definition at line 1669 of file TBufferSQL2.cxx.

SQLWriteArrayContent

#define SQLWriteArrayContent	(		vname,
			arrsize,
			withsize
	)

Value:

{                                                    \
      PushStack()->SetArray(withsize ? arrsize : -1);   \
      if (fCompressLevel>0) {                           \
         SQLWriteArrayCompress(vname, arrsize)          \
            } else {                                    \
         SQLWriteArrayNoncompress(vname, arrsize)       \
            }                                           \
      PopStack();                                       \
   }

Definition at line 1680 of file TBufferSQL2.cxx.

SQLWriteArrayNoncompress

#define SQLWriteArrayNoncompress	(		vname,
			arrsize
	)

Value:

{                                                    \
      for(Int_t indx=0;indx<arrsize;indx++) {           \
         SqlWriteBasic(vname[indx]);                    \
         Stack()->ChildArrayIndex(indx, 1);             \
      }                                                 \
   }

Definition at line 1660 of file TBufferSQL2.cxx.

TBufferSQL2_operatorin

#define TBufferSQL2_operatorin

(

vname

)

Value:

{                                            \
      SqlReadBasic(vname);                      \
   }

Definition at line 2105 of file TBufferSQL2.cxx.

TBufferSQL2_operatorout

#define TBufferSQL2_operatorout

(

vname

)

Value:

{                                            \
      SqlWriteBasic(vname);                     \
   }

Definition at line 2256 of file TBufferSQL2.cxx.

TBufferSQL2_ReadArray

#define TBufferSQL2_ReadArray	(		tname,
			vname
	)

Value:

{                                            \
      Int_t n = SqlReadArraySize();             \
      if (n<=0) return 0;                       \
      if (!vname) vname = new tname[n];         \
      SQLReadArrayContent(vname, n, kTRUE);     \
      return n;                                 \
   }

Definition at line 1053 of file TBufferSQL2.cxx.

TBufferSQL2_ReadFastArray

#define TBufferSQL2_ReadFastArray

(

vname

)

Value:

{                                                                    \
      if (n<=0) return;                                                 \
      TStreamerElement* elem = Stack(0)->GetElement();                  \
      if ((elem!=0) && (elem->GetType()>TStreamerInfo::kOffsetL) &&     \
          (elem->GetType()<TStreamerInfo::kOffsetP) &&                  \
          (elem->GetArrayLength()!=n)) fExpectedChain = kTRUE;          \
      if (fExpectedChain) {                                             \
         fExpectedChain = kFALSE;                                       \
         Int_t startnumber = Stack(0)->GetElementNumber();              \
         TStreamerInfo* info = Stack(1)->GetStreamerInfo();             \
         Int_t index = 0;                                               \
         while (index<n) {                                              \
            elem = (TStreamerElement*)info->GetElements()->At(startnumber++); \
            if (index>1) { PopStack(); WorkWithElement(elem, elem->GetType()); } \
            if (elem->GetType()<TStreamerInfo::kOffsetL) {              \
               SqlReadBasic(vname[index]);                              \
               index++;                                                 \
            } else {                                                    \
               Int_t elemlen = elem->GetArrayLength();                  \
               SQLReadArrayContent((vname+index), elemlen, kFALSE);     \
               index+=elemlen;                                          \
            }                                                           \
         }                                                              \
      } else {                                                          \
         SQLReadArrayContent(vname, n, kFALSE);                         \
      }                                                                 \
   }

Definition at line 1386 of file TBufferSQL2.cxx.

TBufferSQL2_ReadStaticArray

#define TBufferSQL2_ReadStaticArray

(

vname

)

Value:

{                                            \
      Int_t n = SqlReadArraySize();             \
      if (n<=0) return 0;                       \
      if (!vname) return 0;                     \
      SQLReadArrayContent(vname, n, kTRUE);     \
      return n;                                 \
   }

Definition at line 1255 of file TBufferSQL2.cxx.

TBufferSQL2_WriteArray

#define TBufferSQL2_WriteArray

(

vname

)

Value:

{                                            \
      SQLWriteArrayContent(vname, n, kTRUE);    \
   }

Definition at line 1692 of file TBufferSQL2.cxx.

TBufferSQL2_WriteFastArray

#define TBufferSQL2_WriteFastArray

(

vname

)

Value:

{                                                                    \
      if (n<=0) return;                                                 \
      TStreamerElement* elem = Stack(0)->GetElement();                  \
      if ((elem!=0) && (elem->GetType()>TStreamerInfo::kOffsetL) &&     \
          (elem->GetType()<TStreamerInfo::kOffsetP) &&                  \
          (elem->GetArrayLength()!=n)) fExpectedChain = kTRUE;          \
      if (fExpectedChain) {                                             \
         TStreamerInfo* info = Stack(1)->GetStreamerInfo();             \
         Int_t startnumber = Stack(0)->GetElementNumber();              \
         Int_t index = 0;                                               \
         while (index<n) {                                              \
            elem = (TStreamerElement*)info->GetElements()->At(startnumber++); \
            if (index>0) { PopStack(); WorkWithElement(elem, elem->GetType()); } \
            if (elem->GetType()<TStreamerInfo::kOffsetL) {              \
               SqlWriteBasic(vname[index]);                             \
               index++;                                                 \
            } else {                                                    \
               Int_t elemlen = elem->GetArrayLength();                  \
               SQLWriteArrayContent((vname+index), elemlen, kFALSE);    \
               index+=elemlen;                                          \
            }                                                           \
            fExpectedChain = kFALSE;                                    \
         }                                                              \
      } else {                                                          \
         SQLWriteArrayContent(vname, n, kFALSE);                        \
      }                                                                 \
   }

Definition at line 1819 of file TBufferSQL2.cxx.