#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

◆ 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.

25 {}

Member Function Documentation

◆ fetchData()

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

◆ fetchLastData()

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

privatenoexcept

Definition at line 111 of file RunDCSMagnetDat.cc.

References gather_cfg::cout, MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, AlCaHLTBitMon_QueryRunRegistry::string, and 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
   }
 }

◆ fillTheMap()

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

private

Definition at line 64 of file RunDCSMagnetDat.cc.

References gather_cfg::cout, cuy::dh, MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, setMagnetCurrent(), setTime(), AlCaHLTBitMon_QueryRunRegistry::string, and 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
   }
 }

◆ getMagnetAccount()

std::string RunDCSMagnetDat::getMagnetAccount ( )

inline

Definition at line 25 of file RunDCSMagnetDat.h.

25 { return "CMS_DCS_ENV_PVSS_COND"; }

◆ getMagnetCurrent()

float RunDCSMagnetDat::getMagnetCurrent ( ) const

inline

Definition at line 27 of file RunDCSMagnetDat.h.

References m_current.

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

27 { return m_current; }

RunDCSMagnetDat::m_current

float m_current

Definition: RunDCSMagnetDat.h:48

◆ getMagnetRset()

ResultSet * RunDCSMagnetDat::getMagnetRset ( )

private

Definition at line 41 of file RunDCSMagnetDat.cc.

References gather_cfg::cout, cuy::dh, MillePedeFileConverter_cfg::e, contentValuesFiles::query, AlCaHLTBitMon_QueryRunRegistry::string, and 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;
 }

◆ getTable()

std::string RunDCSMagnetDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 24 of file RunDCSMagnetDat.h.

24 { return "CMSFWMAGNET_LV"; }

◆ getTime()

Tm RunDCSMagnetDat::getTime ( void ) const

Definition at line 29 of file RunDCSMagnetDat.cc.

29 { return m_time; }

RunDCSMagnetDat::m_time

Tm m_time

Definition: RunDCSMagnetDat.h:49

◆ nowMicroseconds()

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