---

cond::ConnectionHandler Class Reference

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

List of all members.

Public Member Functions
void	connect (cond::DBSession *session)
	global connect delegate all the registered proxy to connect if timeOutInSec !=0, cleanup idle connections with given parameter
	ConnectionHandler ()
	contructor
void	disconnectAll ()
	manually disconnect all and clean the registry as well. Otherwise, all connections will be closed and cleaned in the destructor
Connection *	getConnection (const std::string &name)
	query connection
void	registerConnection (const std::string &userconnect, cond::DBSession &session, int timeOutInSec=0)
	register userconnection string. This method will translate the userconnect to the real connect using technology proxy. It also initialised the session for the given technology. timeout value can be -1,0 and n sec
void	registerConnection (const std::string &name, const std::string &con, int timeOutInSec=0)
	register connection with a given name and timeout value. timeout value can be -1,0 and n sec
void	removeConnection (const std::string &name)
	remove connection from connection pool
Static Public Member Functions
static ConnectionHandler &	Instance ()
Private Member Functions
	ConnectionHandler (ConnectionHandler &)
	hide copy constructor
ConnectionHandler &	operator= (const ConnectionHandler &)
	hide assign op
	~ConnectionHandler ()
	hide destructor
Private Attributes
std::map< std::string, cond::Connection * >	m_registry
	registry of real connection handles

---

Detailed Description

Definition at line 19 of file ConnectionHandler.h.

---

Constructor & Destructor Documentation

cond::ConnectionHandler::ConnectionHandler

(

)

[inline]

contructor

Definition at line 39 of file ConnectionHandler.h.

{}

cond::ConnectionHandler::ConnectionHandler

(

ConnectionHandler &

)

[private]

hide copy constructor

ConnectionHandler::~ConnectionHandler

(

)

[private]

hide destructor

Definition at line 89 of file ConnectionHandler.cc.

References disconnectAll(), and m_registry.

                                         {
  if( m_registry.size() != 0){
    this->disconnectAll();
  }
}

---

Member Function Documentation

void ConnectionHandler::connect

(

cond::DBSession *

session

)

global connect delegate all the registered proxy to connect if timeOutInSec !=0, cleanup idle connections with given parameter

Definition at line 69 of file ConnectionHandler.cc.

References it, and m_registry.

Referenced by cond::service::PoolDBOutputService::PoolDBOutputService().

                                                    {
  std::map<std::string,cond::Connection*>::iterator it;  
  std::map<std::string,cond::Connection*>::iterator itEnd=m_registry.end();
  for(it=m_registry.begin();it!=itEnd;++it){
    it->second->connect(session);
  }
}

void ConnectionHandler::disconnectAll

(

)

manually disconnect all and clean the registry as well. Otherwise, all connections will be closed and cleaned in the destructor

Definition at line 77 of file ConnectionHandler.cc.

References it, and m_registry.

Referenced by ~ConnectionHandler().

                                    {
  if( m_registry.size()==0 ) return;
  std::map<std::string,cond::Connection*>::iterator it;  
  std::map<std::string,cond::Connection*>::iterator itEnd=m_registry.end();
  for(it=m_registry.begin();it!=itEnd;++it){
    if(it->second!=0){
      delete it->second;
      it->second=0;
    }
  }
  m_registry.clear();
}

cond::Connection * ConnectionHandler::getConnection

(

const std::string &

name

)

query connection

Definition at line 95 of file ConnectionHandler.cc.

References it, and m_registry.

Referenced by cond::RDBMS::getDB(), cond::service::PoolDBOutputService::PoolDBOutputService(), and cond::RDBMS::setLogger().

                                                           {
  std::map<std::string,cond::Connection*>::iterator it=m_registry.find(name);
  if( it!=m_registry.end() ){
    return it->second;
  }
  return 0;
}

cond::ConnectionHandler & ConnectionHandler::Instance

(

)

[static]

Definition at line 46 of file ConnectionHandler.cc.

References me.

