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 VldContext;
class VldTimeStamp;

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 fTableNameUc; }
const DbiTableProxy* GetTableProxy() const { return fTableProxy; }
                void StoreMetaData(DbiTableMetaData& metaData) const;
              Bool_t TableExists(Int_t selectDbNo=-1) const;

// Query (input) member functions
           void FindTimeBoundaries(const VldContext& vc, 
                                   const Dbi::Task& task,
                                   UInt_t dbNo,
                                   VldTimeStamp earliestCreate,
                                   VldTimeStamp& start,
                                   VldTimeStamp& 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 VldContext& vc, 
                              const Dbi::Task& task,
                              UInt_t dbNo) const;
  DbiResultSet* QueryValidity(const string& context, 
                              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 VldTimeStamp& 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; }

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; 

  string fTableNameUc; 

   const DbiTableProxy* fTableProxy;

  string fVldSuffix;

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

};

#endif  // DBIDBPROXY_H

---