#include <DCUIDarkDat.h>

Inheritance diagram for DCUIDarkDat:

Public Member Functions
	DCUIDarkDat ()

float	getAPDIDark () const

std::string	getTable () override

void	setAPDIDark (float i)

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

void	prepareWrite () noexcept(false) override

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

void	writeDB (const EcalLogicID ecid, const DCUIDarkDat item, DCUIOV *iov) noexcept(false)

Private Attributes
float	m_apdIDark

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 DCUIDarkDat.h.

Constructor & Destructor Documentation

DCUIDarkDat::DCUIDarkDat ( )

Definition at line 12 of file DCUIDarkDat.cc.

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

DCUIDarkDat::~DCUIDarkDat ( )

override

Definition at line 24 of file DCUIDarkDat.cc.

25 {

26 }

Member Function Documentation

void DCUIDarkDat::fetchData	(	std::map< EcalLogicID, DCUIDarkDat > *	fillVec,
		DCUIOV *	iov
	)

privatenoexcept

Definition at line 74 of file DCUIDarkDat.cc.

References MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, setAPDIDark(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getAPDIDark().

 {
   this->checkConnection();
   fillMap->clear();
 
   iov->setConnection(m_env, m_conn);
   int iovID = iov->fetchID();
   if (!iovID) { 
     //  throw(std::runtime_error("DCUIDarkDat::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.apd_idark "
          "FROM channelview cv JOIN dcu_idark_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, DCUIDarkDat > p;
     DCUIDarkDat dat;
     while(rset->next()) {
       p.first = EcalLogicID( getOraString(rset,1),     // name
                  rset->getInt(2),        // logic_id
                  rset->getInt(3),        // id1
                  rset->getInt(4),        // id2
                  rset->getInt(5),        // id3
                  getOraString(rset,6));    // maps_to
 
       dat.setAPDIDark( rset->getFloat(7) );
 
       p.second = dat;
       fillMap->insert(p);
     }
   } catch (SQLException &e) {
     throw(std::runtime_error(std::string("DCUIDarkDat::fetchData():  ")+getOraMessage(&e)));
   }
 }

float DCUIDarkDat::getAPDIDark ( ) const

inline

Definition at line 22 of file DCUIDarkDat.h.

References data, fetchData(), m_apdIDark, noexcept, prepareWrite(), writeArrayDB(), and writeDB().

Referenced by writeArrayDB().

22 { return m_apdIDark; }

DCUIDarkDat::m_apdIDark

float m_apdIDark

Definition: DCUIDarkDat.h:39

std::string DCUIDarkDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 19 of file DCUIDarkDat.h.

19 { return "DCU_IDARK_DAT"; }

void DCUIDarkDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 30 of file DCUIDarkDat.cc.

References MillePedeFileConverter_cfg::e, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getAPDIDark().

 {
   this->checkConnection();
 
   try {
     m_writeStmt = m_conn->createStatement();
     m_writeStmt->setSQL("INSERT INTO dcu_idark_dat (iov_id, logic_id, "
             "apd_idark) "
             "VALUES (:iov_id, :logic_id, "
             ":apd_idark)");
   } catch (SQLException &e) {
     throw(std::runtime_error(std::string("DCUIDarkDat::prepareWrite():  ")+getOraMessage(&e)));
   }
 }

void DCUIDarkDat::setAPDIDark ( float i )

inline

Definition at line 21 of file DCUIDarkDat.h.

References mps_fire::i, and m_apdIDark.

Referenced by fetchData().

21 { m_apdIDark = i; }

mps_fire.i

i

Definition: mps_fire.py:269

DCUIDarkDat::m_apdIDark

float m_apdIDark

Definition: DCUIDarkDat.h:39

void DCUIDarkDat::writeArrayDB	(	const std::map< EcalLogicID, DCUIDarkDat > *	data,
		DCUIOV *	iov
	)

privatenoexcept

Definition at line 116 of file DCUIDarkDat.cc.

References KineDebug3::count(), data, MillePedeFileConverter_cfg::e, getAPDIDark(), EcalLogicID::getLogicID(), AlCaHLTBitMon_ParallelJobs::p, AlCaHLTBitMon_QueryRunRegistry::string, x, and geometryCSVtoXML::xx.

Referenced by getAPDIDark().

 {
   this->checkConnection();
   this->checkPrepare();
 
   int iovID = iov->fetchID();
   if (!iovID) { throw(std::runtime_error("DCUIDarkDat::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 DCUIDarkDat* dataitem;
   int count=0;
   typedef map< EcalLogicID, DCUIDarkDat >::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("DCUIDarkDat::writeArrayDB:  Bad EcalLogicID")); }
     ids[count]=logicID;
     iovid_vec[count]=iovID;
 
     dataitem = &(p->second);
     // dataIface.writeDB( channel, dataitem, iov);
     float x=dataitem->getAPDIDark();
 
     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(std::string("DCUIDarkDat::writeArrayDB():  ")+getOraMessage(&e)));
   }
 }

void DCUIDarkDat::writeDB	(	const EcalLogicID *	ecid,
		const DCUIDarkDat *	item,
		DCUIOV *	iov
	)

privatenoexcept

Definition at line 48 of file DCUIDarkDat.cc.

References MillePedeFileConverter_cfg::e, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getAPDIDark().

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