#include <ConnectionPool.h>

Public Member Functions
void	configure ()

	ConnectionPool ()

Session	createReadOnlySession (const std::string &connectionString, const std::string &transactionId)

Session	createSession (const std::string &connectionString, bool writeCapable=false)

bool	isLoggingEnabled () const

void	setAuthenticationPath (const std::string &p)

void	setAuthenticationSystem (int authSysCode)

void	setLogging (bool flag)

void	setMessageVerbosity (coral::MsgLevel level)

void	setParameters (const edm::ParameterSet &connectionPset)

	~ConnectionPool ()

Private Member Functions
void	configure (coral::IConnectionServiceConfiguration &coralConfig)

Session	createSession (const std::string &connectionString, const std::string &transactionId, bool writeCapable=false)

Private Attributes
std::string	m_authPath

int	m_authSys = 0

bool	m_loggingEnabled = false

coral::MsgLevel	m_messageLevel = coral::Info

cond::CoralServiceManager *	m_pluginManager = 0

std::vector< std::string >	m_refreshtablelist

Detailed Description

Definition at line 29 of file ConnectionPool.h.

Constructor & Destructor Documentation

cond::persistency::ConnectionPool::ConnectionPool ( )

Definition at line 23 of file ConnectionPool.cc.

References configure(), and m_refreshtablelist.

                                   :
       m_authPath(),
       m_authSys(0),
       m_messageLevel( coral::Error ),
       m_loggingEnabled( false ),
       m_pluginManager( new cond::CoralServiceManager ),
       m_refreshtablelist(){
       m_refreshtablelist.reserve(6);
       //table names for IOVSequence in the old POOL mapping
       m_refreshtablelist.push_back("IOV");
       m_refreshtablelist.push_back("IOV_DATA");
       //table names for IOVSequence in ORA
       m_refreshtablelist.push_back("ORA_C_COND_IOVSEQUENCE");
       m_refreshtablelist.push_back("ORA_C_COND_IOVSEQU_A0");
       m_refreshtablelist.push_back("ORA_C_COND_IOVSEQU_A1");
       //table names for IOVSequence in CONDDB
       m_refreshtablelist.push_back("TAG");
       configure();
     }

cond::persistency::ConnectionPool::~ConnectionPool ( )

Definition at line 43 of file ConnectionPool.cc.

References m_pluginManager.

                                    {
       delete m_pluginManager;
     }

Member Function Documentation

void cond::persistency::ConnectionPool::configure ( )

Definition at line 137 of file ConnectionPool.cc.

Referenced by CondDBESSource::CondDBESSource(), ConnectionPool(), DTKeyedConfigHandler::getNewObjects(), and DTUserKeyedConfigHandler::getNewObjects().

                                    {
       coral::ConnectionService connServ;
       configure( connServ.configuration() );
     }

void cond::persistency::ConnectionPool::configure ( coral::IConnectionServiceConfiguration & coralConfig )

private

Definition at line 88 of file ConnectionPool.cc.

References builder_last_value_cfg::authPath, cond::Auth::COND_AUTH_PATH, cond::Auth::COND_AUTH_PATH_PROPERTY, cond::Auth::COND_AUTH_SYS, cond::persistency::CondDbKey, cond::persistency::CoralXMLFile, instance, m_authPath, m_authSys, m_messageLevel, m_pluginManager, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                     {
       
       coralConfig.disablePoolAutomaticCleanUp();
       coralConfig.disableConnectionSharing();
       // message streaming
       coral::MessageStream::setMsgVerbosity( m_messageLevel );
       std::string authServiceName("CORAL/Services/EnvironmentAuthenticationService");
       std::string authPath = m_authPath;
       // authentication
       if( authPath.empty() ){
     // first try to check the env...
     const char* authEnv = ::getenv( cond::Auth::COND_AUTH_PATH );
     if(authEnv){
       authPath += authEnv;
     } 
       }
       int authSys = m_authSys;
       // first attempt, look at the env...
       const char* authSysEnv = ::getenv( cond::Auth::COND_AUTH_SYS );
       if( authSysEnv ){
     authSys = ::atoi( authSysEnv );
       }
       if( authSys !=CondDbKey && authSys != CoralXMLFile ){
     // take the default
     authSys = CondDbKey;
       }  
       std::string servName("");
       if( authSys == CondDbKey ){
     if( authPath.empty() ){
       const char* authEnv = ::getenv("HOME");
       if(authEnv){
         authPath += authEnv;
       } 
     }
     servName = "COND/Services/RelationalAuthenticationService";     
       } else if( authSys == CoralXMLFile ){
     if( authPath.empty() ){
       authPath = ".";
     }
     servName = "COND/Services/XMLAuthenticationService";  
       }
       if( !authPath.empty() ){
     authServiceName = servName;    
     coral::Context::instance().PropertyManager().property(cond::Auth::COND_AUTH_PATH_PROPERTY)->set(authPath);  
     coral::Context::instance().loadComponent( authServiceName, m_pluginManager );
       }
       coralConfig.setAuthenticationService( authServiceName );
     }

