#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 ()

Tm	getTime () const

	RunDCSMagnetDat ()

void	setMagnetCurrent (float t)

void	setTime (Tm start)

	~RunDCSMagnetDat ()

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) throw (std::runtime_error)

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

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

ResultSet *	getMagnetRset ()

int	nowMicroseconds ()

void	prepareWrite () throw (std::runtime_error)

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

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 () throw (std::runtime_error)

void	createReadStatement () throw (std::runtime_error)

void	setPrefetchRowCount (int ncount) throw (std::runtime_error)

void	terminateReadStatement () throw (std::runtime_error)

void	terminateWriteStatement () throw (std::runtime_error)

Protected Member Functions inherited from IDBObject
void	checkConnection () const throw (std::runtime_error)

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.

References NULL.

 {
   m_env = NULL;
   m_conn = NULL;
   m_writeStmt = NULL;
   m_readStmt = NULL;
 
   m_current = 0;
   m_time=Tm();
 }

RunDCSMagnetDat::~RunDCSMagnetDat ( )

Definition at line 28 of file RunDCSMagnetDat.cc.

29 {

30 }

Member Function Documentation

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

private

Definition at line 62 of file RunDCSMagnetDat.cc.

References gather_cfg::cout, and edm::pset::fillMap().

 {
 
   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	)
throw	(	std::runtime_error
	)

private

Definition at line 145 of file RunDCSMagnetDat.cc.

References gather_cfg::cout, alignCSCRings::e, edm::pset::fillMap(), and AlCaHLTBitMon_ParallelJobs::p.

 {
   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) {
     throw(std::runtime_error("RunDCSMagnetDat::fetchData():  "+e.getMessage()));
   }
 }

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

private

Definition at line 95 of file RunDCSMagnetDat.cc.

References gather_cfg::cout, DateHandler::dateToTm(), alignCSCRings::e, AlCaHLTBitMon_ParallelJobs::p, setMagnetCurrent(), and setTime().

                                                                  {
 
   // 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) {
     throw(std::runtime_error("RunDCSMagnetDat::fetchData():  "+e.getMessage()));
   }
 }

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

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, alignCSCRings::e, NULL, and o2o::query.

                                           {
 
   DateHandler dh(m_env, m_conn);
 
   ResultSet* rset = NULL;
   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) {
     throw(std::runtime_error("RunDCSMagnetDat::getBarrelRset():  " + e.getMessage() + " " + query));
   }
   return rset;
 }

std::string RunDCSMagnetDat::getTable ( )

inlinevirtual

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.

 {
   return m_time;
 }

int RunDCSMagnetDat::nowMicroseconds ( )

private

Definition at line 135 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;
 }