#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 28 of file RunDCSMagnetDat.cc.

29 {

30 }

Member Function Documentation

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

privatenoexcept

Definition at line 62 of file RunDCSMagnetDat.cc.

References gather_cfg::cout.

Referenced by getMagnetCurrent().

 {
 
   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 153 of file RunDCSMagnetDat.cc.

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

Referenced by getMagnetCurrent().

 {
   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():  ")+getOraMessage(&e)));
 #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 99 of file RunDCSMagnetDat.cc.

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

Referenced by getMagnetCurrent().

                                                                  {
 
   // 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( getOraString(rset,1),     // name
                  rset->getInt(2),        // logic_id
                  rset->getInt(3),        // id1
                  rset->getInt(4),        // id2
                  rset->getInt(5),        // id3
                  getOraString(rset,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():  ")+getOraMessage(&e)));
 #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.

25 { return "CMS_DCS_ENV_PVSS_COND"; }

float RunDCSMagnetDat::getMagnetCurrent ( ) const

inline

Definition at line 27 of file RunDCSMagnetDat.h.

References fetchData(), fetchLastData(), fillTheMap(), getMagnetRset(), getTime(), m_current, noexcept, nowMicroseconds(), prepareWrite(), setTime(), and writeDB().

Referenced by popcon::EcalADCToGeVHandler::getNewObjects(), and popcon::EcalIntercalibHandler::getNewObjects().

27 { return m_current; }

RunDCSMagnetDat::m_current

float m_current

Definition: RunDCSMagnetDat.h:53

ResultSet * RunDCSMagnetDat::getMagnetRset ( )

private

Definition at line 73 of file RunDCSMagnetDat.cc.

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

Referenced by getMagnetCurrent().

                                           {
 
   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():  ") + getOraMessage(&e) + " " + 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.

24 { return "CMSFWMAGNET_LV"; }

Tm RunDCSMagnetDat::getTime ( void ) const

Definition at line 37 of file RunDCSMagnetDat.cc.

Referenced by getMagnetCurrent().

 {
   return m_time;
 }

int RunDCSMagnetDat::nowMicroseconds ( )

private

Definition at line 143 of file RunDCSMagnetDat.cc.

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

Referenced by getMagnetCurrent().

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