DbiConnection.h

Go to the documentation of this file.

#ifndef DBICONNECTION
#define DBICONNECTION



#include <string>

#ifndef ROOT_Rtypes
#if !defined(__CINT__) || defined(__MAKECINT__)
#include "Rtypes.h"
#endif
#endif
#include "TSQLServer.h"
#include "TSQLStatement.h"
#include "TUrl.h"

#include "DatabaseInterface/Dbi.h"
#include "DatabaseInterface/DbiExceptionLog.h"

class DbiConnection
{

public:

// Constructors and destructors.
           DbiConnection(const std::string& url = "",
                         const std::string& user = "",
                         const std::string& password = "");
  virtual ~DbiConnection();

// State testing member functions

// Standard getters.

    const std::string& GetDbName() const { return fDbName; }
          Dbi::DbTypes GetDbType() const { return fDbType; }
    const std::string& GetPassword() const { return fPassword; }
    const std::string& GetUrl() const;
    const std::string& GetUser() const { return fUser; }
                Bool_t IsClosed() const { return ! fServer; }
                Bool_t IsTemporary() const { return fIsTemporary; }
                Bool_t TableExists(const std::string& tableName) const;

// Exception log handling

  const DbiExceptionLog& GetExceptionLog() const { return fExceptionLog; }
  void ClearExceptionLog() { fExceptionLog.Clear(); }

  Bool_t PrintExceptionLog(Int_t level = 3) const;

  void RecordException();

// State changing member functions

  void SetTableExists(const std::string& tableName = ""); 

// Idle connnection management

  void Connect()    { this->ConnectStatement(); }
  void DisConnect() { this->DisConnectStatement(); }

  void ConnectStatement() { ++fNumConnectedStatements; }
  void DisConnectStatement() {
       --fNumConnectedStatements;
      if ( ! fNumConnectedStatements ) this->CloseIdleConnection(); }
  void SetPermanent(Bool_t permanent = true) { fIsTemporary = ! permanent; }


  Bool_t Close(Bool_t force = false);
  Bool_t Open();

  TSQLServer* GetServer();

  TSQLStatement* CreatePreparedStatement(const std::string& sql);

private:  

  void CloseIdleConnection();


// Data members

  std::string fDbName;

    std::string fExistingTableList;

  TUrl fUrl;

  std::string fUser;

  std::string fPassword;

  Bool_t fUrlValidated;

  Int_t fNumConnectedStatements;
                                 
  Bool_t fIsTemporary;  

  TSQLServer* fServer;   

  DbiExceptionLog fExceptionLog;

  Dbi::DbTypes fDbType;

 ClassDef(DbiConnection,0)     // Managed TSQLServer

};


#endif // DBICONNECTION

---