Referenced by PoolDBESSource::fillRecordToIOVInfo(), cond::RDBMS::getDB(), cond::service::PoolDBOutputService::initDB(), PoolDBESSource::PoolDBESSource(), cond::service::PoolDBOutputService::PoolDBOutputService(), PoolDBESSource::registerProxies(), PoolDBESSource::setIntervalFor(), and cond::RDBMS::setLogger().

                               {
  //std::cout<<"in ConnectionHandler::Instance"<<std::endl;
  /*if(!edmplugin::PluginManager::isAvailable()){
    edmplugin::PluginManager::Config config;
    const char* path = getenv("LD_LIBRARY_PATH");
    std::string spath(path? path: "");
    std::string::size_type last=0;
    std::string::size_type i=0;
    std::vector<std::string> paths;
    while( (i=spath.find_first_of(':',last))!=std::string::npos) {
      paths.push_back(spath.substr(last,i-last));
      last = i+1;
      //std::cout <<paths.back()<<std::endl;
    }
    paths.push_back(spath.substr(last,std::string::npos));
    config.searchPath(paths);
    edmplugin::PluginManager::configure(config);
  }
  */
  static cond::ConnectionHandler me;
  return me;
}

ConnectionHandler& cond::ConnectionHandler::operator=

(

const ConnectionHandler &

)

[private]

hide assign op

void ConnectionHandler::registerConnection	(	const std::string &	userconnect,
		cond::DBSession &	session,
		int	timeOutInSec = 0
	)

register userconnection string. This method will translate the userconnect to the real connect using technology proxy. It also initialised the session for the given technology. timeout value can be -1,0 and n sec

Definition at line 15 of file ConnectionHandler.cc.

References Exception, DBSPlugin::get(), m_registry, p, and ptr.

                                                                       {
  std::string realconnect(userconnect);
  std::string protocol;
  std::size_t pos=userconnect.find_first_of(':');
  if( pos!=std::string::npos ){
    protocol=userconnect.substr(0,pos);
    std::size_t p=protocol.find_first_of('_');
    if(p!=std::string::npos){
      protocol=protocol.substr(0,p);
    }
  }else{
    throw cond::Exception("connection string format error");
  }
  //std::cout<<"userconnect "<<userconnect<<std::endl;
  //std::cout<<"protocol "<<protocol<<std::endl;  
  std::auto_ptr<cond::TechnologyProxy> ptr(cond::TechnologyProxyFactory::get()->create(protocol,userconnect));
  realconnect=ptr->getRealConnectString();
  //std::cout<<"realconnect "<<realconnect<<std::endl;
  m_registry.insert(std::make_pair<std::string,cond::Connection*>(userconnect, new cond::Connection(realconnect,connectionTimeOutInSec)));
  ptr->setupSession(session);
}

void ConnectionHandler::registerConnection	(	const std::string &	name,
		const std::string &	con,
		int	timeOutInSec = 0
	)

register connection with a given name and timeout value. timeout value can be -1,0 and n sec

Definition at line 9 of file ConnectionHandler.cc.

References m_registry.

Referenced by cond::RDBMS::getDB(), cond::service::PoolDBOutputService::PoolDBOutputService(), and cond::RDBMS::setLogger().

                                                                       {
  m_registry.insert(std::make_pair<std::string,cond::Connection*>(name, new cond::Connection(con,connectionTimeoutInSec)));
}

void ConnectionHandler::removeConnection

(

const std::string &

name

)

remove connection from connection pool

Definition at line 39 of file ConnectionHandler.cc.

References m_registry.

                                                             {
  std::map<std::string,cond::Connection*>::iterator pos=m_registry.find(name);
  if( pos!=m_registry.end() ){
    m_registry.erase(pos);
  }
}

---

Member Data Documentation

std::map<std::string,cond::Connection*> cond::ConnectionHandler::m_registry [private]

registry of real connection handles

Definition at line 51 of file ConnectionHandler.h.

Referenced by connect(), disconnectAll(), getConnection(), registerConnection(), removeConnection(), and ~ConnectionHandler().

---

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

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

---