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 const int	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

ResultSet

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

Definition at line 17 of file RunDCSMagnetDat.h.

Constructor & Destructor Documentation

RunDCSMagnetDat()

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::~RunDCSMagnetDat ( )

override

Definition at line 25 of file RunDCSMagnetDat.cc.

{}

Member Function Documentation

fetchData()

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

privatenoexcept

Definition at line 35 of file RunDCSMagnetDat.cc.

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

References gather_cfg::cout.

fetchLastData()

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

privatenoexcept

Definition at line 111 of file RunDCSMagnetDat.cc.

                                                                                              {
  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
  }
}

References gather_cfg::cout, MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, and AlCaHLTBitMon_QueryRunRegistry::string.

fillTheMap()

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

private

Definition at line 64 of file RunDCSMagnetDat.cc.

                                                                                            {
  // 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
  }
}

References gather_cfg::cout, cuy::dh, MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, setMagnetCurrent(), setTime(), and AlCaHLTBitMon_QueryRunRegistry::string.

getMagnetAccount()

std::string RunDCSMagnetDat::getMagnetAccount ( )

inline

Definition at line 25 of file RunDCSMagnetDat.h.

{ return "CMS_DCS_ENV_PVSS_COND"; }

getMagnetCurrent()

float RunDCSMagnetDat::getMagnetCurrent ( ) const

inline

Definition at line 27 of file RunDCSMagnetDat.h.

{ return m_current; }

References m_current.

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

getMagnetRset()

ResultSet * RunDCSMagnetDat::getMagnetRset ( )

private

Definition at line 41 of file RunDCSMagnetDat.cc.

                                          {
  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;
}

References gather_cfg::cout, cuy::dh, MillePedeFileConverter_cfg::e, contentValuesFiles::query, and AlCaHLTBitMon_QueryRunRegistry::string.

getTable()

std::string RunDCSMagnetDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 24 of file RunDCSMagnetDat.h.

{ return "CMSFWMAGNET_LV"; }

getTime()

Tm RunDCSMagnetDat::getTime

(

void

)

const

Definition at line 29 of file RunDCSMagnetDat.cc.

{ return m_time; }

nowMicroseconds()

int RunDCSMagnetDat::nowMicroseconds ( )

private

Definition at line 103 of file RunDCSMagnetDat.cc.

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

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

prepareWrite()

void RunDCSMagnetDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 31 of file RunDCSMagnetDat.cc.

{}

setMagnetCurrent()

void RunDCSMagnetDat::setMagnetCurrent ( float  t )

inline

Definition at line 26 of file RunDCSMagnetDat.h.

{ m_current = t; }

References m_current, and submitPVValidationJobs::t.

Referenced by fillTheMap().

setTime()

void RunDCSMagnetDat::setTime

(

const Tm &

start

)

Definition at line 27 of file RunDCSMagnetDat.cc.

{ m_time = start; }

References command_line::start.

Referenced by fillTheMap().

writeDB()

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

EcalCondDBInterface

friend class EcalCondDBInterface

friend

Definition at line 19 of file RunDCSMagnetDat.h.

Member Data Documentation

m_current

float RunDCSMagnetDat::m_current

private

Definition at line 48 of file RunDCSMagnetDat.h.

Referenced by getMagnetCurrent(), and setMagnetCurrent().

m_time

Tm RunDCSMagnetDat::m_time

private

Definition at line 49 of file RunDCSMagnetDat.h.