cond::persistency::PayloadReader Class Reference

#include <PayloadReader.h>

Public Member Functions
void	close ()
ConnectionPool &	connection ()
template<typename T >
std::shared_ptr< T >	fetch (const cond::Hash &payloadHash)
void	open (const std::string &connectionString)
void	open ()
PayloadReader &	operator= (const PayloadReader &rhs)
	PayloadReader ()
	PayloadReader (const PayloadReader &rhs)
virtual	~PayloadReader ()

Static Public Attributes
static constexpr const char *const	PRODUCTION_DB = "oracle://cms_orcon_adg/CMS_CONDITIONS"

Private Attributes
std::shared_ptr< ConnectionPool >	m_connection
Session	m_session

Detailed Description

Definition at line 23 of file PayloadReader.h.

Constructor & Destructor Documentation

PayloadReader() [1/2]

PayloadReader::PayloadReader

(

)

Definition at line 7 of file PayloadReader.cc.

References m_connection.

{ m_connection.reset(new ConnectionPool); }

PayloadReader() [2/2]

PayloadReader::PayloadReader

(

const PayloadReader &

rhs

)

Definition at line 9 of file PayloadReader.cc.

: m_connection(rhs.m_connection), m_session(rhs.m_session) {}

~PayloadReader()

PayloadReader::~PayloadReader ( )

virtual

Definition at line 11 of file PayloadReader.cc.

{}

Member Function Documentation

close()

void PayloadReader::close

(

void

)

Definition at line 27 of file PayloadReader.cc.

References cond::persistency::Session::close(), and m_session.

Referenced by esMonitoring.AsyncLineReaderMixin::handle_close(), and esMonitoring.FDJsonServer::handle_close().

{ m_session.close(); }

connection()

ConnectionPool & PayloadReader::connection

(

)

Definition at line 19 of file PayloadReader.cc.

References m_connection.

{ return *m_connection; }

fetch()

template<typename T >

std::shared_ptr< T > PayloadReader::fetch ( const cond::Hash &  payloadHash )

inline

Definition at line 62 of file PayloadReader.h.

References cond::persistency::Transaction::commit(), cond::persistency::Session::connectionString(), cond::persistency::Session::fetchPayload(), m_session, open(), PRODUCTION_DB, runTheMatrix::ret, cond::persistency::Transaction::start(), and cond::persistency::Session::transaction().

                                                                            {
      std::shared_ptr<T> ret;
      if (m_session.connectionString().empty())
        open(PRODUCTION_DB);
      m_session.transaction().start(true);
      ret = m_session.fetchPayload<T>(payloadHash);
      m_session.transaction().commit();
      return ret;
    }

open() [1/2]

void PayloadReader::open

(

const std::string &

connectionString

)

Definition at line 21 of file PayloadReader.cc.

References l1RCTOmdsFedVectorProducer_cfi::connectionString, m_connection, and m_session.

                                                              {
      m_session = m_connection->createSession(connectionString);
    }

open() [2/2]

void PayloadReader::open

(

)

Definition at line 25 of file PayloadReader.cc.

References PRODUCTION_DB.

Referenced by fetch().

{ open(PRODUCTION_DB); }

operator=()

PayloadReader & PayloadReader::operator=

(

const PayloadReader &

rhs

)

Definition at line 13 of file PayloadReader.cc.

References m_connection, and m_session.

                                                                    {
      m_connection = rhs.m_connection;
      m_session = rhs.m_session;
      return *this;
    }

Member Data Documentation

m_connection

std::shared_ptr<ConnectionPool> cond::persistency::PayloadReader::m_connection

private

Definition at line 57 of file PayloadReader.h.

Referenced by connection(), open(), operator=(), and PayloadReader().

m_session

Session cond::persistency::PayloadReader::m_session

private

Definition at line 58 of file PayloadReader.h.

Referenced by close(), fetch(), open(), and operator=().

PRODUCTION_DB

constexpr const char* const cond::persistency::PayloadReader::PRODUCTION_DB = "oracle://cms_orcon_adg/CMS_CONDITIONS"

static

Definition at line 25 of file PayloadReader.h.

Referenced by fetch(), and open().