#include <CaliCrystalIntercalDat.h>

Inheritance diagram for CaliCrystalIntercalDat:

Public Member Functions
	CaliCrystalIntercalDat ()

float	getCali () const

float	getCaliRMS () const

int	getNumEvents () const

std::string	getTable () override

bool	getTaskStatus () const

void	setCali (float c)

void	setCaliRMS (float c)

void	setNumEvents (int n)

void	setTaskStatus (bool s)

	~CaliCrystalIntercalDat () 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, CaliCrystalIntercalDat > fillVec, CaliIOV iov) noexcept(false)

void	prepareWrite () noexcept(false) override

void	writeArrayDB (const std::map< EcalLogicID, CaliCrystalIntercalDat > data, CaliIOV iov) noexcept(false)

void	writeDB (const EcalLogicID ecid, const CaliCrystalIntercalDat item, CaliIOV *iov) noexcept(false)

Private Attributes
float	m_cali

float	m_caliRMS

int	m_numEvents

bool	m_taskStatus

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 12 of file CaliCrystalIntercalDat.h.

Constructor & Destructor Documentation

◆ CaliCrystalIntercalDat()

CaliCrystalIntercalDat::CaliCrystalIntercalDat ( )

Definition at line 12 of file CaliCrystalIntercalDat.cc.

                                                {
   m_env = nullptr;
   m_conn = nullptr;
   m_writeStmt = nullptr;
  
   m_cali = 0;
   m_caliRMS = 0;
   m_numEvents = 0;
   m_taskStatus = false;
 }

◆ ~CaliCrystalIntercalDat()

CaliCrystalIntercalDat::~CaliCrystalIntercalDat ( )

override

Definition at line 23 of file CaliCrystalIntercalDat.cc.

23 {}

Member Function Documentation

◆ fetchData()

void CaliCrystalIntercalDat::fetchData	(	std::map< EcalLogicID, CaliCrystalIntercalDat > *	fillVec,
		CaliIOV *	iov
	)

privatenoexcept

Definition at line 71 of file CaliCrystalIntercalDat.cc.

                                                                      {
   this->checkConnection();
   fillMap->clear();
  
   iov->setConnection(m_env, m_conn);
   int iovID = iov->fetchID();
   if (!iovID) {
     //  throw(std::runtime_error("CaliCrystalIntercalDat::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.cali, d.cali_rms, d.num_events, d.task_status "
         "FROM channelview cv JOIN cali_crystal_intercal_dat 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, CaliCrystalIntercalDat> p;
     CaliCrystalIntercalDat 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.setCali(rset->getFloat(7));
       dat.setCaliRMS(rset->getFloat(8));
       dat.setNumEvents(rset->getInt(9));
       dat.setTaskStatus(rset->getInt(10));
  
       p.second = dat;
       fillMap->insert(p);
     }
   } catch (SQLException& e) {
     throw(std::runtime_error("CaliCrystalIntercalDat::fetchData():  " + e.getMessage()));
   }
 }

References MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, setCali(), setCaliRMS(), setNumEvents(), and setTaskStatus().

◆ getCali()

float CaliCrystalIntercalDat::getCali ( ) const

inline

Definition at line 22 of file CaliCrystalIntercalDat.h.

22 { return m_cali; }

References m_cali.

Referenced by writeArrayDB().

◆ getCaliRMS()

float CaliCrystalIntercalDat::getCaliRMS ( ) const

inline

Definition at line 25 of file CaliCrystalIntercalDat.h.

25 { return m_caliRMS; }

References m_caliRMS.

Referenced by writeArrayDB().

◆ getNumEvents()

int CaliCrystalIntercalDat::getNumEvents ( ) const

inline

Definition at line 28 of file CaliCrystalIntercalDat.h.

28 { return m_numEvents; }

References m_numEvents.

Referenced by writeArrayDB().

◆ getTable()

std::string CaliCrystalIntercalDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 19 of file CaliCrystalIntercalDat.h.

19 { return "CALI_CRYSTAL_INTERCAL_DAT"; }

◆ getTaskStatus()

bool CaliCrystalIntercalDat::getTaskStatus ( ) const

inline

Definition at line 31 of file CaliCrystalIntercalDat.h.

31 { return m_taskStatus; }

References m_taskStatus.

Referenced by writeArrayDB().

◆ prepareWrite()

void CaliCrystalIntercalDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 25 of file CaliCrystalIntercalDat.cc.

                                                           {
   this->checkConnection();
  
   try {
     m_writeStmt = m_conn->createStatement();
     m_writeStmt->setSQL(
         "INSERT INTO cali_crystal_intercal_dat (iov_id, logic_id, "
         "cali, cali_rms, num_events, task_status) "
         "VALUES (:iov_id, :logic_id, "
         ":3, :4, :5, :6)");
   } catch (SQLException& e) {
     throw(std::runtime_error("CaliCrystalIntercalDat::prepareWrite():  " + e.getMessage()));
   }
 }

References MillePedeFileConverter_cfg::e.

◆ setCali()

void CaliCrystalIntercalDat::setCali ( float c )

inline

Definition at line 21 of file CaliCrystalIntercalDat.h.

21 { m_cali = c; }

References c, and m_cali.

Referenced by fetchData().

◆ setCaliRMS()

void CaliCrystalIntercalDat::setCaliRMS ( float c )

