---

cond::Connection Class Reference

#include <CondCore/DBCommon/interface/Connection.h>

List of all members.

Public Member Functions
void	connect (cond::DBSession *session)
	pass on the connection service handle to the proxy, do not connect for real.
	Connection (const std::string &con, int connectionTimeout=0)
	Constructor. If connectionTimeout=0, the commit method will close the database connection; if connectionTimeout=-1, the connection is not closed untill explict user call of disconnect method; if connectionTimeout=n, the connection will be closed by the commit method that holds the closest value of n.
std::string	connectStr () const
	return connection string in use
CoralTransaction &	coralTransaction ()
	return handle to the underlying coral transaction
void	disconnect ()
	disconnect open connection by hand if connectionTimeout <0, otherwise, no real action taken
PoolTransaction &	poolTransaction ()
	return handle to the underlying pool transaction
	~Connection ()
	Destructor.
Private Attributes
std::string	m_con
coral::IConnectionService *	m_connectionServiceHandle
int	m_connectionTimeOut
std::vector < CoralConnectionProxy * >	m_coralConnectionPool
int	m_idleConnectionCleanupPeriod
std::vector < PoolConnectionProxy * >	m_poolConnectionPool

---

Detailed Description

Definition at line 26 of file Connection.h.

---

Constructor & Destructor Documentation

Connection::Connection	(	const std::string &	con,
		int	connectionTimeout = 0
	)

Constructor. If connectionTimeout=0, the commit method will close the database connection; if connectionTimeout=-1, the connection is not closed untill explict user call of disconnect method; if connectionTimeout=n, the connection will be closed by the commit method that holds the closest value of n.

Definition at line 10 of file Connection.cc.

References m_coralConnectionPool.

