TrigConf::SessionMgr Class Reference

Manager of the database session. More...

#include <SessionMgr.h>

Inheritance diagram for TrigConf::SessionMgr:

Collaboration diagram for TrigConf::SessionMgr:

Public Member Functions
	SessionMgr ()
	constructor More...
virtual	~SessionMgr () override
	destructor More...
void	closeSession ()
	close open sessions More...
coral::ISessionProxy &	createSession ()
	instantiates the session More...
void	setTypeConversionRules ()
	SQL -> C++ type conversion mapping for Oracle database to match MySQL. More...
void	setConnectionString (const std::string &connStr)
void	setUseFrontier (bool useFrontier)
void	setRetrialPeriod (int retrialPeriod)
void	setRetrialTimeout (int retrialTimeout)
void	setConnectionTimeout (int connectionTimeout)
void	setDbType (const std::string &s)
void	setDbServer (const std::string &s)
void	setDbName (const std::string &s)
void	setDbUser (const std::string &s)
void	setDbPassword (const std::string &s)
const std::string &	connection () const
bool	useFrontier () const
int	retrialPeriod () const
int	retrialTimeout () const
int	connectionTimeout () const
const std::string &	dbType () const
const std::string &	dbServer () const
const std::string &	dbName () const
const std::string &	dbUser () const
const std::string &	dbPassword () const
bool	msgLvl (const MSGTC::Level lvl) const
	Test the output level. More...
MsgStreamTC &	msg () const
	The standard message stream. More...
MsgStreamTC &	msg (const MSGTC::Level lvl) const
	The standard message stream. More...
const std::string &	getName () const
	name accessor More...

Private Member Functions
void	buildConnectionString ()
void	setCppTypeForSqlType (const std::string &cpp_type, const std::string &sql_type)
	SQL -> C++ type conversion interface to CORAL. More...

Private Attributes
coral::ISessionProxy *	m_sessionproxy { nullptr }
	the coral database session More...
std::string	m_connectionString { "" }
	connection string More...
std::string	m_dbtype { "" }
	db type More...
std::string	m_dbserver { "" }
	db server More...
std::string	m_dbname { "" }
	db name More...
std::string	m_user { "" }
	user name More...
std::string	m_password { "" }
	password More...
bool	m_useFrontier { false }
	uses frontier instead of oracle More...
int	m_retrialPeriod {0}
int	m_retrialTimeout {0}
int	m_connectionTimeout {0}
ReplicaSorter *	m_replicaSorter { nullptr }
boost::thread_specific_ptr< MsgStreamTC >	m_msg_tls
	MsgStreamTC instance (a std::cout like with print-out levels) More...
std::string	m_name

Detailed Description

Manager of the database session.

it uses CORAL to connect to the different DB technologies

Definition at line 29 of file SessionMgr.h.

Constructor & Destructor Documentation

SessionMgr()

SessionMgr::SessionMgr

(

)

constructor

Definition at line 37 of file SessionMgr.cxx.

                       :
   TrigConfMessaging("SessionMgr")
{}

~SessionMgr()

SessionMgr::~SessionMgr ( )

overridevirtual

destructor

Definition at line 41 of file SessionMgr.cxx.

                        {
   // Dtors are noexcept by default, so if closeSession() throws,
   // std::terminate will be called.  However, cppcheck warns here
   // about the uncaught exception, so do the std::terminate call
   // explicitly.
   try {
     closeSession();
   } catch (...) {
     std::terminate();
   }
   // never delete the m_replicaSorter, we will have to live with that
   // one-time memory leak. The problem is the CORAL interface that
   // does keeps a reference to the replicaSorter and keeps using it
   // but doesn't clean it up. And if we delete it too early, then
   // later access leads to a crash
}

Member Function Documentation

buildConnectionString()

void TrigConf::SessionMgr::buildConnectionString ( )

private

Definition at line 76 of file SessionMgr.cxx.

                                          {
 
   if(m_connectionString!="")
      return;
 
   if(m_dbserver=="") { 
      m_connectionString = m_dbname; 
   } else if(m_dbtype == "dblookup") { 
      m_connectionString = m_dbserver; 
   } else { 
      m_connectionString = m_dbtype + "://" + m_dbserver + "/" + m_dbname;     
   }
}

closeSession()

void SessionMgr::closeSession

(

)

close open sessions

Definition at line 59 of file SessionMgr.cxx.

                         {
 
   if(m_sessionproxy) {
      try{
         delete m_sessionproxy;
         m_sessionproxy = nullptr;
         TRG_MSG_INFO("Closing session " << m_connectionString);
      }
      catch ( coral::Exception& e ) {
         TRG_MSG_WARNING("CORAL exception " << e.what());
         throw;
      }
   }
 
}

connection()

