RPCDBCom Class Reference

#include <RPCDBCom.h>

Inheritance diagram for RPCDBCom:

Public Member Functions
	RPCDBCom ()
virtual void	run ()=0
void	setVerbosityLevel (coral::MsgLevel level)
virtual	~RPCDBCom ()

Protected Member Functions
coral::ISession *	connect (const std::string &connectionString, const std::string &userName, const std::string &password)

Private Attributes
coral::IConnection *	m_connection

Detailed Description

Definition at line 12 of file RPCDBCom.h.

Constructor & Destructor Documentation

RPCDBCom()

RPCDBCom::RPCDBCom

(

)

Definition at line 8 of file RPCDBCom.cc.

                   : m_connection(nullptr) {
  coral::Context& context = coral::Context::instance();
  context.loadComponent("CORAL/RelationalPlugins/oracle");
  coral::IHandle<coral::IRelationalDomain> domain =
      context.query<coral::IRelationalDomain>("CORAL/RelationalPlugins/oracle");
  if (!domain.isValid())
    throw std::runtime_error("Could not load the OracleAccess plugin");
}

References instance.

~RPCDBCom()

RPCDBCom::~RPCDBCom ( )

virtual

Definition at line 17 of file RPCDBCom.cc.

                    {
  if (m_connection)
    delete m_connection;
}

References m_connection.

Member Function Documentation

connect()

coral::ISession * RPCDBCom::connect ( const std::string &  connectionString, const std::string &  userName, const std::string &  password  )

protected

Definition at line 22 of file RPCDBCom.cc.

                                                              {
  coral::Context& ctx = coral::Context::instance();
  ctx.loadComponent("CORAL/RelationalPlugins/oracle");
  coral::IHandle<coral::IRelationalDomain> iHandle =
      ctx.query<coral::IRelationalDomain>("CORAL/RelationalPlugins/oracle");
  if (!iHandle.isValid()) {
    throw std::runtime_error("Could not load the OracleAccess plugin");
  }
  std::pair<std::string, std::string> connectionAndSchema = iHandle->decodeUserConnectionString(connectionString);
 
  if (!m_connection)
    m_connection = iHandle->newConnection(connectionAndSchema.first);
 
  if (!m_connection->isConnected())
    m_connection->connect();
 
  coral::ISession* session = m_connection->newSession(connectionAndSchema.second);
 
  if (session) {
    session->startUserSession(userName, password);
  }
  //memory leaking
  return session;
}

References l1RCTOmdsFedVectorProducer_cfi::connectionString, instance, m_connection, EcalCondDBWriter_cfi::password, and EcalCondDBWriter_cfi::userName.

Referenced by RPCFw::createFEB(), RPCFw::createGAS(), RPCFw::createIDMAP(), RPCFw::createIMON(), RPCFw::createMix(), RPCFw::createSTATUS(), RPCFw::createT(), RPCFw::createUXC(), RPCFw::createVMON(), and o2o_db_cfgmap.DbManagerDAQ::update_hashmap().

run()

virtual void RPCDBCom::run ( )

pure virtual

Implemented in RPCFw.

Referenced by Types.EventID::cppID(), and Types.LuminosityBlockID::cppID().

setVerbosityLevel()

void RPCDBCom::setVerbosityLevel

(

coral::MsgLevel

level

)

Definition at line 49 of file RPCDBCom.cc.

{ coral::MessageStream::setMsgVerbosity(level); }

References personalPlayback::level.

Member Data Documentation

m_connection

coral::IConnection* RPCDBCom::m_connection

private

Definition at line 25 of file RPCDBCom.h.

Referenced by connect(), and ~RPCDBCom().