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

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.

62 { return m_connectionString; }

◆ connectionTimeout()

int TrigConf::SessionMgr::connectionTimeout ( ) const

inline

Definition at line 66 of file SessionMgr.h.

66 { 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.

69 { return m_dbname; }

◆ dbPassword()

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

inline

Definition at line 71 of file SessionMgr.h.

71 { return m_password; }

◆ dbServer()

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

inline

Definition at line 68 of file SessionMgr.h.

68 { return m_dbserver; }

◆ dbType()

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

inline

Definition at line 67 of file SessionMgr.h.

67 { return m_dbtype; }

◆ dbUser()

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

inline

Definition at line 70 of file SessionMgr.h.

70 { return m_user; }

◆ 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 81 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 91 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 70 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.

64 { return m_retrialPeriod; }

◆ retrialTimeout()

int TrigConf::SessionMgr::retrialTimeout ( ) const

inline

Definition at line 65 of file SessionMgr.h.

65 { return m_retrialTimeout; }

◆ setConnectionString()

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

inline

Definition at line 49 of file SessionMgr.h.

49 { m_connectionString = connStr; }

◆ setConnectionTimeout()

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

inline

Definition at line 53 of file SessionMgr.h.

53 { 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.

51 { m_retrialPeriod = retrialPeriod; }

◆ setRetrialTimeout()

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

inline

Definition at line 52 of file SessionMgr.h.

52 { 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.

50 { m_useFrontier = useFrontier; }

◆ useFrontier()

bool TrigConf::SessionMgr::useFrontier ( ) const

inline

Definition at line 63 of file SessionMgr.h.

63 { 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 66 of file TrigConfMessaging.h.

◆ m_name

std::string TrigConf::TrigConfMessaging::m_name

privateinherited

Definition at line 67 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:

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ SessionMgr()

◆ ~SessionMgr()

Member Function Documentation

◆ buildConnectionString()

◆ closeSession()

◆ connection()

◆ connectionTimeout()

◆ createSession()

◆ dbName()

◆ dbPassword()

◆ dbServer()

◆ dbType()

◆ dbUser()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ retrialPeriod()

◆ retrialTimeout()

◆ setConnectionString()

◆ setConnectionTimeout()

◆ setCppTypeForSqlType()

◆ setDbName()

◆ setDbPassword()

◆ setDbServer()

◆ setDbType()

◆ setDbUser()

◆ setRetrialPeriod()

◆ setRetrialTimeout()

◆ setTypeConversionRules()

◆ setUseFrontier()

◆ useFrontier()

Member Data Documentation

◆ m_connectionString

◆ m_connectionTimeout

◆ m_dbname

◆ m_dbserver

◆ m_dbtype

◆ m_msg_tls

◆ m_name

◆ m_password

◆ m_replicaSorter

◆ m_retrialPeriod

◆ m_retrialTimeout

◆ m_sessionproxy

◆ m_useFrontier

◆ m_user