inline

Definition at line 24 of file CaliCrystalIntercalDat.h.

24 { m_caliRMS = c; }

References c, and m_caliRMS.

Referenced by fetchData().

◆ setNumEvents()

void CaliCrystalIntercalDat::setNumEvents ( int n )

inline

Definition at line 27 of file CaliCrystalIntercalDat.h.

27 { m_numEvents = n; }

References m_numEvents, and dqmiodumpmetadata::n.

Referenced by fetchData().

◆ setTaskStatus()

void CaliCrystalIntercalDat::setTaskStatus ( bool s )

inline

Definition at line 30 of file CaliCrystalIntercalDat.h.

30 { m_taskStatus = s; }

References m_taskStatus, and alignCSCRings::s.

Referenced by fetchData().

◆ writeArrayDB()

void CaliCrystalIntercalDat::writeArrayDB	(	const std::map< EcalLogicID, CaliCrystalIntercalDat > *	data,
		CaliIOV *	iov
	)

privatenoexcept

Definition at line 116 of file CaliCrystalIntercalDat.cc.

                                                                         {
   this->checkConnection();
   this->checkPrepare();
  
   int iovID = iov->fetchID();
   if (!iovID) {
     throw(std::runtime_error("CaliCrystalIntercalDat::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* tt = new int[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* tt_len = new ub2[nrows];
   ub2* st_len = new ub2[nrows];
  
   const EcalLogicID* channel;
   const CaliCrystalIntercalDat* dataitem;
   int count = 0;
   typedef map<EcalLogicID, CaliCrystalIntercalDat>::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("CaliCrystalIntercalDat::writeArrayDB:  Bad EcalLogicID"));
     }
     ids[count] = logicID;
     iovid_vec[count] = iovID;
  
     dataitem = &(p->second);
     // dataIface.writeDB( channel, dataitem, iov);
     float x = dataitem->getCali();
     float y = dataitem->getCaliRMS();
     int xtt = dataitem->getNumEvents();
     int statu = dataitem->getTaskStatus();
  
     xx[count] = x;
     yy[count] = y;
     tt[count] = xtt;
     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]);
     tt_len[count] = sizeof(tt[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*)tt, OCCIINT, sizeof(tt[0]), tt_len);
     m_writeStmt->setDataBuffer(6, (dvoid*)st, OCCIINT, sizeof(st[0]), st_len);
  
     m_writeStmt->executeArrayUpdate(nrows);
  
     delete[] ids;
     delete[] iovid_vec;
     delete[] xx;
     delete[] yy;
     delete[] st;
     delete[] tt;
  
     delete[] ids_len;
     delete[] iov_len;
     delete[] x_len;
     delete[] y_len;
     delete[] tt_len;
     delete[] st_len;
  
   } catch (SQLException& e) {
     throw(std::runtime_error("MonPedestalsDat::writeArrayDB():  " + e.getMessage()));
   }
 }

References submitPVResolutionJobs::count, data, MillePedeFileConverter_cfg::e, getCali(), getCaliRMS(), EcalLogicID::getLogicID(), getNumEvents(), getTaskStatus(), AlCaHLTBitMon_ParallelJobs::p, groupFilesInBlocks::tt, x, geometryCSVtoXML::xx, y, and geometryCSVtoXML::yy.

◆ writeDB()

void CaliCrystalIntercalDat::writeDB	(	const EcalLogicID *	ecid,
		const CaliCrystalIntercalDat *	item,
		CaliIOV *	iov
	)

privatenoexcept

Definition at line 40 of file CaliCrystalIntercalDat.cc.

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

References MillePedeFileConverter_cfg::e, and B2GTnPMonitor_cfi::item.

Friends And Related Function Documentation

◆ EcalCondDBInterface

friend class EcalCondDBInterface

friend

Definition at line 14 of file CaliCrystalIntercalDat.h.

Member Data Documentation

◆ m_cali

float CaliCrystalIntercalDat::m_cali

private

Definition at line 43 of file CaliCrystalIntercalDat.h.

Referenced by getCali(), and setCali().

◆ m_caliRMS

float CaliCrystalIntercalDat::m_caliRMS

private

Definition at line 44 of file CaliCrystalIntercalDat.h.

Referenced by getCaliRMS(), and setCaliRMS().

◆ m_numEvents

int CaliCrystalIntercalDat::m_numEvents

private

Definition at line 45 of file CaliCrystalIntercalDat.h.

Referenced by getNumEvents(), and setNumEvents().

◆ m_taskStatus

bool CaliCrystalIntercalDat::m_taskStatus

private

Definition at line 46 of file CaliCrystalIntercalDat.h.

Referenced by getTaskStatus(), and setTaskStatus().

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ CaliCrystalIntercalDat()

◆ ~CaliCrystalIntercalDat()

Member Function Documentation

◆ fetchData()

◆ getCali()

◆ getCaliRMS()

◆ getNumEvents()

◆ getTable()

◆ getTaskStatus()

◆ prepareWrite()

◆ setCali()

◆ setCaliRMS()

◆ setNumEvents()

◆ setTaskStatus()

◆ writeArrayDB()

◆ writeDB()

Friends And Related Function Documentation

◆ EcalCondDBInterface

Member Data Documentation

◆ m_cali

◆ m_caliRMS

◆ m_numEvents

◆ m_taskStatus