Session cond::persistency::ConnectionPool::createReadOnlySession	(	const std::string &	connectionString,
		const std::string &	transactionId
	)

Definition at line 157 of file ConnectionPool.cc.

References createSession().

Referenced by CondDBESSource::CondDBESSource(), and CondDBESSource::setIntervalFor().

                                                                                                                     {
       return createSession( connectionString, transactionId );
     }

Session cond::persistency::ConnectionPool::createSession	(	const std::string &	connectionString,
		bool	writeCapable = `false`
	)

Definition at line 153 of file ConnectionPool.cc.

Referenced by createReadOnlySession(), CondDBESSource::fillTagCollectionFromGT(), DTKeyedConfigHandler::getNewObjects(), and DTUserKeyedConfigHandler::getNewObjects().

                                                                                                {
       return createSession( connectionString, "", writeCapable );
     }

Session cond::persistency::ConnectionPool::createSession	(	const std::string &	connectionString,
		const std::string &	transactionId,
		bool	writeCapable = `false`
	)

private

Definition at line 142 of file ConnectionPool.cc.

References cond::persistency::getRealConnectionString(), and m_refreshtablelist.

                                                                                                                                {
       coral::ConnectionService connServ;
       std::pair<std::string,std::string> fullConnectionPars = getRealConnectionString( connectionString, transactionId );
       if( !fullConnectionPars.second.empty() ) 
     for( auto tableName : m_refreshtablelist ) connServ.webCacheControl().refreshTable( fullConnectionPars.second, tableName );
 
       boost::shared_ptr<coral::ISessionProxy> coralSession( connServ.connect( fullConnectionPars.first, 
                                           writeCapable?coral::Update:coral::ReadOnly ) );
       return Session( coralSession, connectionString );
     }

bool cond::persistency::ConnectionPool::isLoggingEnabled ( ) const

Definition at line 84 of file ConnectionPool.cc.

References m_loggingEnabled.

                                                 {
       return m_loggingEnabled;
     }

void cond::persistency::ConnectionPool::setAuthenticationPath ( const std::string & p )

Definition at line 47 of file ConnectionPool.cc.

References m_authPath, and AlCaHLTBitMon_ParallelJobs::p.

Referenced by DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), and setParameters().

                                                                   {
       m_authPath = p;
     }

void cond::persistency::ConnectionPool::setAuthenticationSystem ( int authSysCode )

Definition at line 51 of file ConnectionPool.cc.

References m_authSys.

Referenced by setParameters().

                                                                  {
       m_authSys = authSysCode;
     }

void cond::persistency::ConnectionPool::setLogging ( bool flag )

Definition at line 55 of file ConnectionPool.cc.

References m_loggingEnabled.

Referenced by setParameters().

                                               {
       m_loggingEnabled = flag;
     }

void cond::persistency::ConnectionPool::setMessageVerbosity ( coral::MsgLevel level )

Definition at line 160 of file ConnectionPool.cc.

References testEve_cfg::level, and m_messageLevel.

Referenced by setParameters().

                                                                  {
       m_messageLevel = level;
     }

void cond::persistency::ConnectionPool::setParameters ( const edm::ParameterSet & connectionPset )

Definition at line 59 of file ConnectionPool.cc.

References Debug, edm::ParameterSet::getUntrackedParameter(), testEve_cfg::level, setAuthenticationPath(), setAuthenticationSystem(), setLogging(), setMessageVerbosity(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by CondDBESSource::CondDBESSource(), and cond::service::PoolDBOutputService::PoolDBOutputService().

                                                                              {
       setAuthenticationPath( connectionPset.getUntrackedParameter<std::string>("authenticationPath","") );
       setAuthenticationSystem( connectionPset.getUntrackedParameter<int>("authenticationSystem",0) );
       int messageLevel = connectionPset.getUntrackedParameter<int>("messageLevel",0);
       coral::MsgLevel level = coral::Error;
       switch (messageLevel) {
       case 0 :
     level = coral::Error;
     break;    
       case 1:
     level = coral::Warning;
     break;
       case 2:
     level = coral::Info;
     break;
       case 3:
     level = coral::Debug;
     break;
       default:
     level = coral::Error;
       }
       setMessageVerbosity(level);
       setLogging( connectionPset.getUntrackedParameter<bool>("logging",false) );
     }