CMS 3D CMS Logo

List of all members | Public Member Functions | Private Member Functions | Private Attributes | Friends
MonLaserGreenDat Class Reference

#include <MonLaserGreenDat.h>

Inheritance diagram for MonLaserGreenDat:
IDataItem IDBObject

Public Member Functions

float getAPDMean () const
 
float getAPDOverPNMean () const
 
float getAPDOverPNRMS () const
 
float getAPDRMS () const
 
std::string getTable () override
 
bool getTaskStatus () const
 
 MonLaserGreenDat ()
 
void setAPDMean (float mean)
 
void setAPDOverPNMean (float mean)
 
void setAPDOverPNRMS (float rms)
 
void setAPDRMS (float rms)
 
void setTaskStatus (bool status)
 
 ~MonLaserGreenDat () 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, MonLaserGreenDat > *fillMap, MonRunIOV *iov) noexcept(false)
 
void prepareWrite () noexcept(false) override
 
void writeArrayDB (const std::map< EcalLogicID, MonLaserGreenDat > *data, MonRunIOV *iov) noexcept(false)
 
void writeDB (const EcalLogicID *ecid, const MonLaserGreenDat *item, MonRunIOV *iov) noexcept(false)
 

Private Attributes

float m_apdMean
 
float m_apdOverPNMean
 
float m_apdOverPNRMS
 
float m_apdRMS
 
bool m_taskStatus
 

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

Constructor & Destructor Documentation

MonLaserGreenDat::MonLaserGreenDat ( )

Definition at line 10 of file MonLaserGreenDat.cc.

11 {
12  m_env = nullptr;
13  m_conn = nullptr;
14  m_writeStmt = nullptr;
15  m_readStmt = nullptr;
16 
17  m_apdMean = 0;
18  m_apdRMS = 0;
19  m_apdOverPNMean = 0;
20  m_apdOverPNRMS = 0;
21  m_taskStatus = false;
22 
23 }
oracle::occi::Environment * m_env
Definition: IDBObject.h:38
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:28
oracle::occi::Connection * m_conn
Definition: IDBObject.h:39
oracle::occi::Statement * m_readStmt
Definition: IDataItem.h:29
MonLaserGreenDat::~MonLaserGreenDat ( )
override

Definition at line 27 of file MonLaserGreenDat.cc.

28 {
29 }

Member Function Documentation

void MonLaserGreenDat::fetchData ( std::map< EcalLogicID, MonLaserGreenDat > *  fillMap,
MonRunIOV iov 
)
privatenoexcept

Definition at line 81 of file MonLaserGreenDat.cc.

References MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, setAPDMean(), setAPDOverPNMean(), setAPDOverPNRMS(), setAPDRMS(), setTaskStatus(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getTaskStatus().

83 {
84  this->checkConnection();
85 
86  fillMap->clear();
87 
88  iov->setConnection(m_env, m_conn);
89  int iovID = iov->fetchID();
90  if (!iovID) {
91  // throw(std::runtime_error("MonLaserGreenDat::writeDB: IOV not in DB"));
92  return;
93  }
94 
95  try {
96 
97  m_readStmt->setSQL("SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
98  "d.apd_mean, d.apd_rms, d.apd_over_pn_mean, d.apd_over_pn_rms, d.task_status "
99  "FROM channelview cv JOIN mon_laser_green_dat d "
100  "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
101  "WHERE d.iov_id = :iov_id");
102  m_readStmt->setInt(1, iovID);
103  ResultSet* rset = m_readStmt->executeQuery();
104 
105  std::pair< EcalLogicID, MonLaserGreenDat > p;
106  MonLaserGreenDat dat;
107  while(rset->next()) {
108  p.first = EcalLogicID( getOraString(rset,1), // name
109  rset->getInt(2), // logic_id
110  rset->getInt(3), // id1
111  rset->getInt(4), // id2
112  rset->getInt(5), // id3
113  getOraString(rset,6)); // maps_to
114 
115  dat.setAPDMean( rset->getFloat(7) );
116  dat.setAPDRMS( rset->getFloat(8) );
117  dat.setAPDOverPNMean( rset->getFloat(9) );
118  dat.setAPDOverPNRMS( rset->getFloat(10) );
119  dat.setTaskStatus( rset->getInt(11) );
120 
121 
122  p.second = dat;
123  fillMap->insert(p);
124  }
125  } catch (SQLException &e) {
126  throw(std::runtime_error(std::string("MonLaserGreenDat::fetchData(): ")+getOraMessage(&e)));
127  }
128 }
oracle::occi::Environment * m_env
Definition: IDBObject.h:38
oracle::occi::Connection * m_conn
Definition: IDBObject.h:39
int fetchID() noexcept(false) override
Definition: MonRunIOV.cc:118
void checkConnection() const noexcept(false)
Definition: IDBObject.h:41
void setTaskStatus(bool status)
void setAPDMean(float mean)
void setAPDRMS(float rms)
oracle::occi::Statement * m_readStmt
Definition: IDataItem.h:29
void setAPDOverPNRMS(float rms)
void setAPDOverPNMean(float mean)
void setConnection(oracle::occi::Environment *env, oracle::occi::Connection *conn)
Definition: IDBObject.h:23
float MonLaserGreenDat::getAPDMean ( ) const
inline

Definition at line 22 of file MonLaserGreenDat.h.

References m_apdMean.

Referenced by writeArrayDB().

22 { return m_apdMean; }
float MonLaserGreenDat::getAPDOverPNMean ( ) const
inline

Definition at line 28 of file MonLaserGreenDat.h.

References m_apdOverPNMean.

Referenced by writeArrayDB().

28 { return m_apdOverPNMean; }
float MonLaserGreenDat::getAPDOverPNRMS ( ) const
inline

Definition at line 31 of file MonLaserGreenDat.h.

References m_apdOverPNRMS.

Referenced by writeArrayDB().

31 { return m_apdOverPNRMS; }
float MonLaserGreenDat::getAPDRMS ( ) const
inline

Definition at line 25 of file MonLaserGreenDat.h.

References m_apdRMS.

Referenced by writeArrayDB().

25 { return m_apdRMS; }
std::string MonLaserGreenDat::getTable ( )
inlineoverridevirtual

Implements IDataItem.

Definition at line 19 of file MonLaserGreenDat.h.

19 { return "MON_LASER_GREEN_DAT"; }
bool MonLaserGreenDat::getTaskStatus ( ) const
inline

Definition at line 34 of file MonLaserGreenDat.h.

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

Referenced by writeArrayDB().

34 { return m_taskStatus; }
void MonLaserGreenDat::prepareWrite ( )
overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 33 of file MonLaserGreenDat.cc.

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

Referenced by getTaskStatus().

35 {
36  this->checkConnection();
37 
38  try {
39  m_writeStmt = m_conn->createStatement();
40  m_writeStmt->setSQL("INSERT INTO mon_laser_green_dat (iov_id, logic_id, "
41  "apd_mean, apd_rms, apd_over_pn_mean, apd_over_pn_rms, task_status) "
42  "VALUES (:iov_id, :logic_id, "
43  ":apd_mean, :apd_rms, :apd_over_pn_mean, :apd_over_pn_rms, :task_status)");
44  } catch (SQLException &e) {
45  throw(std::runtime_error(std::string("MonLaserGreenDat::prepareWrite(): ")+getOraMessage(&e)));
46  }
47 }
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:28
oracle::occi::Connection * m_conn
Definition: IDBObject.h:39
void checkConnection() const noexcept(false)
Definition: IDBObject.h:41
void MonLaserGreenDat::setAPDMean ( float  mean)
inline
void MonLaserGreenDat::setAPDOverPNMean ( float  mean)
inline
void MonLaserGreenDat::setAPDOverPNRMS ( float  rms)
inline
void MonLaserGreenDat::setAPDRMS ( float  rms)
inline
void MonLaserGreenDat::setTaskStatus ( bool  status)
inline

Definition at line 33 of file MonLaserGreenDat.h.

References m_taskStatus, and mps_update::status.

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

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

Definition at line 130 of file MonLaserGreenDat.cc.

References KineDebug3::count(), data, MillePedeFileConverter_cfg::e, getAPDMean(), getAPDOverPNMean(), getAPDOverPNRMS(), getAPDRMS(), EcalLogicID::getLogicID(), getTaskStatus(), electrons_cff::ids, AlCaHLTBitMon_ParallelJobs::p, AlCaHLTBitMon_QueryRunRegistry::string, w, x, geometryCSVtoXML::xx, y, geometryCSVtoXML::yy, z, and geometryCSVtoXML::zz.

Referenced by getTaskStatus().

132 {
133  this->checkConnection();
134  this->checkPrepare();
135 
136  int iovID = iov->fetchID();
137  if (!iovID) { throw(std::runtime_error("MonLaserGreenDat::writeArrayDB: IOV not in DB")); }
138 
139 
140  int nrows=data->size();
141  int* ids= new int[nrows];
142  int* iovid_vec= new int[nrows];
143  float* xx= new float[nrows];
144  float* yy= new float[nrows];
145  float* zz= new float[nrows];
146  float* ww= new float[nrows];
147  int* st= new int[nrows];
148 
149  ub2* ids_len= new ub2[nrows];
150  ub2* iov_len= new ub2[nrows];
151  ub2* x_len= new ub2[nrows];
152  ub2* y_len= new ub2[nrows];
153  ub2* z_len= new ub2[nrows];
154  ub2* w_len= new ub2[nrows];
155  ub2* st_len= new ub2[nrows];
156 
157  const EcalLogicID* channel;
158  const MonLaserGreenDat* dataitem;
159  int count=0;
160  typedef map< EcalLogicID, MonLaserGreenDat >::const_iterator CI;
161  for (CI p = data->begin(); p != data->end(); ++p) {
162  channel = &(p->first);
163  int logicID = channel->getLogicID();
164  if (!logicID) { throw(std::runtime_error("MonLaserGreenDat::writeArrayDB: Bad EcalLogicID")); }
165  ids[count]=logicID;
166  iovid_vec[count]=iovID;
167 
168  dataitem = &(p->second);
169  // dataIface.writeDB( channel, dataitem, iov);
170  float x=dataitem->getAPDMean();
171  float y=dataitem->getAPDRMS();
172  float z=dataitem->getAPDOverPNMean();
173  float w=dataitem->getAPDOverPNRMS();
174  int statu=dataitem->getTaskStatus();
175 
176 
177 
178  xx[count]=x;
179  yy[count]=y;
180  zz[count]=z;
181  ww[count]=w;
182  st[count]=statu;
183 
184 
185  ids_len[count]=sizeof(ids[count]);
186  iov_len[count]=sizeof(iovid_vec[count]);
187 
188  x_len[count]=sizeof(xx[count]);
189  y_len[count]=sizeof(yy[count]);
190  z_len[count]=sizeof(zz[count]);
191  w_len[count]=sizeof(ww[count]);
192  st_len[count]=sizeof(st[count]);
193 
194  count++;
195  }
196 
197 
198  try {
199  m_writeStmt->setDataBuffer(1, (dvoid*)iovid_vec, OCCIINT, sizeof(iovid_vec[0]),iov_len);
200  m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len );
201  m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIFLOAT , sizeof(xx[0]), x_len );
202  m_writeStmt->setDataBuffer(4, (dvoid*)yy, OCCIFLOAT , sizeof(yy[0]), y_len );
203  m_writeStmt->setDataBuffer(5, (dvoid*)zz, OCCIFLOAT , sizeof(zz[0]), z_len );
204  m_writeStmt->setDataBuffer(6, (dvoid*)ww, OCCIFLOAT , sizeof(ww[0]), w_len );
205  m_writeStmt->setDataBuffer(7, (dvoid*)st, OCCIINT , sizeof(st[0]), st_len );
206 
207 
208  m_writeStmt->executeArrayUpdate(nrows);
209 
210  delete [] ids;
211  delete [] iovid_vec;
212  delete [] xx;
213  delete [] yy;
214  delete [] zz;
215  delete [] ww;
216  delete [] st;
217 
218  delete [] ids_len;
219  delete [] iov_len;
220  delete [] x_len;
221  delete [] y_len;
222  delete [] z_len;
223  delete [] w_len;
224  delete [] st_len;
225 
226 
227 
228  } catch (SQLException &e) {
229  throw(std::runtime_error(std::string("MonLaserGreenDat::writeArrayDB(): ")+getOraMessage(&e)));
230  }
231 }
float getAPDOverPNMean() const
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:28
const double w
Definition: UKUtility.cc:23
void checkPrepare() noexcept(false)
Definition: IDataItem.h:31
int fetchID() noexcept(false) override
Definition: MonRunIOV.cc:118
float getAPDMean() const
bool getTaskStatus() const
void checkConnection() const noexcept(false)
Definition: IDBObject.h:41
int getLogicID() const
Definition: EcalLogicID.cc:41
float getAPDRMS() const
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:82
float getAPDOverPNRMS() const
void MonLaserGreenDat::writeDB ( const EcalLogicID ecid,
const MonLaserGreenDat item,
MonRunIOV iov 
)
privatenoexcept