const std::string& TrigConf::SessionMgr::connection ( ) const

inline

Definition at line 62 of file SessionMgr.h.

{ return m_connectionString; }

connectionTimeout()

int TrigConf::SessionMgr::connectionTimeout ( ) const

inline

Definition at line 66 of file SessionMgr.h.

{ return m_connectionTimeout; }

createSession()

coral::ISessionProxy & TrigConf::SessionMgr::createSession

(

)

instantiates the session

Definition at line 92 of file SessionMgr.cxx.

                                  {
 
   if( m_sessionproxy ) return *m_sessionproxy;
 
   coral::ConnectionService connSvc;
   coral::IConnectionServiceConfiguration& csc = connSvc.configuration();
   csc.setConnectionRetrialPeriod( m_retrialPeriod );
   csc.setConnectionRetrialTimeOut( m_retrialTimeout );
   csc.setConnectionTimeOut( m_connectionTimeout );
 
   
   if(csc.replicaSortingAlgorithm() == nullptr) { // likely to be standalone, create our own
      TRG_MSG_INFO("Create own ReplicaSortingAlgorithm");
      m_replicaSorter = new TrigConf::ReplicaSorter();
      csc.setReplicaSortingAlgorithm(*m_replicaSorter);
   }
 
   buildConnectionString();
   TRG_MSG_INFO("Connecting to " << m_connectionString);
   m_sessionproxy = connSvc.connect(m_connectionString, coral::AccessMode::ReadOnly);
   TRG_MSG_INFO("Opening session " << m_connectionString << " with " << m_retrialPeriod << "/" << m_retrialTimeout << "/" << m_connectionTimeout);
 
   return *m_sessionproxy;   
}

dbName()

const std::string& TrigConf::SessionMgr::dbName ( ) const

inline

Definition at line 69 of file SessionMgr.h.

{ return m_dbname; }

dbPassword()

const std::string& TrigConf::SessionMgr::dbPassword ( ) const

inline

Definition at line 71 of file SessionMgr.h.

{ return m_password; }

dbServer()

const std::string& TrigConf::SessionMgr::dbServer ( ) const

inline

Definition at line 68 of file SessionMgr.h.

{ return m_dbserver; }

dbType()

const std::string& TrigConf::SessionMgr::dbType ( ) const

inline

Definition at line 67 of file SessionMgr.h.

{ return m_dbtype; }

dbUser()

const std::string& TrigConf::SessionMgr::dbUser ( ) const

inline

Definition at line 70 of file SessionMgr.h.

{ return m_user; }

getName()

const std::string & TrigConf::TrigConfMessaging::getName ( ) const

inlineinherited

name accessor

Returns

the name

Definition at line 101 of file TrigConfMessaging.h.

                                                           {
    return m_name;
  }

msg() [1/2]

MsgStreamTC & TrigConf::TrigConfMessaging::msg ( ) const

inlineinherited

The standard message stream.

Returns a reference to the message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 86 of file TrigConfMessaging.h.

  {
    MsgStreamTC* ms = m_msg_tls.get();
    if (!ms) {
      ms = new MsgStreamTC(m_name);
      m_msg_tls.reset(ms);
    }
    return *ms;
  }

msg() [2/2]

MsgStreamTC & TrigConf::TrigConfMessaging::msg ( const MSGTC::Level  lvl ) const

inlineinherited

The standard message stream.

Returns a reference to the default message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 96 of file TrigConfMessaging.h.

  {
    return msg() << lvl;
  }

msgLvl()

bool TrigConf::TrigConfMessaging::msgLvl ( const MSGTC::Level  lvl ) const

inlineinherited

Test the output level.

Parameters

lvl	The message level to test against

Returns

boolean Indicting if messages at given level will be printed

Return values

true	Messages at level "lvl" will be printed

Definition at line 75 of file TrigConfMessaging.h.

  {
    if (msg().level() <= lvl) {
      msg() << lvl;
      return true;
    }
    else {
      return false;
    }
  }

retrialPeriod()

int TrigConf::SessionMgr::retrialPeriod ( ) const

inline

Definition at line 64 of file SessionMgr.h.

{ return m_retrialPeriod; }

retrialTimeout()

int TrigConf::SessionMgr::retrialTimeout ( ) const

inline

Definition at line 65 of file SessionMgr.h.

{ return m_retrialTimeout; }

setConnectionString()

void TrigConf::SessionMgr::setConnectionString ( const std::string &  connStr )

inline

Definition at line 49 of file SessionMgr.h.

{ m_connectionString = connStr; }

setConnectionTimeout()

void TrigConf::SessionMgr::setConnectionTimeout ( int  connectionTimeout )

inline

Definition at line 53 of file SessionMgr.h.

{ m_connectionTimeout = connectionTimeout; }

