#include <MonShapeQualityDat.h>

Inheritance diagram for MonShapeQualityDat:

Public Member Functions
float	getAvgChi2 () const

std::string	getTable () override

	MonShapeQualityDat ()

void	setAvgChi2 (float chi2)

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

void	prepareWrite () noexcept(false) override

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

void	writeDB (const EcalLogicID ecid, const MonShapeQualityDat item, MonRunIOV *iov) noexcept(false)

Private Attributes
float	m_avgChi2

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

Constructor & Destructor Documentation

MonShapeQualityDat::MonShapeQualityDat ( )

Definition at line 12 of file MonShapeQualityDat.cc.

                                        {
   m_env = nullptr;
   m_conn = nullptr;
   m_writeStmt = nullptr;
   m_readStmt = nullptr;
 
   m_avgChi2 = 0;
 }

MonShapeQualityDat::~MonShapeQualityDat ( )

override

Definition at line 21 of file MonShapeQualityDat.cc.

21 {}

Member Function Documentation

void MonShapeQualityDat::fetchData	(	std::map< EcalLogicID, MonShapeQualityDat > *	fillVec,
		MonRunIOV *	iov
	)

privatenoexcept

Definition at line 66 of file MonShapeQualityDat.cc.

References dat, alignCSCRings::e, AlCaHLTBitMon_ParallelJobs::p, and setAvgChi2().

                                                                                                                    {
   this->checkConnection();
   fillMap->clear();
 
   iov->setConnection(m_env, m_conn);
   int iovID = iov->fetchID();
   if (!iovID) {
     //  throw(std::runtime_error("MonShapeQualityDat::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.avg_chi2 "
         "FROM channelview cv JOIN mon_shape_quality_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, MonShapeQualityDat> p;
     MonShapeQualityDat 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.setAvgChi2(rset->getFloat(7));
 
       p.second = dat;
       fillMap->insert(p);
     }
   } catch (SQLException& e) {
     throw(std::runtime_error("MonShapeQualityDat::fetchData():  " + e.getMessage()));
   }
 }

float MonShapeQualityDat::getAvgChi2 ( ) const

inline

Definition at line 22 of file MonShapeQualityDat.h.

References m_avgChi2.

Referenced by writeArrayDB().

22 { return m_avgChi2; }

MonShapeQualityDat::m_avgChi2

float m_avgChi2

Definition: MonShapeQualityDat.h:34

std::string MonShapeQualityDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 19 of file MonShapeQualityDat.h.

19 { return "MON_SHAPE_QUALITY_DAT"; }

void MonShapeQualityDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 23 of file MonShapeQualityDat.cc.

References alignCSCRings::e.

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

void MonShapeQualityDat::setAvgChi2 ( float chi2 )

inline

Definition at line 21 of file MonShapeQualityDat.h.

References HLT_FULL_cff::chi2, and m_avgChi2.

Referenced by fetchData().

21 { m_avgChi2 = chi2; }

MonShapeQualityDat::m_avgChi2

float m_avgChi2

Definition: MonShapeQualityDat.h:34

HLT_FULL_cff.chi2

tuple chi2

Definition: HLT_FULL_cff.py:10024

void MonShapeQualityDat::writeArrayDB	(	const std::map< EcalLogicID, MonShapeQualityDat > *	data,
		MonRunIOV *	iov
	)

privatenoexcept

Definition at line 107 of file MonShapeQualityDat.cc.

References submitPVResolutionJobs::count, data, alignCSCRings::e, getAvgChi2(), EcalLogicID::getLogicID(), AlCaHLTBitMon_ParallelJobs::p, and x.

                                                                       {
   this->checkConnection();
   this->checkPrepare();
 
   int iovID = iov->fetchID();
   if (!iovID) {
     throw(std::runtime_error("MonShapeQualityDat::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];
 
   ub2* ids_len = new ub2[nrows];
   ub2* iov_len = new ub2[nrows];
   ub2* x_len = new ub2[nrows];
 
   const EcalLogicID* channel;
   const MonShapeQualityDat* dataitem;
   int count = 0;
   typedef map<EcalLogicID, MonShapeQualityDat>::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("MonShapeQualityDat::writeArrayDB:  Bad EcalLogicID"));
     }
     ids[count] = logicID;
     iovid_vec[count] = iovID;
 
     dataitem = &(p->second);
     // dataIface.writeDB( channel, dataitem, iov);
     float x = dataitem->getAvgChi2();
 
     xx[count] = x;
 
     ids_len[count] = sizeof(ids[count]);
     iov_len[count] = sizeof(iovid_vec[count]);
 
     x_len[count] = sizeof(xx[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->executeArrayUpdate(nrows);
 
     delete[] ids;
     delete[] iovid_vec;
     delete[] xx;
 
     delete[] ids_len;
     delete[] iov_len;
     delete[] x_len;
 
   } catch (SQLException& e) {
     throw(std::runtime_error("MonPedestalsDat::writeArrayDB():  " + e.getMessage()));
   }
 }

void MonShapeQualityDat::writeDB	(	const EcalLogicID *	ecid,
		const MonShapeQualityDat *	item,
		MonRunIOV *	iov
	)

privatenoexcept

Definition at line 38 of file MonShapeQualityDat.cc.

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

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