00011                                                    :
00012   m_con( con ),
00013   m_connectionTimeOut ( connectionTimeOut )
00014 {
00015   m_coralConnectionPool.reserve(10);
00016 }
cond::Connection::~Connection(){

Connection::~Connection

(

)

Destructor.

Definition at line 17 of file Connection.cc.

References disconnect().

                           {
  this->disconnect();
}

---

Member Function Documentation

void Connection::connect

(

cond::DBSession *

session

)

pass on the connection service handle to the proxy, do not connect for real.

This method must be called after

Definition at line 20 of file Connection.cc.

References cond::DBSession::configuration(), cond::SessionConfiguration::connectionConfiguration(), cond::DBSession::connectionService(), cond::ConnectionConfiguration::idleConnectionCleanupPeriod(), m_connectionServiceHandle, and m_idleConnectionCleanupPeriod.

Referenced by DTDBSession::connect(), popcon::L1RPCHwConfigSourceHandler::ConnectOnlineDB(), popcon::RPCEMapSourceHandler::ConnectOnlineDB(), CondBasicIter::create(), l1t::DataManager::DataManager(), cond::RDBMS::getDB(), DTCCBConfigHandler::getNewObjects(), PixelPopConCalibSourceHandler::getNewObjects_coral(), and cond::RDBMS::setLogger().

                                                    {
  m_connectionServiceHandle=&(session->connectionService());
  m_idleConnectionCleanupPeriod=session->configuration().connectionConfiguration()->idleConnectionCleanupPeriod();
}

std::string Connection::connectStr

(

)

const

return connection string in use

Definition at line 57 of file Connection.cc.

References m_con.

Referenced by cond::service::PoolDBOutputService::add(), and cond::service::PoolDBOutputService::createNewIOV().

                                {
  return m_con;
}

cond::CoralTransaction & Connection::coralTransaction

(

)

return handle to the underlying coral transaction

if first time, init everything, start timer if not first time,

Definition at line 29 of file Connection.cc.

References it, m_con, m_connectionServiceHandle, m_connectionTimeOut, m_coralConnectionPool, m_idleConnectionCleanupPeriod, me, and cond::CoralConnectionProxy::transaction().

Referenced by l1t::DataWriter::addMappings(), cond::CondDB::allTags(), popcon::L1RPCHwConfigSourceHandler::ConnectOnlineDB(), popcon::RPCEMapSourceHandler::ConnectOnlineDB(), CondBasicIter::create(), cond::service::PoolDBOutputService::createNewIOV(), l1t::DataManager::DataManager(), PoolDBESSource::fillRecordToIOVInfo(), l1t::DataWriter::findTokenForTag(), DTCCBConfigHandler::getNewObjects(), PixelPopConCalibSourceHandler::getNewObjects_coral(), cond::service::PoolDBOutputService::initDB(), cond::CondDB::iovToken(), l1t::DataReader::loadIntervals(), l1t::OMDSReader::OMDSReader(), and l1t::DataReader::payloadToken().

                                {
  if( !m_coralConnectionPool.empty() ){
    std::vector<cond::CoralConnectionProxy*>::iterator it;
    std::vector<cond::CoralConnectionProxy*>::iterator itEnd=m_coralConnectionPool.end();
    for( it=m_coralConnectionPool.begin(); it!=itEnd; ++it ){
      return static_cast<cond::CoralTransaction&>((*it)->transaction());
    }
  }
  cond::CoralConnectionProxy* me=new cond::CoralConnectionProxy(
             m_connectionServiceHandle,m_con,m_connectionTimeOut,m_idleConnectionCleanupPeriod);
  m_coralConnectionPool.push_back(me);
  return static_cast<cond::CoralTransaction&>( me->transaction() );
}

void Connection::disconnect

(

void

)

disconnect open connection by hand if connectionTimeout <0, otherwise, no real action taken

Definition at line 61 of file Connection.cc.

References it, m_coralConnectionPool, and m_poolConnectionPool.

Referenced by DTDBSession::disconnect(), popcon::RPCEMapSourceHandler::DisconnectOnlineDB(), popcon::L1RPCHwConfigSourceHandler::DisconnectOnlineDB(), cond::CondDB::operator=(), cond::CondDB::~CondDB(), ~Connection(), and l1t::DataManager::~DataManager().

                          {
  if(!m_coralConnectionPool.empty()){
    std::vector<cond::CoralConnectionProxy*>::iterator it;
    std::vector<cond::CoralConnectionProxy*>::iterator itEnd=m_coralConnectionPool.end();
    for( it=m_coralConnectionPool.begin(); it!=itEnd; ++it){
      if( *it!=0 ) {
        delete *it;
        *it=0;
      } 
    }
    m_coralConnectionPool.clear();
  }
  if(!m_poolConnectionPool.empty()){
    std::vector<cond::PoolConnectionProxy*>::iterator poolit;
    std::vector<cond::PoolConnectionProxy*>::iterator poolitEnd=m_poolConnectionPool.end();
    for( poolit=m_poolConnectionPool.begin(); poolit!=poolitEnd; ++poolit){
      if( *poolit!=0 ) {
        delete *poolit;
        *poolit=0;
      } 
    }
    m_poolConnectionPool.clear();
  }
}

cond::PoolTransaction & Connection::poolTransaction

(

)

return handle to the underlying pool transaction

Definition at line 44 of file Connection.cc.

References it, m_con, m_connectionServiceHandle, m_connectionTimeOut, m_idleConnectionCleanupPeriod, m_poolConnectionPool, me, and cond::PoolConnectionProxy::transaction().

Referenced by cond::service::PoolDBOutputService::add(), DTDBSession::connect(), CondBasicIter::create(), cond::service::PoolDBOutputService::createNewIOV(), cond::CondDB::iov(), cond::CondDB::iovWithLib(), popcon::PopConSourceHandler< DTT0 >::lastPayload(), l1t::DataReader::loadIntervals(), DataProxy< RecordT, DataT >::make(), DataProxy< IdealGeometryRecord, DDCompactView >::make(), cond::CondDB::payLoad(), l1t::DataReader::payloadToken(), l1t::DataReader::readKey(), l1t::DataReader::readPayload(), PoolDBESSource::setIntervalFor(), cond::service::PoolDBOutputService::tagInfo(), l1t::DataWriter::updateIOV(), l1t::DataWriter::writeKey(), l1t::DataWriter::writeKeyList(), and l1t::DataWriter::writePayload().

                               {
  if( !m_poolConnectionPool.empty() ){
    std::vector<cond::PoolConnectionProxy*>::iterator it;
    std::vector<cond::PoolConnectionProxy*>::iterator itEnd=m_poolConnectionPool.end();
    for( it=m_poolConnectionPool.begin(); it!=itEnd; ++it ){
      return static_cast<cond::PoolTransaction&>((*it)->transaction());
    }
  }
  cond::PoolConnectionProxy* me=new cond::PoolConnectionProxy(m_connectionServiceHandle,m_con,m_connectionTimeOut,m_idleConnectionCleanupPeriod); 
  m_poolConnectionPool.push_back(me);
  return static_cast<cond::PoolTransaction&>(me->transaction());
}

---

Member Data Documentation

std::string cond::Connection::m_con [private]

Definition at line 46 of file Connection.h.

Referenced by connectStr(), coralTransaction(), and poolTransaction().

coral::IConnectionService* cond::Connection::m_connectionServiceHandle [private]

Definition at line 51 of file Connection.h.

Referenced by connect(), coralTransaction(), and poolTransaction().

int cond::Connection::m_connectionTimeOut [private]

Definition at line 47 of file Connection.h.

Referenced by coralTransaction(), and poolTransaction().

std::vector<CoralConnectionProxy*> cond::Connection::m_coralConnectionPool [private]

Definition at line 50 of file Connection.h.

Referenced by Connection(), coralTransaction(), and disconnect().

int cond::Connection::m_idleConnectionCleanupPeriod [private]

Definition at line 48 of file Connection.h.

Referenced by connect(), coralTransaction(), and poolTransaction().

std::vector<PoolConnectionProxy*> cond::Connection::m_poolConnectionPool [private]

Definition at line 49 of file Connection.h.

Referenced by disconnect(), and poolTransaction().

---

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

• CondCore/DBCommon/interface/Connection.h
• CondCore/DBCommon/src/Connection.cc

---