DbiSqlValPacket.h

Go to the documentation of this file.

#ifndef DBISQLVALPACKET
#define DBISQLVALPACKET

#include <fstream>
#include <list>
#include <vector>
#include <string>
#include "DatabaseInterface/Dbi.h"
#include "DatabaseInterface/DbiTableProxy.h"
using std::string;

#if !defined(__CINT__) || defined(__MAKECINT__)
#include "Rtypes.h"
#endif

#include "Context/TimeStamp.h"

class DbiTableRow;
class DbiValidityRec;
class ContextRange;

class DbiSqlValPacket
{

public:

// Types and enum

  typedef enum ECompResult {
    kIdentical,
    kUpdate,
    kOutOfDate,
    kConflict 
  } CompResult_t;

// Constructors and destructors.
           DbiSqlValPacket();
           DbiSqlValPacket(std::ifstream& is);
           DbiSqlValPacket(const DbiValidityRec& vrec);
  virtual ~DbiSqlValPacket();

// State testing member functions
        Bool_t CanBeStored() const { 
             return (fSeqNo > 0 && fNumErrors == 0 && this->GetNumSqlStmts()> 0)
            ? kTRUE : kFALSE; };
  CompResult_t Compare(const DbiSqlValPacket& that,
                       Bool_t log = kFALSE,
                       const Char_t* thisName = "this",
                       const Char_t* thatName = "that" ) const;
        Bool_t CreateTable(UInt_t dbNo) const;
        UInt_t GetNumErrors() const { return fNumErrors; }
        UInt_t GetNumSqlStmts() const { return fNumStmts; }
        UInt_t GetSeqNo() const { return fSeqNo; }
  TimeStamp GetVersionDate() const { return fVersionDate; }
        string GetStmt(UInt_t stmtNo) const;
        std::vector<string> GetStmtValues(UInt_t stmtNo) const;
 const string& GetTableName() const{ return fTableName; }
        Bool_t IsEqual(const DbiSqlValPacket& that,
                       Bool_t log = kFALSE,
                       const Char_t* thisName = "this",
                       const Char_t* thatName = "that" ) const;

//  I/O
        Bool_t Fill(std::ifstream& is);
        Bool_t Store(UInt_t dbNo, Bool_t replace = kFALSE) const;
        Bool_t Write(std::ofstream& ios,
                     Bool_t addMetadata = kFALSE) const;

//  Reconstruct.        
          void Recreate(const string& tableName,
                        const ContextRange& vr,
                        Int_t aggNo,
                        Dbi::SubSite subsite = 0,
                        Dbi::Task task = 0,
                        TimeStamp versionDate = TimeStamp());
        Bool_t AddDataRow(const DbiTableProxy& tblProxy,
                          const DbiValidityRec* vrec,
                          const DbiTableRow& row);

//  State changing member functions
          void Clear() { this->Reset(); fNumErrors = 0; }
          void SetVersionDate(TimeStamp ts);
          void SetSeqNo(UInt_t seqno);
          void Reset();  //Doesn't clear fNumErrors.

  virtual void Print(Option_t *option="") const;

protected:

private:  
          void AddRow(const string & row);
        Bool_t AddRow(const DbiTableProxy& tblProxy,
                      const DbiValidityRec* vrec,
                      const DbiTableRow& row);
          void Report(const char* msg, 
                      UInt_t line_num,
                      const string& line);
          void SetMetaData() const;
          void SetSeqNoOnRow(string& row,const string& seqno);

          static Bool_t fgLastMetaHadRowCounter;  // Ugly hack during transition to ROW_COUNTER tables.
  DbiSqlValPacket(const DbiSqlValPacket& );  // Not allowed.


// Data members

  UInt_t fNumErrors;         

  UInt_t fSeqNo;             

  mutable string fSqlMySqlMetaMain;  

  mutable string fSqlMySqlMetaVld;   

  std::list<string>  fSqlStmts;          

  UInt_t fNumStmts;          

  string fTableName;         

  TimeStamp fVersionDate;      

 // Removed: ClassDef(DbiSqlValPacket,0)           // SQL to generate Validity Packet.

};
#endif  // DBISQLVALPACKET