Definition at line 51 of file MonLaserGreenDat.cc.

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

Referenced by getTaskStatus().

53 {
54  this->checkConnection();
55  this->checkPrepare();
56 
57  int iovID = iov->fetchID();
58  if (!iovID) { throw(std::runtime_error("MonLaserGreenDat::writeDB: IOV not in DB")); }
59 
60  int logicID = ecid->getLogicID();
61  if (!logicID) { throw(std::runtime_error("MonLaserGreenDat::writeDB: Bad EcalLogicID")); }
62 
63  try {
64  m_writeStmt->setInt(1, iovID);
65  m_writeStmt->setInt(2, logicID);
66 
67  m_writeStmt->setFloat(3, item->getAPDMean() );
68  m_writeStmt->setFloat(4, item->getAPDRMS() );
69  m_writeStmt->setFloat(5, item->getAPDOverPNMean() );
70  m_writeStmt->setFloat(6, item->getAPDOverPNRMS() );
71  m_writeStmt->setInt(7, item->getTaskStatus() );
72 
73  m_writeStmt->executeUpdate();
74  } catch (SQLException &e) {
75  throw(std::runtime_error(std::string("MonLaserGreenDat::writeDB(): ")+getOraMessage(&e)));
76  }
77 }
float getAPDOverPNMean() const
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:28
void checkPrepare() noexcept(false)
Definition: IDataItem.h:31
int fetchID() noexcept(false) override
Definition: MonRunIOV.cc:118
float getAPDMean() const
bool getTaskStatus() const
void checkConnection() const noexcept(false)
Definition: IDBObject.h:41
int getLogicID() const
Definition: EcalLogicID.cc:41
float getAPDRMS() const
float getAPDOverPNRMS() const

Friends And Related Function Documentation

friend class EcalCondDBInterface
friend

Definition at line 14 of file MonLaserGreenDat.h.

Member Data Documentation

float MonLaserGreenDat::m_apdMean
private

Definition at line 52 of file MonLaserGreenDat.h.

Referenced by getAPDMean(), and setAPDMean().

float MonLaserGreenDat::m_apdOverPNMean
private

Definition at line 54 of file MonLaserGreenDat.h.

Referenced by getAPDOverPNMean(), and setAPDOverPNMean().

float MonLaserGreenDat::m_apdOverPNRMS
private

Definition at line 55 of file MonLaserGreenDat.h.

Referenced by getAPDOverPNRMS(), and setAPDOverPNRMS().

float MonLaserGreenDat::m_apdRMS
private

Definition at line 53 of file MonLaserGreenDat.h.

Referenced by getAPDRMS(), and setAPDRMS().

bool MonLaserGreenDat::m_taskStatus
private

Definition at line 56 of file MonLaserGreenDat.h.

Referenced by getTaskStatus(), and setTaskStatus().