DbiDBProxy.h

Go to the documentation of this file.

#ifndef DBIDBPROXY_H
#define DBIDBPROXY_H

#include <string>
using std::string;
#include <list>
#include <vector>

#include "DatabaseInterface/Dbi.h"

class DbiCascader;
class DbiResultSet;
class DbiTableMetaData;
class DbiTableProxy;
class Context;
class TimeStamp;
class DbiValidityRec;

class DbiDBProxy
{

public:

#ifndef __CINT__
typedef const std::vector<UInt_t> SeqList_t;
#endif

// Constructors.
           DbiDBProxy(DbiCascader& cascader, 
                      const string& tableName,
                      const DbiTableMetaData* metaData,
                      const DbiTableMetaData* metaValid,
                      const DbiTableProxy* tableProxy);
  virtual ~DbiDBProxy();

// State testing member functions
              UInt_t GetNumDb() const;
       const string& GetTableName() const { return fTableName; }
const DbiTableProxy* GetTableProxy() const { return fTableProxy; }
                void StoreMetaData(DbiTableMetaData& metaData) const;
              Bool_t TableExists() const;

// Query (input) member functions

           UInt_t FindSeqNoWithVersionDate( const TimeStamp& versionDate,
                                             const DbiValidityRec& vrec,
                                             UInt_t dbNo,
                                             UInt_t uniqingSiteMask=0,
                                             UInt_t uniqingSimMask=0,
                                             UInt_t excludingSeqno=0,
                                             UInt_t useTimeGate=0,
                                             Bool_t count=false
                                           ) const ;

           UInt_t FindSeqNoWithVersionDate( const TimeStamp& versionDate,
                                            const Context& vc, 
                                            const Dbi::SubSite& subsite,
                                            const Dbi::Task& task,
                                            UInt_t dbNo,
                                            UInt_t uniqingSiteMask,
                                            UInt_t uniqingSimMask,
                                            UInt_t excludingSeqno,
                                            UInt_t useTimeGate,
                                            Bool_t count
                                          ) const ;


           void FindTimeBoundaries(const Context& vc, 
                                   const Dbi::SubSite& subsite,
                                   const Dbi::Task& task,
                                   UInt_t dbNo,
                                   TimeStamp earliestCreate,
                                   TimeStamp& start,
                                   TimeStamp& end) const;
  DbiResultSet* QueryAllValidities(UInt_t dbNo,UInt_t seqNo=0) const;
  DbiResultSet* QuerySeqNo(UInt_t seqNo,UInt_t dbNo) const;
#ifndef __CINT__

  DbiResultSet* QuerySeqNos(SeqList_t& seqNos,
                            UInt_t dbNo,
                            const string& sqlData = "",
                            const string& fillOpts = "") const;
#endif
  DbiResultSet* QueryValidity(const Context& vc, 
                              const Dbi::SubSite& subsite,
                              const Dbi::Task& task,
                              UInt_t dbNo) const;
  DbiResultSet* QueryValidity(const string& context, 
                              const Dbi::SubSite& subsite,
                              const Dbi::Task& task,
                              UInt_t dbNo) const;
  DbiResultSet* QueryValidity(UInt_t seqNo,
                              UInt_t dbNo) const;

// Store (output) member functions
         Bool_t ReplaceInsertDate(const TimeStamp& ts,
                                  UInt_t SeqNo,
                                  UInt_t dbNo) const;
         Bool_t RemoveSeqNo(UInt_t seqNo,
                            UInt_t dbNo) const;
         Bool_t ReplaceSeqNo(UInt_t oldSeqNo,
                             UInt_t newSeqNo,
                             UInt_t dbNo) const;

// State changing member functions
           void SetSqlCondition(const string& sql) { 
                                                  fSqlCondition = sql; }

           void SetExtraOrdering(const string& sql) { 
                                                  fExtraOrdering = sql; }
// Getters

           string GetSqlCondition(){ return fSqlCondition ; }

           string GetExtraOrdering(){ return fExtraOrdering ; }


private:

   Bool_t ReplaceSeqNoOracle(UInt_t oldSeqNo,
                             UInt_t newSeqNo,
                             UInt_t dbNo) const;
// Disabled (not implemented) copy constructor and asignment.

 DbiDBProxy(const DbiDBProxy&);
 DbiDBProxy& operator=(const DbiDBProxy&);

// Data members
 
  DbiCascader& fCascader;    

  const DbiTableMetaData* fMetaData;

  const DbiTableMetaData* fMetaValid; 

  string fSqlCondition;

  string fTableName; 

   const DbiTableProxy* fTableProxy;

  string fVldSuffix;

  string fExtraOrdering ;

// Removed: ClassDef(DbiDBProxy,0)     //  Proxy for physical database.

};

#endif  // DBIDBPROXY_H