#include <CalibDbConnection.h>

Collaboration diagram for MuonCalib::CalibDbConnection:

Public Member Functions
	CalibDbConnection (const std::string &ConnectionString, const std::string &WorkingSchema)
virtual	~CalibDbConnection ()
bool	OpenConnection ()
void	SetLogin (const std::string &username, const std::string &password)
void	GetLogin (std::string &username, std::string &password) const
const std::string &	GetConnectionString () const
void	SetTargetUser (const std::string &target_user)
void	OpenTransaction ()
void	Commit ()
void	Rollback ()
coral::ITableDataEditor &	GetTableEditor (const std::string &table_name)
coral::IQuery *	GetQuery ()
void	DestroyQuery (coral::IQuery *query)

Private Member Functions
coral::IRelationalDomain &	domain (const std::string &connectionString)

Private Attributes
std::string	m_connection_string
std::string	m_working_schema
bool	m_comp_loaded
std::set< coral::IQuery * >	m_queries
coral::Context *	m_context
coral::ISessionProxy *	m_session
std::string	m_username
std::string	m_password
std::string	m_target_user
bool	m_transaction

Detailed Description

Definition at line 22 of file CalibDbConnection.h.

Constructor & Destructor Documentation

◆ CalibDbConnection()

MuonCalib::CalibDbConnection::CalibDbConnection	(	const std::string &	ConnectionString,
		const std::string &	WorkingSchema )

Definition at line 38 of file CalibDbConnection.cxx.

                                                                                                          :
        m_connection_string(ConnectionString),
        m_working_schema(WorkingSchema),
        m_comp_loaded(false),
        m_context(&coral::Context::instance()),
        m_session(nullptr),
        m_transaction(false) {
        coral::IHandle<coral::IConnectionService> lookSvcH = m_context->query<coral::IConnectionService>();
        if (!lookSvcH.isValid()) {
            m_context->loadComponent("CORAL/Services/ConnectionService");
            lookSvcH = m_context->query<coral::IConnectionService>();
        }
        if (!lookSvcH.isValid()) { return; }
        m_context->loadComponent("CORAL/Services/XMLAuthenticationService");
        m_context->loadComponent("CORAL/Services/RelationalService");
        m_comp_loaded = true;
        m_session = nullptr;
    }

◆ ~CalibDbConnection()

MuonCalib::CalibDbConnection::~CalibDbConnection ( )

virtual

Definition at line 57 of file CalibDbConnection.cxx.

                                          {
        for (std::set<coral::IQuery*>::iterator it = m_queries.begin(); it != m_queries.end(); ++it) {
            if (*it) { delete (*it); }
        }
        m_queries.clear();
    }

Member Function Documentation

◆ Commit()

void MuonCalib::CalibDbConnection::Commit ( )

Definition at line 109 of file CalibDbConnection.cxx.

                                   {
        if (m_transaction) {
            m_session->transaction().commit();
            m_transaction = false;
        }
    }

◆ DestroyQuery()

void MuonCalib::CalibDbConnection::DestroyQuery ( coral::IQuery * query )

Definition at line 151 of file CalibDbConnection.cxx.

                                                           {
        std::set<coral::IQuery*>::iterator it = m_queries.find(query);
        if (it == m_queries.end()) { return; }
        m_queries.erase(it);
        delete query;
    }

◆ domain()

coral::IRelationalDomain & MuonCalib::CalibDbConnection::domain ( const std::string & connectionString )

private

Definition at line 158 of file CalibDbConnection.cxx.

                                                                                       {
        coral::IHandle<coral::IRelationalService> relationalService = m_context->query<coral::IRelationalService>();
        if (!relationalService.isValid()) {
            throw std::runtime_error(
                Form("File: %s, Line: %d\nCalibDbConnection::domain() - Could not locate the relational service!", __FILE__, __LINE__));
        }
 
        coral::IHandle<coral::IAuthenticationService> authenticationService = m_context->query<coral::IAuthenticationService>();
        if (!authenticationService.isValid()) {
            throw std::runtime_error(
                Form("File: %s, Line: %d\nCalibDbConnection::domain() - Could not locate the authentication service!", __FILE__, __LINE__));
        }
        if (m_username == "") {
            const coral::IAuthenticationCredentials& credentials = authenticationService->credentials(connectionString);
            m_username = credentials.valueForItem("user");
            m_password = credentials.valueForItem("password");
        }
        if (m_target_user != "" && m_target_user != m_username) { m_username = m_username + "[" + m_target_user + "]"; }
        return relationalService->domainForConnection(connectionString);
    }

◆ GetConnectionString()

const std::string & MuonCalib::CalibDbConnection::GetConnectionString ( ) const

inline

Definition at line 38 of file CalibDbConnection.h.

38{ return m_connection_string; }

◆ GetLogin()

void MuonCalib::CalibDbConnection::GetLogin	(	std::string &	username,
		std::string &	password ) const

inline

Definition at line 34 of file CalibDbConnection.h.

                                                                             {
            username = m_username;
            password = m_password;
        }

◆ GetQuery()

coral::IQuery * MuonCalib::CalibDbConnection::GetQuery ( )

