#include <DCSPTMTempList.h>

Inheritance diagram for DCSPTMTempList:

Public Member Functions
	DCSPTMTempList ()

void	fetchValuesForECID (const EcalLogicID &ecid) noexcept(false)

void	fetchValuesForECIDAndTime (const EcalLogicID &ecid, const Tm &start, const Tm &end) noexcept(false)

std::vector< DCSPTMTemp >	getList ()

	~DCSPTMTempList () override

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 Attributes
std::vector< DCSPTMTemp >	m_vec_temp

Friends
class	EcalCondDBInterface

Additional Inherited Members
Static Public Attributes inherited from IDBObject
static int const	ECALDB_NROWS = 1024

Protected Member Functions inherited from IDBObject
void	checkConnection () const noexcept(false)

Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn

oracle::occi::Environment *	m_env

Detailed Description

Definition at line 15 of file DCSPTMTempList.h.

Constructor & Destructor Documentation

DCSPTMTempList::DCSPTMTempList ( )

Definition at line 14 of file DCSPTMTempList.cc.

14 { m_conn = nullptr; }

IDBObject::m_conn

oracle::occi::Connection * m_conn

Definition: IDBObject.h:34

DCSPTMTempList::~DCSPTMTempList ( )

override

Definition at line 16 of file DCSPTMTempList.cc.

16 {}

Member Function Documentation

void DCSPTMTempList::fetchValuesForECID ( const EcalLogicID & ecid )

noexcept

Definition at line 20 of file DCSPTMTempList.cc.

References gather_cfg::cout, DateHandler::dateToTm(), cuy::dh, alignCSCRings::e, mps_fire::i, alignCSCRings::r, DCSPTMTemp::setEcalLogicID(), DCSPTMTemp::setEnd(), DCSPTMTemp::setStart(), DCSPTMTemp::setTemperature(), and x.

Referenced by EcalCondDBInterface::fetchDCSPTMTempList().

                                                                                {
   this->checkConnection();
   int nruns = 0;
 
   int ecid_id = ecid.getLogicID();
 
   try {
     Statement* stmt0 = m_conn->createStatement();
     stmt0->setSQL(
         "SELECT count(since) FROM PVSS_TEMPERATURE_DAT "
         "WHERE logic_id = :logic_id  ");
     stmt0->setInt(1, ecid_id);
 
     ResultSet* rset0 = stmt0->executeQuery();
     if (rset0->next()) {
       nruns = rset0->getInt(1);
     }
     m_conn->terminateStatement(stmt0);
 
     cout << "DCSPTMTempList::fetchValuesForECID>> Number of records in DB=" << nruns << endl;
     m_vec_temp.reserve(nruns);
 
     Statement* stmt = m_conn->createStatement();
     stmt->setSQL(
         "SELECT  "
         "since, till, temperature  FROM PVSS_TEMPERATURE_DAT "
         "WHERE logic_id = :logic_id  order by since ");
     stmt->setInt(1, ecid_id);
 
     DateHandler dh(m_env, m_conn);
     Tm runStart;
     Tm runEnd;
 
     ResultSet* rset = stmt->executeQuery();
     int i = 0;
     while (i < nruns) {
       rset->next();
 
       Date startDate = rset->getDate(1);
       Date endDate = rset->getDate(2);
       float x = rset->getFloat(3);
       runStart = dh.dateToTm(startDate);
       runEnd = dh.dateToTm(endDate);
 
       DCSPTMTemp r;
       r.setTemperature(x);
       r.setStart(runStart);
       r.setEnd(runEnd);
       r.setEcalLogicID(ecid);
       m_vec_temp.push_back(r);
 
       i++;
     }
 
     cout << "DCSPTMTempList::fetchValuesForECID>> loop done " << endl;
 
     m_conn->terminateStatement(stmt);
   } catch (SQLException& e) {
     throw(std::runtime_error("DCSPTMTempList:  " + e.getMessage()));
   }
 }

void DCSPTMTempList::fetchValuesForECIDAndTime	(	const EcalLogicID &	ecid,
		const Tm &	start,
		const Tm &	end
	)

noexcept

Definition at line 82 of file DCSPTMTempList.cc.

References gather_cfg::cout, DateHandler::dateToTm(), cuy::dh, alignCSCRings::e, dataset::end, mps_fire::i, alignCSCRings::r, DCSPTMTemp::setEcalLogicID(), DCSPTMTemp::setEnd(), DCSPTMTemp::setStart(), DCSPTMTemp::setTemperature(), command_line::start, DateHandler::tmToDate(), and x.

Referenced by EcalCondDBInterface::fetchDCSPTMTempList().

                                                                               {
   this->checkConnection();
   int nruns = 0;
 
   int ecid_id = ecid.getLogicID();
 
   DateHandler dh(m_env, m_conn);
   Tm runStart;
   Tm runEnd;
 
   try {
     Statement* stmt0 = m_conn->createStatement();
     stmt0->setSQL(
         "SELECT count(since) FROM PVSS_TEMPERATURE_DAT "
         "WHERE logic_id = :logic_id  "
         "AND since >= :start_time  "
         "AND since <= :till_time  ");
     stmt0->setInt(1, ecid_id);
     stmt0->setDate(2, dh.tmToDate(start));
     stmt0->setDate(3, dh.tmToDate(end));
 
     ResultSet* rset0 = stmt0->executeQuery();
     if (rset0->next()) {
       nruns = rset0->getInt(1);
     }
     m_conn->terminateStatement(stmt0);
 
     cout << "DCSPTMTempList::fetchValuesForECIDAndTime>> Number of records in DB=" << nruns << endl;
     m_vec_temp.reserve(nruns);
 
     Statement* stmt = m_conn->createStatement();
     stmt->setSQL(
         "SELECT  "
         "since, till, temperature  FROM PVSS_TEMPERATURE_DAT "
         "WHERE logic_id = :logic_id "
         "AND since >= :start_time  "
         "AND since <= :till_time  "
         " order by since ");
     stmt->setInt(1, ecid_id);
     stmt->setDate(2, dh.tmToDate(start));
     stmt->setDate(3, dh.tmToDate(end));
 
     ResultSet* rset = stmt->executeQuery();
     int i = 0;
     while (i < nruns) {
       rset->next();
 
       Date startDate = rset->getDate(1);
       Date endDate = rset->getDate(2);
       float x = rset->getFloat(3);
       runStart = dh.dateToTm(startDate);
       runEnd = dh.dateToTm(endDate);
 
       DCSPTMTemp r;
       r.setTemperature(x);
       r.setStart(runStart);
       r.setEnd(runEnd);
       r.setEcalLogicID(ecid);
       m_vec_temp.push_back(r);
 
       i++;
     }
 
     m_conn->terminateStatement(stmt);
   } catch (SQLException& e) {
     throw(std::runtime_error("DCSPTMTempList:  " + e.getMessage()));
   }
 }