DbiValidityRec.h

Go to the documentation of this file.

#ifndef DBIVALIDITYREC_H
#define DBIVALIDITYREC_H

#include "DatabaseInterface/Dbi.h"
#include "DatabaseInterface/DbiTableRow.h"
#include "Validity/VldRange.h"
#include "Validity/VldTimeStamp.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 VldRange& range,
                          Dbi::Task task,
                          Int_t aggNo,
                          UInt_t seqNo,
                          Int_t dbNo = -1,
                          Bool_t isGap = kFALSE,
                          VldTimeStamp time = VldTimeStamp());
  virtual ~DbiValidityRec();

// State testing member functions

  virtual DbiTableRow* CreateTableRow() const {
                                           return new DbiValidityRec; }
                 Int_t GetAggregateNo() const { return fAggregateNo; }
          VldTimeStamp GetCreationDate() const { return fCreationDate; }
                UInt_t GetDbNo() const { return fDbNo; }
          VldTimeStamp GetInsertDate() const { return fInsertDate; }
             Dbi::Task GetTask() const { return fTask; }
           std::string GetL2CacheName() const;
                UInt_t GetSeqNo() const { return fSeqNo; }
  const DbiTableProxy* GetTableProxy() const { return fTableProxy; }
       const VldRange& GetVldRange() const { return fVldRange;}
                Bool_t HasExpired(const DbiValidityRec& other) const;
                Bool_t HasExpired(const VldContext& vc,
                                  const Dbi::Task& task) const;
               Bool_t IsCompatible(const VldContext& vc,
                                    const Dbi::Task& task) const;
                Bool_t IsGap() const { return fIsGap; }

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

// State changing member functions
        void AndTimeWindow(const VldTimeStamp& start,
                           const VldTimeStamp& 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 VldTimeStamp& start,
                           const VldTimeStamp& end);
        void SetVldRange(const VldRange& range) { fVldRange=range;}
        void Trim(const VldTimeStamp& 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;

  VldTimeStamp fCreationDate;

  Int_t fDbNo;  

  VldTimeStamp fInsertDate; 

    Bool_t fIsGap;

  Dbi::Task fTask;

  Int_t fSeqNo;

  const DbiTableProxy* fTableProxy;

  VldRange fVldRange;

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

};


#endif  // DBIVALIDITYREC_H

---