DbiTableProxy.h

Go to the documentation of this file.

#ifndef DBITABLEPROXY_H
#define DBITABLEPROXY_H

#include <string>
#include <sstream>
using std::string;

#include "DatabaseInterface/Dbi.h"
#include "DatabaseInterface/DbiDBProxy.h"
#include "DatabaseInterface/DbiTableMetaData.h"
#include "DatabaseInterface/DbiValidityRec.h"
#include "Context/Context.h"
#include "Context/TimeStamp.h"

class DbiCache;
class DbiCascader;
class DbiResult;
class DbiTableProxyRegistry;
class DbiTableRow;
class DbiValidityRec;
class DbiValidityRecBuilder;

class DbiTableProxy
{

  friend class DbiTableProxyRegistry;    //Allow Resistry access to ctor/dtor.

public:

// State testing member functions
      const DbiDBProxy& GetDBProxy() const { return fDBProxy; }
           DbiCascader& GetCascader() { return *fCascader; }
const DbiTableMetaData& GetMetaData() const { return fMetaData; }
const DbiTableMetaData& GetMetaValid() const { return fMetaValid; }
                 string GetRowName() const { 
                      return fTableRow ? fTableRow->name() : "Unknown";}
                 string GetTableName() const { return fTableName;}
                 string GetExtraCondition() const { return fTableRow ? fTableRow->GetExtraCondition() : "" ; }
// State changing member functions
              DbiCache* GetCache() { return fCache;}

   // for efficient access to last validity in partial context
       const DbiValidityRecBuilder* MakeValidityRecBuilder(const string& context, 
                              const Dbi::SubSite& subsite,
                              const Dbi::Task& task);
       const DbiValidityRec* LastValidityRec( const string& context, 
                              const Dbi::SubSite& subsite,
                              const Dbi::Task& task);
       const DbiValidityRec* FirstValidityRec( const string& context, 
                              const Dbi::SubSite& subsite,
                              const Dbi::Task& task);
       const DbiValidityRec* ValidityRec( const string& context, 
                              const Dbi::SubSite& subsite,
                              const Dbi::Task& task,
                              Int_t n );

       const DbiResult* Query(const Context& vc, 
                              const Dbi::SubSite& subsite,
                              const Dbi::Task& task,
                              Bool_t findFullTimeWindow = true);
       const DbiResult* Query(const string& context, 
                              const Dbi::SubSite& subsite,
                              const Dbi::Task& task,
                              const string& data,
                              const string& fillOpts);
       const DbiResult* Query(UInt_t seqNo,UInt_t dbNo);
       const DbiResult* Query(const DbiValidityRec& vrec, 
                              Bool_t canReuse = kTRUE);
           TimeStamp QueryOverlayVersionDate(const DbiValidityRec& vrec,
                                             UInt_t dbNo,
                                             Bool_t timeStartFloored = kFALSE);
                   void RefreshMetaData(); 
                   void SetSqlCondition(const string& sql); 
                   void SetOverlayOffsetSeconds(UInt_t secs); 
                   UInt_t GetOverlayOffsetSeconds(); 
                 Bool_t TableExists() const { return fExists; }

protected:

// Constructors (protected because created and owned by DbiTableProxyRegistry).
           DbiTableProxy(DbiCascader* cascader, 
                         const string& tableName,
                         const string& vldSuffix,
                         const DbiTableRow* tableRow);
  virtual ~DbiTableProxy();

// State testing member functions

// State changing member functions

private:

// Disabled (not implemented) copy constructor and asignment.

 DbiTableProxy(const DbiTableProxy&);
 DbiTableProxy& operator=(const DbiTableProxy&);
  

// Level 2 (disk) cache management.
 Bool_t CanReadL2Cache() const;
 Bool_t CanWriteL2Cache() const;
 Bool_t RestoreFromL2Cache(const DbiValidityRecBuilder& builder);
 Bool_t SaveToL2Cache(const string& name, DbiResult& res);
 
// Data members (fMeta* must precede fDBProxy, it has to be created
//               first - see initialiser list)
 

  DbiCascader* fCascader;

  DbiTableMetaData fMetaData;
 
  DbiTableMetaData fMetaValid;

   Bool_t fCanL2Cache;

  DbiCache* fCache;

  DbiDBProxy fDBProxy;

  Bool_t fExists;

string  fTableName;
  
 DbiTableRow* fTableRow;

  UInt_t fOverlayOffsetSeconds ;

// Removed: ClassDef(DbiTableProxy,0)        // Object to query a specific table.

};


#endif  // DBITABLEPROXY_H