RPCDBCom.cc

Go to the documentation of this file.

#include "CondTools/RPC/interface/RPCDBCom.h"
#include "RelationalAccess/IRelationalDomain.h"
#include "RelationalAccess/IConnection.h"
#include "RelationalAccess/ISession.h"
#include "RelationalAccess/RelationalServiceException.h"
#include "CoralKernel/Context.h"

RPCDBCom::RPCDBCom() : 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() {
  if (m_connection)
    delete m_connection;
}

coral::ISession* RPCDBCom::connect(const std::string& connectionString,
                                   const std::string& userName,
                                   const std::string& password) {
  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;
}

void RPCDBCom::setVerbosityLevel(coral::MsgLevel level) { coral::MessageStream::setMsgVerbosity(level); }