DbiValidityRec.h

Go to the documentation of this file.

#ifndef DBIVALIDITYREC_H
#define DBIVALIDITYREC_H

#include "DatabaseInterface/Dbi.h"
#include "DatabaseInterface/DbiTableRow.h"
#include "Context/ContextRange.h"
#include "Context/TimeStamp.h"

#include <iosfwd>
#include <string>

class DbiBinaryFile;
class DbiTableProxy;
class DbiValidityRec;

ostream& operator<<(ostream& s, const DbiValidityRec& vRec);    

class DbiValidityRec : public DbiTableRow
{


public:

// Constructors and destructors.
           DbiValidityRec(Int_t dbNo = -1, Bool_t isGap = kTRUE);
           DbiValidityRec(const DbiValidityRec& from);
           DbiValidityRec(const ContextRange& range,
                          Dbi::SubSite subsite,
                          Dbi::Task task,
                          Int_t aggNo,
                          UInt_t seqNo,
                          Int_t dbNo = -1,
                          Bool_t isGap = kFALSE,
                          TimeStamp time = TimeStamp());
  virtual ~DbiValidityRec();

// State testing member functions

  virtual DbiTableRow* CreateTableRow() const {
                                           return new DbiValidityRec; }
                 Int_t GetAggregateNo() const { return fAggregateNo; }
             TimeStamp GetVersionDate() const { return fVersionDate; }
                UInt_t GetDbNo() const { return fDbNo; }
             TimeStamp GetInsertDate() const { return fInsertDate; }
          Dbi::SubSite GetSubSite() const { return fSubSite; }
             Dbi::Task GetTask() const { return fTask; }
           std::string GetL2CacheName() const;
                UInt_t GetSeqNo() const { return fSeqNo; }
  const DbiTableProxy* GetTableProxy() const { return fTableProxy; }
   const ContextRange& GetContextRange() const { return fContextRange;}
                Bool_t HasExpired(const DbiValidityRec& other) const;
                Bool_t HasExpired(const Context& vc,
                                  const Dbi::SubSite& subsite,
                                  const Dbi::Task& task ) const;
               Bool_t IsCompatible(const Context& vc,
                                  const Dbi::SubSite& subsite,
                                  const Dbi::Task& task ) const;
                Bool_t IsGap() const { return fIsGap; }

static     std::string GetL2CacheName(UInt_t seqLo, UInt_t seqHi, TimeStamp ts);

// State changing member functions
        void AndTimeWindow(const TimeStamp& start,
                           const TimeStamp& end);
        void SetAggregateNo(Int_t aggNo) { fAggregateNo = aggNo; }
        void SetDbNo(Int_t dbNo) { fDbNo = dbNo; }
        void SetTableProxy(const DbiTableProxy* tp) { fTableProxy = tp; }
        void SetTimeWindow(const TimeStamp& start,
                           const TimeStamp& end);
        void SetContextRange(const ContextRange& range) { fContextRange=range;}
        void Trim(const TimeStamp& queryTime,
                  const DbiValidityRec& other);

// I/O  member functions
  virtual void Fill(DbiResultSet& rs,
                    const DbiValidityRec* vrec);
  virtual void Store(DbiOutRowStream& ors,
                    const DbiValidityRec* vrec) const;
          void Streamer(DbiBinaryFile& file);

private:  

// Data members


  Int_t fAggregateNo;

  TimeStamp fVersionDate;

  Int_t fDbNo;  

  TimeStamp fInsertDate; 

    Bool_t fIsGap;

  Dbi::SubSite fSubSite;

  Dbi::Task fTask;

  Int_t fSeqNo;

  const DbiTableProxy* fTableProxy;

  ContextRange fContextRange;

// Removed: ClassDef(DbiValidityRec,0)  // Validity range table row. 

};


#endif  // DBIVALIDITYREC_H