#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 ( )

Definition at line 8 of file RPCDBCom.cc.

References visDQMUpload::context, and instance.

                    : 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");
 }

RPCDBCom::~RPCDBCom ( )

virtual

Definition at line 17 of file RPCDBCom.cc.

References m_connection.

                     {
   if (m_connection)
     delete m_connection;
 }

Member Function Documentation

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.

References instance, m_connection, and run_AlCaRecoTriggerBitsUpdateWorkflow::session.

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().

                                                               {
   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;
 }