#include <ITimingDat.h>

Inheritance diagram for ITimingDat:

Public Types
typedef oracle::occi::ResultSet	ResultSet

typedef oracle::occi::SQLException	SQLException

Public Member Functions
std::string	getTable () override

bool	getTaskStatus () const

float	getTimingMean () const

float	getTimingRMS () const

	ITimingDat ()

void	setTable (std::string x)

void	setTaskStatus (bool status)

void	setTimingMean (float mean)

void	setTimingRMS (float rms)

	~ITimingDat () 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
template<class DATT , class IOVT >
void	fetchData (std::map< EcalLogicID, DATT > fillMap, IOVT iov) noexcept(false)

void	prepareWrite () noexcept(false) override

template<class DATT , class IOVT >
void	writeArrayDB (const std::map< EcalLogicID, DATT > data, IOVT iov) noexcept(false)

template<class DATT , class IOVT >
void	writeDB (const EcalLogicID ecid, const DATT item, IOVT *iov) noexcept(false)

Private Attributes
std::string	m_table_name

bool	m_taskStatus

float	m_timingMean

float	m_timingRMS

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 17 of file ITimingDat.h.

Member Typedef Documentation

◆ ResultSet

typedef oracle::occi::ResultSet ITimingDat::ResultSet

Definition at line 20 of file ITimingDat.h.

◆ SQLException

typedef oracle::occi::SQLException ITimingDat::SQLException

Definition at line 19 of file ITimingDat.h.

Constructor & Destructor Documentation

◆ ITimingDat()

ITimingDat::ITimingDat ( )

inline

Definition at line 23 of file ITimingDat.h.

                {
     m_env = nullptr;
     m_conn = nullptr;
     m_writeStmt = nullptr;
     m_readStmt = nullptr;
  
     m_timingMean = 0;
     m_timingRMS = 0;
     m_taskStatus = false;
   };

References IDBObject::m_conn, IDBObject::m_env, IDataItem::m_readStmt, m_taskStatus, m_timingMean, m_timingRMS, and IDataItem::m_writeStmt.

◆ ~ITimingDat()

ITimingDat::~ITimingDat ( )

inlineoverride

Definition at line 34 of file ITimingDat.h.

34 {};

Member Function Documentation

◆ fetchData()

template<class DATT , class IOVT >

void ITimingDat::fetchData	(	std::map< EcalLogicID, DATT > *	fillMap,
		IOVT *	iov
	)

inlineprivatenoexcept

Definition at line 181 of file ITimingDat.h.

                                                                                 {
     this->checkConnection();
     fillMap->clear();
  
     iov->setConnection(m_env, m_conn);
     int iovID = iov->fetchID();
     if (!iovID) {
       //  throw(std::runtime_error("ITimingDat::writeDB:  IOV not in DB"));
       return;
     }
  
     try {
       m_readStmt->setSQL(
           "SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
           "d.timing_mean, d.timing_rms, d.task_status "
           "FROM channelview cv JOIN " +
           getTable() +
           "  d "
           "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
           "WHERE d.iov_id = :iov_id");
       m_readStmt->setInt(1, iovID);
       ResultSet* rset = m_readStmt->executeQuery();
  
       std::pair<EcalLogicID, DATT> p;
       DATT dat;
       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
  
         dat.setTimingMean(rset->getFloat(7));
         dat.setTimingRMS(rset->getFloat(8));
         dat.setTaskStatus(rset->getInt(9));
  
         p.second = dat;
         fillMap->insert(p);
       }
  
     } catch (SQLException& e) {
       throw(std::runtime_error("ITimingDat::fetchData():  " + e.getMessage()));
     }
   }

References IDBObject::checkConnection(), MillePedeFileConverter_cfg::e, getTable(), IDBObject::m_conn, IDBObject::m_env, IDataItem::m_readStmt, and AlCaHLTBitMon_ParallelJobs::p.

◆ getTable()

std::string ITimingDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Reimplemented in MonTimingLaserBlueCrystalDat, MonTimingCrystalDat, MonTimingLaserBlueTTDat, MonTimingLaserGreenCrystalDat, MonTimingLaserGreenTTDat, MonTimingLaserIRedCrystalDat, MonTimingLaserIRedTTDat, MonTimingLaserRedCrystalDat, MonTimingLaserRedTTDat, MonTimingLed1CrystalDat, MonTimingLed1TTDat, MonTimingLed2CrystalDat, MonTimingLed2TTDat, and MonTimingTTDat.

Definition at line 37 of file ITimingDat.h.

37 { return m_table_name; }

References m_table_name.

