RunCommentDat Class Reference

#include <RunCommentDat.h>

Inheritance diagram for RunCommentDat:

Public Member Functions
std::string	getComment () const
Tm	getDBTime () const
std::string	getSource () const
std::string	getTable () override
	RunCommentDat ()
void	setComment (std::string x)
void	setDBTime (const Tm &x)
void	setSource (std::string x)
	~RunCommentDat () override
Public Member Functions inherited from IDataItem
	IDataItem ()
Public Member Functions inherited from IDBObject
oracle::occi::Connection *	getConn () const
oracle::occi::Environment *	getEnv () const
void	setConnection (oracle::occi::Environment *env, oracle::occi::Connection *conn)
virtual	~IDBObject ()

Private Member Functions
void	fetchData (std::map< EcalLogicID, RunCommentDat > *fillMap, RunIOV *iov) noexcept(false)
void	prepareWrite () noexcept(false) override
void	writeDB (const EcalLogicID *ecid, const RunCommentDat *item, RunIOV *iov) noexcept(false)

Private Attributes
std::string	m_comment
std::string	m_source
Tm	m_time

Friends
class	EcalCondDBInterface

Additional Inherited Members
Static Public Attributes inherited from IDBObject
static int const	ECALDB_NROWS =1024
Protected Member Functions inherited from IDataItem
void	checkPrepare () noexcept(false)
void	createReadStatement () noexcept(false)
void	setPrefetchRowCount (int ncount) noexcept(false)
void	terminateReadStatement () noexcept(false)
void	terminateWriteStatement () noexcept(false)
Protected Member Functions inherited from IDBObject
void	checkConnection () const noexcept(false)
Protected Attributes inherited from IDataItem
oracle::occi::Statement *	m_readStmt
oracle::occi::Statement *	m_writeStmt
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Detailed Description

Definition at line 11 of file RunCommentDat.h.

Constructor & Destructor Documentation

RunCommentDat::RunCommentDat

(

)

Definition at line 16 of file RunCommentDat.cc.

{
  m_env = nullptr;
  m_conn = nullptr;
  m_writeStmt = nullptr;
  m_source = "";
  m_comment = "";
  m_time = Tm();
}

RunCommentDat::~RunCommentDat ( )

override

Definition at line 28 of file RunCommentDat.cc.

{
}

Member Function Documentation

void RunCommentDat::fetchData ( std::map< EcalLogicID, RunCommentDat > *  fillMap, RunIOV *  iov  )

privatenoexcept

Definition at line 74 of file RunCommentDat.cc.

References DateHandler::dateToTm(), cuy::dh, MillePedeFileConverter_cfg::e, EcalLogicID::NULLID, AlCaHLTBitMon_ParallelJobs::p, setComment(), and setSource().

Referenced by getDBTime().

{
  this->checkConnection();
  fillMap->clear();

  DateHandler dh(m_env, m_conn);

  iov->setConnection(m_env, m_conn);
  int iovID = iov->fetchID();
  if (!iovID) { 
    //  throw(std::runtime_error("RunCommentDat::writeDB:  IOV not in DB")); 
    return;
  }

  try {
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL("SELECT d.comment_id, "
         "d.source, d.user_comment, d.db_timestamp "
         "FROM run_comment_dat d "
         "WHERE d.iov_id = :iov_id order by d.logic_id ");
    stmt->setInt(1, iovID);
    ResultSet* rset = stmt->executeQuery();
    
    std::pair< EcalLogicID, RunCommentDat > p;
    RunCommentDat dat;
    while(rset->next()) {
      p.first = EcalLogicID( "Comment_order",
                 rset->getInt(1),  rset->getInt(1), 
                 EcalLogicID::NULLID, EcalLogicID::NULLID,        // comment number
                "Comment_order");    

      dat.setSource( rset->getString(2) );
      dat.setComment( rset->getString(3) );

      Date startDate = rset->getDate(4);
      m_time = dh.dateToTm( startDate );

      p.second = dat;
      fillMap->insert(p);
    }
    m_conn->terminateStatement(stmt);
  } catch (SQLException &e) {
    throw(std::runtime_error("RunCommentDat::fetchData():  "+e.getMessage()));
  }
}

std::string RunCommentDat::getComment ( ) const

inline

Definition at line 23 of file RunCommentDat.h.

References m_comment.

{ return m_comment; }

Tm RunCommentDat::getDBTime ( ) const

inline

Definition at line 25 of file RunCommentDat.h.

References fetchData(), m_time, noexcept, prepareWrite(), and writeDB().

{return m_time;}

std::string RunCommentDat::getSource ( ) const

inline

Definition at line 21 of file RunCommentDat.h.

References m_source.

{ return m_source; }

std::string RunCommentDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 18 of file RunCommentDat.h.

{ return "RUN_COMMENT_DAT"; }

void RunCommentDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 34 of file RunCommentDat.cc.

References MillePedeFileConverter_cfg::e.

Referenced by getDBTime().

{
  this->checkConnection();

  try {
    m_writeStmt = m_conn->createStatement();
    m_writeStmt->setSQL("INSERT INTO run_comment_dat (iov_id,  "
            "source, user_comment) "
            "VALUES (:iov_id,  "
            ":source, :user_comment)");
  } catch (SQLException &e) {
    throw(std::runtime_error("RunCommentDat::prepareWrite():  "+e.getMessage()));
  }
}

void RunCommentDat::setComment ( std::string  x )

inline

Definition at line 22 of file RunCommentDat.h.

References m_comment, and x.

Referenced by fetchData().

{ m_comment = x; }

void RunCommentDat::setDBTime ( const Tm &  x )

inline

Definition at line 24 of file RunCommentDat.h.

References m_time, and x.

{m_time=x;}

void RunCommentDat::setSource ( std::string  x )

inline

Definition at line 20 of file RunCommentDat.h.

References m_source, and x.

Referenced by fetchData().

{ m_source = x; }

void RunCommentDat::writeDB ( const EcalLogicID *  ecid, const RunCommentDat *  item, RunIOV *  iov  )

privatenoexcept

Definition at line 52 of file RunCommentDat.cc.

References MillePedeFileConverter_cfg::e.

Referenced by getDBTime().

{
  this->checkConnection();
  this->checkPrepare();

  int iovID = iov->fetchID();
  if (!iovID) { throw(std::runtime_error("RunCommentDat::writeDB:  IOV not in DB")); }
  
  try {
    m_writeStmt->setInt(1, iovID);
    m_writeStmt->setString(2, item->getSource());
    m_writeStmt->setString(3, item->getComment());
    
    m_writeStmt->executeUpdate();
  } catch (SQLException &e) {
    throw(std::runtime_error("RunCommentDat::writeDB():  "+e.getMessage()));
  }
}

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 13 of file RunCommentDat.h.

Member Data Documentation

std::string RunCommentDat::m_comment

private

Definition at line 39 of file RunCommentDat.h.

Referenced by getComment(), and setComment().

std::string RunCommentDat::m_source

private

Definition at line 38 of file RunCommentDat.h.

Referenced by getSource(), and setSource().

Tm RunCommentDat::m_time

private

Definition at line 40 of file RunCommentDat.h.

Referenced by getDBTime(), and setDBTime().