RunDCSMagnetDat Class Reference

#include <RunDCSMagnetDat.h>

Inheritance diagram for RunDCSMagnetDat:

Public Types
typedef oracle::occi::ResultSet	ResultSet

Public Member Functions
std::string	getMagnetAccount ()
float	getMagnetCurrent () const
std::string	getTable () override
Tm	getTime () const
	RunDCSMagnetDat ()
void	setMagnetCurrent (float t)
void	setTime (const Tm &start)
	~RunDCSMagnetDat () 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, RunDCSMagnetDat > *fillMap, RunIOV *iov) noexcept(false)
void	fetchLastData (std::map< EcalLogicID, RunDCSMagnetDat > *fillMap) noexcept(false)
void	fillTheMap (ResultSet *, std::map< EcalLogicID, RunDCSMagnetDat > *)
ResultSet *	getMagnetRset ()
int	nowMicroseconds ()
void	prepareWrite () noexcept(false) override
void	writeDB (const EcalLogicID *ecid, const RunDCSMagnetDat *item, RunIOV *iov) noexcept(false)

Private Attributes
float	m_current
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 15 of file RunDCSMagnetDat.h.

Member Typedef Documentation

typedef oracle::occi::ResultSet RunDCSMagnetDat::ResultSet

Definition at line 17 of file RunDCSMagnetDat.h.

Constructor & Destructor Documentation

RunDCSMagnetDat::RunDCSMagnetDat

(

)

Definition at line 15 of file RunDCSMagnetDat.cc.

                                 {
  m_env = nullptr;
  m_conn = nullptr;
  m_writeStmt = nullptr;
  m_readStmt = nullptr;

  m_current = 0;
  m_time = Tm();
}

RunDCSMagnetDat::~RunDCSMagnetDat ( )

override

Definition at line 25 of file RunDCSMagnetDat.cc.

{}

Member Function Documentation

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

privatenoexcept

Definition at line 35 of file RunDCSMagnetDat.cc.

References gather_cfg::cout.

                                                                                                       {
  std::cout << "going to call fetchLastData" << std::endl;
  fetchLastData(fillMap);
  std::cout << "returned from fetchLastData" << std::endl;
}

void RunDCSMagnetDat::fetchLastData ( std::map< EcalLogicID, RunDCSMagnetDat > *  fillMap )

privatenoexcept

Definition at line 111 of file RunDCSMagnetDat.cc.

References gather_cfg::cout, dat, alignCSCRings::e, AlCaHLTBitMon_ParallelJobs::p, AlCaHLTBitMon_QueryRunRegistry::string, and cond::impl::to_string().

                                                                                              {
  this->checkConnection();

  std::cout << "fetchLastData>>1" << std::endl;

  fillMap->clear();

  std::cout << "fetchLastData>>2" << std::endl;

  try {
    std::pair<EcalLogicID, RunDCSMagnetDat> p;
    RunDCSMagnetDat dat;
    std::cout << "fetchLastData>>3" << std::endl;

    ResultSet* rset = getMagnetRset();

    std::cout << "fetchLastData>>4" << std::endl;

    fillTheMap(rset, fillMap);
    std::cout << "fetchLastData>>5" << std::endl;

  } catch (SQLException& e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSMagnetDat::fetchData():  ") + e.getMessage()));
#else
    throw(std::runtime_error(std::string("RunDCSMagnetDat::fetchData():  error code ") +
                             std::to_string(e.getErrorCode())));
#endif
  }
}

void RunDCSMagnetDat::fillTheMap ( ResultSet *  rset, std::map< EcalLogicID, RunDCSMagnetDat > *  fillMap  )

private

Definition at line 64 of file RunDCSMagnetDat.cc.