setCppTypeForSqlType()

void TrigConf::SessionMgr::setCppTypeForSqlType ( const std::string &  cpp_type, const std::string &  sql_type  )

private

SQL -> C++ type conversion interface to CORAL.

setDbName()

void TrigConf::SessionMgr::setDbName

(

const std::string &

s

)

Definition at line 131 of file SessionMgr.cxx.

                                                 { 
   m_dbname = s;
   m_connectionString = "";
}

setDbPassword()

void TrigConf::SessionMgr::setDbPassword

(

const std::string &

s

)

Definition at line 143 of file SessionMgr.cxx.

                                                     {
   m_password = s;
   m_connectionString = "";
}

setDbServer()

void TrigConf::SessionMgr::setDbServer

(

const std::string &

s

)

Definition at line 125 of file SessionMgr.cxx.

                                                   {
   m_dbserver = s;
   m_connectionString = "";
}

setDbType()

void TrigConf::SessionMgr::setDbType

(

const std::string &

s

)

Definition at line 119 of file SessionMgr.cxx.

                                                 {
   m_dbtype = boost::to_lower_copy(s);
   m_connectionString = "";
}

setDbUser()

void TrigConf::SessionMgr::setDbUser

(

const std::string &

s

)

Definition at line 137 of file SessionMgr.cxx.

                                                 {
   m_user = s;
   m_connectionString = "";
}

setRetrialPeriod()

void TrigConf::SessionMgr::setRetrialPeriod ( int  retrialPeriod )

inline

Definition at line 51 of file SessionMgr.h.

{ m_retrialPeriod = retrialPeriod; }

setRetrialTimeout()

void TrigConf::SessionMgr::setRetrialTimeout ( int  retrialTimeout )

inline

Definition at line 52 of file SessionMgr.h.

{ m_retrialTimeout = retrialTimeout; }

setTypeConversionRules()

void TrigConf::SessionMgr::setTypeConversionRules

(

)

SQL -> C++ type conversion mapping for Oracle database to match MySQL.

setUseFrontier()

void TrigConf::SessionMgr::setUseFrontier ( bool  useFrontier )

inline

Definition at line 50 of file SessionMgr.h.

{ m_useFrontier = useFrontier; }

useFrontier()

bool TrigConf::SessionMgr::useFrontier ( ) const

inline

Definition at line 63 of file SessionMgr.h.

{ return m_useFrontier; }

Member Data Documentation

m_connectionString

std::string TrigConf::SessionMgr::m_connectionString { "" }

private

connection string

Definition at line 83 of file SessionMgr.h.

m_connectionTimeout

int TrigConf::SessionMgr::m_connectionTimeout {0}

private

Definition at line 92 of file SessionMgr.h.

m_dbname

std::string TrigConf::SessionMgr::m_dbname { "" }

private

db name

Definition at line 86 of file SessionMgr.h.

m_dbserver

std::string TrigConf::SessionMgr::m_dbserver { "" }

private

db server

Definition at line 85 of file SessionMgr.h.

m_dbtype

std::string TrigConf::SessionMgr::m_dbtype { "" }

private

db type

Definition at line 84 of file SessionMgr.h.

m_msg_tls

boost::thread_specific_ptr<MsgStreamTC> TrigConf::TrigConfMessaging::m_msg_tls

mutableprivateinherited

MsgStreamTC instance (a std::cout like with print-out levels)

Definition at line 71 of file TrigConfMessaging.h.

m_name

std::string TrigConf::TrigConfMessaging::m_name

privateinherited

Definition at line 72 of file TrigConfMessaging.h.

m_password

std::string TrigConf::SessionMgr::m_password { "" }

private

password

Definition at line 88 of file SessionMgr.h.

m_replicaSorter

ReplicaSorter* TrigConf::SessionMgr::m_replicaSorter { nullptr }

private

Definition at line 94 of file SessionMgr.h.

m_retrialPeriod

int TrigConf::SessionMgr::m_retrialPeriod {0}

private

Definition at line 90 of file SessionMgr.h.

m_retrialTimeout

int TrigConf::SessionMgr::m_retrialTimeout {0}

private

Definition at line 91 of file SessionMgr.h.

m_sessionproxy

coral::ISessionProxy* TrigConf::SessionMgr::m_sessionproxy { nullptr }

private

the coral database session

Definition at line 81 of file SessionMgr.h.

m_useFrontier

bool TrigConf::SessionMgr::m_useFrontier { false }

private

uses frontier instead of oracle

Definition at line 89 of file SessionMgr.h.

m_user

std::string TrigConf::SessionMgr::m_user { "" }

private

user name

Definition at line 87 of file SessionMgr.h.

---

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

• SessionMgr.h
• SessionMgr.cxx