Referenced by fetchData(), and prepareWrite().

◆ getTaskStatus()

bool ITimingDat::getTaskStatus ( ) const

inline

Definition at line 47 of file ITimingDat.h.

47 { return m_taskStatus; }

References m_taskStatus.

◆ getTimingMean()

float ITimingDat::getTimingMean ( ) const

inline

Definition at line 41 of file ITimingDat.h.

41 { return m_timingMean; }

References m_timingMean.

◆ getTimingRMS()

float ITimingDat::getTimingRMS ( ) const

inline

Definition at line 44 of file ITimingDat.h.

44 { return m_timingRMS; }

References m_timingRMS.

◆ prepareWrite()

void ITimingDat::prepareWrite ( )

inlineoverrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 50 of file ITimingDat.h.

                                                {
     this->checkConnection();
  
     try {
       m_writeStmt = m_conn->createStatement();
       m_writeStmt->setSQL("INSERT INTO " + getTable() +
                           " (iov_id, logic_id, "
                           "timing_mean, timing_rms , task_status ) "
                           "VALUES (:iov_id, :logic_id, "
                           ":timing_mean, :timing_rms, :task_status )");
     } catch (SQLException& e) {
       throw(std::runtime_error("ITimingDat::prepareWrite():  " + e.getMessage()));
     }
   }

References IDBObject::checkConnection(), MillePedeFileConverter_cfg::e, getTable(), IDBObject::m_conn, and IDataItem::m_writeStmt.

◆ setTable()

void ITimingDat::setTable ( std::string x )

inline

Definition at line 38 of file ITimingDat.h.

38 { m_table_name = x; }

References m_table_name, and x.

◆ setTaskStatus()

void ITimingDat::setTaskStatus ( bool status )

inline

Definition at line 46 of file ITimingDat.h.

46 { m_taskStatus = status; }

References m_taskStatus, and mps_update::status.

Referenced by ecaldqm::LaserWriter::run(), and ecaldqm::LedWriter::run().

◆ setTimingMean()

void ITimingDat::setTimingMean ( float mean )

inline

Definition at line 40 of file ITimingDat.h.

40 { m_timingMean = mean; }

References m_timingMean, and SiStripPI::mean.

Referenced by ecaldqm::LaserWriter::run(), and ecaldqm::LedWriter::run().

◆ setTimingRMS()

void ITimingDat::setTimingRMS ( float rms )

inline

Definition at line 43 of file ITimingDat.h.

43 { m_timingRMS = rms; }

References m_timingRMS, and SiStripPI::rms.

Referenced by ecaldqm::LaserWriter::run(), and ecaldqm::LedWriter::run().

◆ writeArrayDB()

template<class DATT , class IOVT >

void ITimingDat::writeArrayDB	(	const std::map< EcalLogicID, DATT > *	data,
		IOVT *	iov
	)

inlineprivatenoexcept

Definition at line 95 of file ITimingDat.h.

                                                                                       {
     using oracle::occi::OCCIFLOAT;
     using oracle::occi::OCCIINT;
  
     this->checkConnection();
     this->checkPrepare();
  
     int iovID = iov->fetchID();
     if (!iovID) {
       throw(std::runtime_error("ITimingDat::writeArrayDB:  IOV not in DB"));
     }
  
     int nrows = data->size();
     int* ids = new int[nrows];
     int* iovid_vec = new int[nrows];
     float* xx = new float[nrows];
     float* yy = new float[nrows];
     int* st = new int[nrows];
  
     ub2* ids_len = new ub2[nrows];
     ub2* iov_len = new ub2[nrows];
     ub2* x_len = new ub2[nrows];
     ub2* y_len = new ub2[nrows];
     ub2* st_len = new ub2[nrows];
  
     const EcalLogicID* channel;
     const DATT* dataitem;
     int count = 0;
     //  typedef std::map< EcalLogicID, DATT >::const_iterator CI;
     typedef typename std::map<EcalLogicID, DATT>::const_iterator CI;
     for (CI p = data->begin(); p != data->end(); ++p) {
       channel = &(p->first);
       int logicID = channel->getLogicID();
       if (!logicID) {
         throw(std::runtime_error("ITimingDat::writeArrayDB:  Bad EcalLogicID"));
       }
       ids[count] = logicID;
       iovid_vec[count] = iovID;
  
       dataitem = &(p->second);
  
       float x = dataitem->getTimingMean();
       float y = dataitem->getTimingRMS();
       int statu = dataitem->getTaskStatus();
  
       xx[count] = x;
       yy[count] = y;
       st[count] = statu;
  
       ids_len[count] = sizeof(ids[count]);
       iov_len[count] = sizeof(iovid_vec[count]);
  
       x_len[count] = sizeof(xx[count]);
       y_len[count] = sizeof(yy[count]);
       st_len[count] = sizeof(st[count]);
  
       count++;
     }
  
     try {
       m_writeStmt->setDataBuffer(1, (dvoid*)iovid_vec, OCCIINT, sizeof(iovid_vec[0]), iov_len);
       m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len);
       m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIFLOAT, sizeof(xx[0]), x_len);
       m_writeStmt->setDataBuffer(4, (dvoid*)yy, OCCIFLOAT, sizeof(yy[0]), y_len);
       m_writeStmt->setDataBuffer(5, (dvoid*)st, OCCIINT, sizeof(st[0]), st_len);
  
       m_writeStmt->executeArrayUpdate(nrows);
  
       delete[] ids;
       delete[] iovid_vec;
       delete[] xx;
       delete[] yy;
       delete[] st;
  
       delete[] ids_len;
       delete[] iov_len;
       delete[] x_len;
       delete[] y_len;
       delete[] st_len;
  
     } catch (SQLException& e) {
       throw(std::runtime_error("ITimingDat::writeArrayDB():  " + e.getMessage()));
     }
   }

