IOVDbConn Class Reference

#include <IOVDbConn.h>

Collaboration diagram for IOVDbConn:

Public Member Functions
	IOVDbConn (const std::string &dbname, const bool readOnly, MsgStream &msg)
	~IOVDbConn ()
bool	isActive () const
bool	isReadOnly () const
bool	aborted () const
unsigned int	nFolders () const
const std::string &	name () const
void	incUsage ()
void	decUsage ()
void	summary (const float fread)
cool::IDatabasePtr	getCoolDb ()
CoraCoolDatabasePtr	getCoraCoolDb ()
void	setInactive ()
void	setReadOnly (const bool readOnly)
bool	open ()
void	close ()
bool	dropAndReconnect ()
bool	valid () const
template<typename T = cool::IFolderPtr>
T	getFolderPtr (const std::string &folderName)
template<>
CoraCoolFolderPtr	getFolderPtr (const std::string &folderName)

Private Attributes
MsgStream &	m_log
bool	m_active
bool	m_readonly
bool	m_abort
unsigned int	m_nconn
unsigned int	m_nfolder
const std::string	m_connstr
cool::IDatabasePtr	m_coolDb
CoraCoolDatabasePtr	m_coracoolDb

Detailed Description

Definition at line 18 of file IOVDbConn.h.

Constructor & Destructor Documentation

IOVDbConn()

IOVDbConn::IOVDbConn	(	const std::string &	dbname,
		const bool	readOnly,
		MsgStream &	msg
	)

Definition at line 17 of file IOVDbConn.cxx.

                                      :
  m_log(msg),
  m_active(false),
  m_readonly(readOnly),
  m_abort(false),
  m_nconn(0),
  m_nfolder(0),
  m_connstr(dbname){
   //nop
}

~IOVDbConn()

IOVDbConn::~IOVDbConn ( )

default

Member Function Documentation

aborted()

bool IOVDbConn::aborted ( ) const

inline

Definition at line 66 of file IOVDbConn.h.

{return m_abort; }

close()

void IOVDbConn::close

(

)

Definition at line 80 of file IOVDbConn.cxx.

                {
  setInactive();
}

decUsage()

void IOVDbConn::decUsage ( )

inline

Definition at line 74 of file IOVDbConn.h.

{ --m_nfolder; }

dropAndReconnect()

bool IOVDbConn::dropAndReconnect

(

)

Definition at line 85 of file IOVDbConn.cxx.

                           {
  bool success{};
  try {
    setInactive();
    success = open();
  } catch (std::exception& e) {
    m_log << MSG::WARNING << "Exception from disconnect/reconnect: " <<e.what() << endmsg;
    // try once more to connect
    try {
      success = open();
    } catch (std::exception& e) {
      m_log << MSG::ERROR << "Cannot reconnect to database:" << e.what()<< endmsg;
    }
  }
  return success;
}

getCoolDb()

cool::IDatabasePtr IOVDbConn::getCoolDb

(

)

Definition at line 31 of file IOVDbConn.cxx.

                                      {
  // only open if not already activated
  if (not m_coolDb.get()) {
    // check connection not already aborted
    if (m_abort) {
      m_log << MSG::ERROR << "COOL connection for " << m_connstr << " already aborted as invalid" << endmsg;
      // in this case, return the null connection ptr immediately to avoid
      // another full attempt to connect
      return m_coolDb;
    }
    // open new connection
    m_log << MSG::INFO << "Opening COOL connection for " << m_connstr << endmsg;
    ++m_nconn;
    cool::IDatabaseSvc& dbSvc = cool::DatabaseSvcFactory::databaseService();
    try {
      m_coolDb = dbSvc.openDatabase(m_connstr, m_readonly);
      m_active = true;
    } catch (std::exception& e) {
      // create a new COOL conditions DB
      if (!m_readonly) {
        m_log << MSG::INFO << "*** COOL  exception caught: " << e.what() << endmsg;
        m_log << MSG::INFO << "Create a new conditions database: " << m_connstr << endmsg;
        try {
          m_coolDb = dbSvc.createDatabase(m_connstr);
          m_active = true;
        } catch (std::exception& e) {
          m_log << MSG::ERROR << "*** COOL  exception caught: " << e.what() << endmsg;
          m_log << MSG::ERROR << "Could not create a new conditions database - abort connection" << endmsg;
          m_abort = true;
          m_coolDb.reset();
        }
      } else { //read-only-case:
        m_log << MSG::ERROR << "*** COOL  exception caught: " << e.what() << endmsg;
        m_log << MSG::ERROR << "*** Cannot open database connection [" << m_connstr << "] in " << (m_readonly ? "readonly" : "writing") << " mode - abort connection" << endmsg;
        m_abort = true;
        m_coolDb.reset();
      }
    }// end catch
  }
  return m_coolDb;
}

getCoraCoolDb()

CoraCoolDatabasePtr IOVDbConn::getCoraCoolDb

(

)