References gather_cfg::cout, dat, DateHandler::dateToTm(), cuy::dh, alignCSCRings::e, AlCaHLTBitMon_ParallelJobs::p, setMagnetCurrent(), setTime(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::impl::to_string().

                                                                                            {
  // method for last value queries

  std::pair<EcalLogicID, RunDCSMagnetDat> p;
  RunDCSMagnetDat dat;
  DateHandler dh(m_env, m_conn);

  try {
    while (rset->next()) {
      p.first = EcalLogicID(rset->getString(1),   // name
                            rset->getInt(2),      // logic_id
                            rset->getInt(3),      // id1
                            rset->getInt(4),      // id2
                            rset->getInt(5),      // id3
                            rset->getString(6));  // maps_to

      std::cout << "done the logic id" << std::endl;
      dat.setMagnetCurrent(rset->getFloat(7));
      std::cout << "done the magnet current" << std::endl;

      Date sinceDate = rset->getDate(8);
      std::cout << "done the date" << std::endl;

      Tm sinceTm = dh.dateToTm(sinceDate);
      dat.setTime(sinceTm);

      p.second = dat;
      fillMap->insert(p);
    }
  } catch (SQLException& e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSMagnetDat::fetchData():  ") + e.getMessage()));
#else
    throw(std::runtime_error(std::string("RunDCSMagnetDat::fetchData():  error code ") +
                             std::to_string(e.getErrorCode())));
#endif
  }
}

std::string RunDCSMagnetDat::getMagnetAccount ( )

inline

Definition at line 25 of file RunDCSMagnetDat.h.

{ return "CMS_DCS_ENV_PVSS_COND"; }

float RunDCSMagnetDat::getMagnetCurrent ( ) const

inline

Definition at line 27 of file RunDCSMagnetDat.h.

References m_current.

Referenced by popcon::EcalADCToGeVHandler::getNewObjects().

{ return m_current; }

ResultSet * RunDCSMagnetDat::getMagnetRset ( )

private

Definition at line 41 of file RunDCSMagnetDat.cc.

References gather_cfg::cout, cuy::dh, alignCSCRings::e, contentValuesFiles::query, AlCaHLTBitMon_QueryRunRegistry::string, and cond::impl::to_string().

                                          {
  DateHandler dh(m_env, m_conn);

  ResultSet* rset = nullptr;
  string query = "SELECT c.name, c.logic_id, c.id1, c.id2, c.id3, c.maps_to , v.value_number, v.change_date from " +
                 getMagnetAccount() +
                 ".CMSFWMAGNET_LV v, channelview c where v.dpe_name= 'CURRENT' and  c.name=maps_to and c.name='EB' ";
  try {
    std::cout << "query:" << query << std::endl;

    m_readStmt->setSQL(query);
    rset = m_readStmt->executeQuery();
  } catch (SQLException& e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSMagnetDat::getBarrelRset():  ") + e.getMessage() + " " + query));
#else
    throw(std::runtime_error(std::string("RunDCSMagnetDat::getBarrelRset():  error code ") +
                             std::to_string(e.getErrorCode()) + " " + query));
#endif
  }
  return rset;
}

std::string RunDCSMagnetDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 24 of file RunDCSMagnetDat.h.

{ return "CMSFWMAGNET_LV"; }

Tm RunDCSMagnetDat::getTime

(

void

)

const

Definition at line 29 of file RunDCSMagnetDat.cc.

{ return m_time; }

int RunDCSMagnetDat::nowMicroseconds ( )

private

Definition at line 103 of file RunDCSMagnetDat.cc.

References Tm::microsTime(), and Tm::setToCurrentGMTime().

                                     {
  Tm t_now_gmt;

  t_now_gmt.setToCurrentGMTime();
  int t_now_gmt_micros = t_now_gmt.microsTime();
  return t_now_gmt_micros;
}

void RunDCSMagnetDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 31 of file RunDCSMagnetDat.cc.

{}

void RunDCSMagnetDat::setMagnetCurrent ( float  t )

inline

Definition at line 26 of file RunDCSMagnetDat.h.

References m_current, and submitPVValidationJobs::t.

Referenced by fillTheMap().

{ m_current = t; }

void RunDCSMagnetDat::setTime

(

const Tm &

start

)

Definition at line 27 of file RunDCSMagnetDat.cc.

References command_line::start.

Referenced by fillTheMap().

{ m_time = start; }

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

privatenoexcept

Definition at line 33 of file RunDCSMagnetDat.cc.

{}

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 19 of file RunDCSMagnetDat.h.

Member Data Documentation

float RunDCSMagnetDat::m_current

private

Definition at line 48 of file RunDCSMagnetDat.h.

Referenced by getMagnetCurrent(), and setMagnetCurrent().

Tm RunDCSMagnetDat::m_time

private

Definition at line 49 of file RunDCSMagnetDat.h.