References IDBObject::checkConnection(), IDataItem::checkPrepare(), submitPVResolutionJobs::count, data, MillePedeFileConverter_cfg::e, EcalLogicID::getLogicID(), IDataItem::m_writeStmt, AlCaHLTBitMon_ParallelJobs::p, x, geometryCSVtoXML::xx, y, and geometryCSVtoXML::yy.

◆ writeDB()

template<class DATT , class IOVT >

void ITimingDat::writeDB	(	const EcalLogicID *	ecid,
		const DATT *	item,
		IOVT *	iov
	)

inlineprivatenoexcept

Definition at line 66 of file ITimingDat.h.

                                                                                      {
     this->checkConnection();
     this->checkPrepare();
  
     int iovID = iov->fetchID();
     if (!iovID) {
       throw(std::runtime_error("ITimingDat::writeDB:  IOV not in DB"));
     }
  
     int logicID = ecid->getLogicID();
     if (!logicID) {
       throw(std::runtime_error("ITimingDat::writeDB:  Bad EcalLogicID"));
     }
  
     try {
       m_writeStmt->setInt(1, iovID);
       m_writeStmt->setInt(2, logicID);
  
       m_writeStmt->setFloat(3, item->getTimingMean());
       m_writeStmt->setFloat(4, item->getTimingRMS());
       m_writeStmt->setInt(5, item->getTaskStatus());
  
       m_writeStmt->executeUpdate();
     } catch (SQLException& e) {
       throw(std::runtime_error("ITimingDat::writeDB():  " + e.getMessage()));
     }
   }

References IDBObject::checkConnection(), IDataItem::checkPrepare(), MillePedeFileConverter_cfg::e, B2GTnPMonitor_cfi::item, and IDataItem::m_writeStmt.

Friends And Related Function Documentation

◆ EcalCondDBInterface

friend class EcalCondDBInterface

friend

Definition at line 21 of file ITimingDat.h.

Member Data Documentation

◆ m_table_name

std::string ITimingDat::m_table_name

private

Definition at line 231 of file ITimingDat.h.

Referenced by getTable(), and setTable().

◆ m_taskStatus

bool ITimingDat::m_taskStatus

private

Definition at line 230 of file ITimingDat.h.

Referenced by getTaskStatus(), ITimingDat(), and setTaskStatus().

◆ m_timingMean

float ITimingDat::m_timingMean

private

Definition at line 228 of file ITimingDat.h.

Referenced by getTimingMean(), ITimingDat(), and setTimingMean().

◆ m_timingRMS

float ITimingDat::m_timingRMS

private

Definition at line 229 of file ITimingDat.h.

Referenced by getTimingRMS(), ITimingDat(), and setTimingRMS().

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ResultSet

◆ SQLException

Constructor & Destructor Documentation

◆ ITimingDat()

◆ ~ITimingDat()

Member Function Documentation

◆ fetchData()

◆ getTable()

◆ getTaskStatus()

◆ getTimingMean()

◆ getTimingRMS()

◆ prepareWrite()

◆ setTable()

◆ setTaskStatus()

◆ setTimingMean()

◆ setTimingRMS()

◆ writeArrayDB()

◆ writeDB()

Friends And Related Function Documentation

◆ EcalCondDBInterface

Member Data Documentation

◆ m_table_name

◆ m_taskStatus

◆ m_timingMean

◆ m_timingRMS