Definition at line 102 of file IOVDbConn.cxx.

                                             {
  // only open if not already activated
  if (not m_coracoolDb.get()) {
    // open new connection
    m_log << MSG::INFO << "Opening CoraCool connection for " << m_connstr << endmsg;
    coral::ConnectionService connSvc;
    m_coracoolDb=CoraCoolDatabasePtr(new CoraCoolDatabase(m_connstr,m_coolDb,connSvc,m_readonly));
    m_coracoolDb->connect();
  }
  return m_coracoolDb;
}

getFolderPtr() [1/2]

template<typename T = cool::IFolderPtr>

T IOVDbConn::getFolderPtr ( const std::string &  folderName )

inline

Definition at line 43 of file IOVDbConn.h.

                                           {
    if (not m_coolDb.get()) return nullptr;
    return m_coolDb->getFolder(folderName);
  }

getFolderPtr() [2/2]

template<>

CoraCoolFolderPtr IOVDbConn::getFolderPtr ( const std::string &  folderName )

inline

Definition at line 78 of file IOVDbConn.h.

                                                  {
  if (not m_coracoolDb.get()) return nullptr;
  return m_coracoolDb->getFolder(folderName);
}

incUsage()

void IOVDbConn::incUsage ( )

inline

Definition at line 72 of file IOVDbConn.h.

{ ++m_nfolder; }

isActive()

bool IOVDbConn::isActive ( ) const

inline

Definition at line 62 of file IOVDbConn.h.

{ return m_active; }

isReadOnly()

bool IOVDbConn::isReadOnly ( ) const

inline

Definition at line 64 of file IOVDbConn.h.

{return m_readonly; }

name()

const std::string & IOVDbConn::name ( ) const

inline

Definition at line 70 of file IOVDbConn.h.

{ return m_connstr; }

nFolders()

unsigned int IOVDbConn::nFolders ( ) const

inline

Definition at line 68 of file IOVDbConn.h.

{return m_nfolder; }

open()

bool IOVDbConn::open

(

)

Definition at line 74 of file IOVDbConn.cxx.

               {
  m_coolDb = getCoolDb();
  return valid();
}

setInactive()

void IOVDbConn::setInactive

(

)

Definition at line 114 of file IOVDbConn.cxx.

                            {
  if (m_coolDb.get()) {
    m_log << MSG::INFO << "Disconnecting from " << m_connstr << endmsg;
    try {
      m_coolDb->closeDatabase();
    } catch (std::exception& e) {
      m_log << MSG::INFO << "Exception caught when disconnecting: " <<e.what() << endmsg;
    }
    m_coolDb.reset();
  }
  if (m_coracoolDb.get()) {
    m_log << MSG::INFO << "Disconnecting CoraCool from " << m_connstr << endmsg;
    try { 
      m_coracoolDb->disconnect();
    } catch (std::exception& e) {
      m_log << MSG::INFO << "Exception caught when disconnecting CoraCool: "<< e.what() << endmsg;
    }
    m_coracoolDb.reset();
  }
  m_active=false;
}

setReadOnly()

void IOVDbConn::setReadOnly

(

const bool

readOnly

)

Definition at line 136 of file IOVDbConn.cxx.

                                               {
  // reset readonly state, assuming different from current one
  // close current connection if required
  setInactive();
  m_readonly=readOnly;
}

summary()

void IOVDbConn::summary

(

const float

fread

)

Definition at line 143 of file IOVDbConn.cxx.

                                         {
  // print summary of usage
  m_log << MSG::INFO << "Connection " << m_connstr << " : nConnect: " <<
    m_nconn << " nFolders: " << m_nfolder <<  " ReadTime: (( " << std::fixed <<
    std::setw(8) << std::setprecision(2) << fread << " ))s" << endmsg;
}

valid()

bool IOVDbConn::valid ( ) const

inline

Definition at line 60 of file IOVDbConn.h.

{ return m_coolDb.get()!=0; }

Member Data Documentation

m_abort

bool IOVDbConn::m_abort

private

Definition at line 52 of file IOVDbConn.h.

m_active

bool IOVDbConn::m_active

private

Definition at line 50 of file IOVDbConn.h.

m_connstr

const std::string IOVDbConn::m_connstr

private

Definition at line 55 of file IOVDbConn.h.

m_coolDb

cool::IDatabasePtr IOVDbConn::m_coolDb

private

Definition at line 56 of file IOVDbConn.h.

m_coracoolDb

CoraCoolDatabasePtr IOVDbConn::m_coracoolDb

private

Definition at line 57 of file IOVDbConn.h.

m_log

MsgStream& IOVDbConn::m_log

private

Definition at line 49 of file IOVDbConn.h.

m_nconn

unsigned int IOVDbConn::m_nconn

private

Definition at line 53 of file IOVDbConn.h.

m_nfolder

unsigned int IOVDbConn::m_nfolder

private

Definition at line 54 of file IOVDbConn.h.

m_readonly

bool IOVDbConn::m_readonly

private

Definition at line 51 of file IOVDbConn.h.

---

The documentation for this class was generated from the following files:

• IOVDbConn.h
• IOVDbConn.cxx