Definition at line 136 of file CalibDbConnection.cxx.

                                             {
        if (!m_session) {
            MsgStream log(Athena::getMessageSvc(), "CalibDbConnection");
            log << MSG::WARNING << "No Session open!" << endmsg;
            return nullptr;
        }
        coral::ISchema& workingSchema = m_session->schema(m_working_schema);
        coral::IQuery* query = workingSchema.newQuery();
        m_queries.insert(query);
        return query;
    }

◆ GetTableEditor()

coral::ITableDataEditor & MuonCalib::CalibDbConnection::GetTableEditor ( const std::string & table_name )

Definition at line 129 of file CalibDbConnection.cxx.

                                                                                        {
        return m_session->schema(m_working_schema).tableHandle(table_name).dataEditor();
    }

◆ OpenConnection()

bool MuonCalib::CalibDbConnection::OpenConnection ( )

Definition at line 68 of file CalibDbConnection.cxx.

                                           {
        if (!m_comp_loaded) { return false; }
        if (m_session) { return true; }
 
        try {
            // Load CORAL connection service
            coral::IHandle<coral::IConnectionService> lookSvcH = m_context->query<coral::IConnectionService>();
            m_context->loadComponent("CORAL/Services/ConnectionService");
            lookSvcH = m_context->query<coral::IConnectionService>();
 
            if (!lookSvcH.isValid()) {
                throw std::runtime_error(
                    Form("File: %s, Line: %d\nCalibDbConnection::OpenConnection() - Could not locate the connection service!", __FILE__,
                         __LINE__));
            }
            // connection to CORAL
            MsgStream log(Athena::getMessageSvc(), "CalibDbConnection");
            log << MSG::INFO << "CalibDbConnection::OpenConnection: " << m_connection_string << " Schema: " << m_working_schema << endmsg;
            m_session = lookSvcH->connect(m_connection_string, coral::Update);
            return true;
        } catch (coral::SchemaException& e) {
            MsgStream log(Athena::getMessageSvc(), "CalibDbConnection");
            log << MSG::WARNING << "Schema exception : " << e.what() << endmsg;
            m_session = nullptr;
            return false;
        }
    }

◆ OpenTransaction()

void MuonCalib::CalibDbConnection::OpenTransaction ( )

Definition at line 99 of file CalibDbConnection.cxx.

                                            {
        if (!m_transaction) {
            m_session->transaction().start();
            m_transaction = true;
        }
    }

◆ Rollback()

void MuonCalib::CalibDbConnection::Rollback ( )

Definition at line 119 of file CalibDbConnection.cxx.

                                     {
        if (m_transaction) {
            m_session->transaction().rollback();
            m_transaction = false;
        }
    }

◆ SetLogin()

void MuonCalib::CalibDbConnection::SetLogin	(	const std::string &	username,
		const std::string &	password )

inline

Definition at line 30 of file CalibDbConnection.h.

                                                                                   {
            m_username = username;
            m_password = password;
        }

◆ SetTargetUser()

void MuonCalib::CalibDbConnection::SetTargetUser ( const std::string & target_user )

inline

Definition at line 40 of file CalibDbConnection.h.

40{ m_target_user = target_user; }

Member Data Documentation

◆ m_comp_loaded

bool MuonCalib::CalibDbConnection::m_comp_loaded

private

Definition at line 55 of file CalibDbConnection.h.

◆ m_connection_string

std::string MuonCalib::CalibDbConnection::m_connection_string

private

Definition at line 54 of file CalibDbConnection.h.

◆ m_context

coral::Context* MuonCalib::CalibDbConnection::m_context

private

Definition at line 59 of file CalibDbConnection.h.

◆ m_password

std::string MuonCalib::CalibDbConnection::m_password

private

Definition at line 65 of file CalibDbConnection.h.

◆ m_queries

std::set<coral::IQuery*> MuonCalib::CalibDbConnection::m_queries

private

Definition at line 57 of file CalibDbConnection.h.

◆ m_session

coral::ISessionProxy* MuonCalib::CalibDbConnection::m_session

private

Definition at line 61 of file CalibDbConnection.h.

◆ m_target_user

std::string MuonCalib::CalibDbConnection::m_target_user

private

Definition at line 67 of file CalibDbConnection.h.

◆ m_transaction

bool MuonCalib::CalibDbConnection::m_transaction

private

Definition at line 69 of file CalibDbConnection.h.

◆ m_username

std::string MuonCalib::CalibDbConnection::m_username

private

Definition at line 63 of file CalibDbConnection.h.

◆ m_working_schema

std::string MuonCalib::CalibDbConnection::m_working_schema

private

Definition at line 54 of file CalibDbConnection.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

◆ CalibDbConnection()

◆ ~CalibDbConnection()

Member Function Documentation

◆ Commit()

◆ DestroyQuery()

◆ domain()

◆ GetConnectionString()

◆ GetLogin()

◆ GetQuery()

◆ GetTableEditor()

◆ OpenConnection()

◆ OpenTransaction()

◆ Rollback()

◆ SetLogin()

◆ SetTargetUser()

Member Data Documentation

◆ m_comp_loaded

◆ m_connection_string

◆ m_context

◆ m_password

◆ m_queries

◆ m_session

◆ m_target_user

◆ m_transaction

◆ m_username

◆ m_working_schema