DbiCascader.h

Go to the documentation of this file.

#ifndef DBICASCADER_H
#define DBICASCADER_H



#include <map>
#include <ostream>
using std::ostream;
#include <string>
using std::string;
#include <vector>
using std::vector;

#if !defined(__CINT__) || defined(__MAKECINT__)
#include "Rtypes.h"
#endif

#include "DatabaseInterface/DbiConnection.h"
#include "DatabaseInterface/DbiStatement.h"

class DbiCascader;
class TSQL_Statement;

class DbiCascader
{

  friend class DbiTableProxyRegistry;  //Only it can create
  friend ostream& operator<<(ostream& s, const DbiCascader& cascader);    

public:

  enum Status { kFailed, kClosed, kOpen };

// State testing member functions

// Cascade entry-specific getters.

 DbiStatement* CreateStatement(UInt_t dbNo) const;

const DbiConnection* 
               GetConnection(UInt_t dbNo) const;
      DbiConnection* 
               GetConnection(UInt_t dbNo) ;

        string GetDbName(UInt_t dbNo) const;
         Int_t GetDbNo(const string& dbName) const;
         Int_t GetStatus(UInt_t dbNo) const {
                 if ( dbNo >= GetNumDb() || ! fConnections[dbNo]  ) return kFailed;
                 return fConnections[dbNo]->IsClosed() ? kClosed : kOpen; } 
        string GetStatusAsString(UInt_t dbNo) const ;
        string GetURL(UInt_t dbNo) const {
                      return ( dbNo < GetNumDb() ) ? fConnections[dbNo]-> GetUrl(): ""; }
        Bool_t IsTemporaryTable(const string& tableName,
                                Int_t dbNo) const;
// Cascade-wide getters.

         Int_t AllocateSeqNo(const string& tableName,
                             Int_t requireGlobal = 0,
                             Int_t dbNo = 0) const;
         Int_t GetAuthorisingDbNo() const { return fGlobalSeqNoDbNo; }
        UInt_t GetNumDb() const {return fConnections.size();}
        Int_t  GetTableDbNo(const string& tableName, Int_t selectDbNo = -1) const;        
        Bool_t TableExists(const string& tableName, Int_t selectDbNo = -1) const { 
                            return this->GetTableDbNo(tableName,selectDbNo) >= 0; }

// State changing member functions

           Int_t CreateTemporaryTable(const string& tableName,
                                      const string& tableDescr);
           void HoldConnections();
           void ReleaseConnections();
           void SetPermanent(UInt_t dbNo);

           // NJT: Make this public.
           void SetAuthorisingEntry(Int_t entry) {fGlobalSeqNoDbNo = entry;}

protected:

private:  

     Int_t ReserveNextSeqNo(const string& tableName,
                            Bool_t isGlobal,
                            UInt_t dbNo) const;

// Constructors and destructors.
           DbiCascader();
  virtual ~DbiCascader();
DbiCascader(const DbiCascader&);  // Not implemented

// Data members

  Int_t fGlobalSeqNoDbNo;
                                
  vector<DbiConnection*> fConnections; 

  std::map<string,Int_t> fTemporaryTables;
                                

// Private Locker object

class Lock {

public:
       Lock(DbiStatement* stmtDB, const string& seqnoTable, const string& dataTable);
      ~Lock();

Bool_t IsLocked() const { return fLocked; }

private:

  void SetLock(Bool_t setting = kTRUE);

   DbiStatement* fStmt;            // Statement to be used to issue lock
          string fSeqnoTableName;  // The SEQNO table that is locked
          string fDataTableName;   // The data table that is locked
          Bool_t fLocked;          // Lock status

};

 // Removed: ClassDef(DbiCascader,0)     //A cascade of DbiConnectionss 

};


#endif  // DBISKEL_H