CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Member Functions | Private Member Functions | Private Attributes | Friends
MonLaserBlueDat Class Reference

#include <MonLaserBlueDat.h>

Inheritance diagram for MonLaserBlueDat:
IDataItem IDBObject

Public Member Functions

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

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 () throw (std::runtime_error)
 
void createReadStatement () throw (std::runtime_error)
 
void setPrefetchRowCount (int ncount) throw (std::runtime_error)
 
void terminateReadStatement () throw (std::runtime_error)
 
void terminateWriteStatement () throw (std::runtime_error)
 
- Protected Member Functions inherited from IDBObject
void checkConnection () const throw (std::runtime_error)
 
- 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 MonLaserBlueDat.h.

Constructor & Destructor Documentation

MonLaserBlueDat::MonLaserBlueDat ( )

Definition at line 10 of file MonLaserBlueDat.cc.

References NULL.

11 {
12  m_env = NULL;
13  m_conn = NULL;
14  m_writeStmt = NULL;
15  m_readStmt = NULL;
16 
17  m_apdMean = 0;
18  m_apdRMS = 0;
19  m_apdOverPNMean = 0;
20  m_apdOverPNRMS = 0;
21  m_taskStatus = 0;
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
#define NULL
Definition: scimark2.h:8
oracle::occi::Statement * m_readStmt
Definition: IDataItem.h:29
MonLaserBlueDat::~MonLaserBlueDat ( )

Definition at line 27 of file MonLaserBlueDat.cc.

28 {
29 }

Member Function Documentation

void MonLaserBlueDat::fetchData ( std::map< EcalLogicID, MonLaserBlueDat > *  fillMap,
MonRunIOV iov 
)
throw (std::runtime_error
)
private

Definition at line 81 of file MonLaserBlueDat.cc.

References alignCSCRings::e, o2o::iov, AlCaHLTBitMon_ParallelJobs::p, setAPDMean(), setAPDOverPNMean(), setAPDOverPNRMS(), setAPDRMS(), and setTaskStatus().

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("MonLaserBlueDat::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_blue_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, MonLaserBlueDat > p;
106  MonLaserBlueDat dat;
107  while(rset->next()) {
108  p.first = EcalLogicID( rset->getString(1), // name
109  rset->getInt(2), // logic_id
110  rset->getInt(3), // id1
111  rset->getInt(4), // id2
112  rset->getInt(5), // id3
113  rset->getString(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("MonLaserBlueDat::fetchData(): "+e.getMessage()));
127  }
128 }
oracle::occi::Environment * m_env
Definition: IDBObject.h:38
oracle::occi::Connection * m_conn
Definition: IDBObject.h:39
void setAPDOverPNMean(float mean)
int fetchID()
Definition: MonRunIOV.cc:118
oracle::occi::SQLException SQLException
Definition: HcalDbOmds.cc:27
void setAPDRMS(float rms)
oracle::occi::Statement * m_readStmt
Definition: IDataItem.h:29
void setTaskStatus(bool status)
oracle::occi::ResultSet ResultSet
Definition: HcalDbOmds.cc:26
void setAPDOverPNRMS(float rms)
void setConnection(oracle::occi::Environment *env, oracle::occi::Connection *conn)
Definition: IDBObject.h:23
void setAPDMean(float mean)
void checkConnection() const
Definition: IDBObject.h:41
float MonLaserBlueDat::getAPDMean ( ) const
inline
float MonLaserBlueDat::getAPDOverPNMean ( ) const
inline

Definition at line 28 of file MonLaserBlueDat.h.

References m_apdOverPNMean.

Referenced by writeArrayDB().

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

Definition at line 31 of file MonLaserBlueDat.h.

References m_apdOverPNRMS.

Referenced by writeArrayDB().

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

Definition at line 25 of file MonLaserBlueDat.h.

References m_apdRMS.

Referenced by writeArrayDB().

25 { return m_apdRMS; }
std::string MonLaserBlueDat::getTable ( )
inlinevirtual

Implements IDataItem.

Definition at line 19 of file MonLaserBlueDat.h.

19 { return "MON_LASER_BLUE_DAT"; }
bool MonLaserBlueDat::getTaskStatus ( ) const
inline

Definition at line 34 of file MonLaserBlueDat.h.

References m_taskStatus.

Referenced by writeArrayDB().

34 { return m_taskStatus; }
void MonLaserBlueDat::prepareWrite ( )
throw (std::runtime_error
)
privatevirtual

Implements IDataItem.

Definition at line 33 of file MonLaserBlueDat.cc.

References alignCSCRings::e.

35 {
36  this->checkConnection();
37 
38  try {
39  m_writeStmt = m_conn->createStatement();
40  m_writeStmt->setSQL("INSERT INTO mon_laser_blue_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("MonLaserBlueDat::prepareWrite(): "+e.getMessage()));
46  }
47 }
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:28
oracle::occi::Connection * m_conn
Definition: IDBObject.h:39
oracle::occi::SQLException SQLException
Definition: HcalDbOmds.cc:27
void checkConnection() const
Definition: IDBObject.h:41
void MonLaserBlueDat::setAPDMean ( float  mean)
inline

Definition at line 21 of file MonLaserBlueDat.h.

References m_apdMean, and timingPdfMaker::mean.

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

void MonLaserBlueDat::setAPDOverPNMean ( float  mean)
inline

Definition at line 27 of file MonLaserBlueDat.h.

References m_apdOverPNMean, and timingPdfMaker::mean.

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

void MonLaserBlueDat::setAPDOverPNRMS ( float  rms)
inline

Definition at line 30 of file MonLaserBlueDat.h.

References m_apdOverPNRMS, and plotscripts::rms().

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

30 { m_apdOverPNRMS = rms; }
void MonLaserBlueDat::setAPDRMS ( float  rms)
inline

Definition at line 24 of file MonLaserBlueDat.h.

References m_apdRMS, and plotscripts::rms().

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

24 { m_apdRMS = rms; }
void MonLaserBlueDat::setTaskStatus ( bool  status)
inline

Definition at line 33 of file MonLaserBlueDat.h.

References m_taskStatus, and mps_update::status.

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

33 { m_taskStatus = status; }
tuple status
Definition: mps_update.py:57
void MonLaserBlueDat::writeArrayDB ( const std::map< EcalLogicID, MonLaserBlueDat > *  data,
MonRunIOV iov 
)
throw (std::runtime_error
)
private

Definition at line 130 of file MonLaserBlueDat.cc.

References KineDebug3::count(), data, alignCSCRings::e, getAPDMean(), getAPDOverPNMean(), getAPDOverPNRMS(), getAPDRMS(), EcalLogicID::getLogicID(), getTaskStatus(), o2o::iov, AlCaHLTBitMon_ParallelJobs::p, w, x, y, and z.

132 {
133  this->checkConnection();
134  this->checkPrepare();
135 
136  int iovID = iov->fetchID();
137  if (!iovID) { throw(std::runtime_error("MonLaserBlueDat::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 MonLaserBlueDat* dataitem;
159  int count=0;
160  typedef map< EcalLogicID, MonLaserBlueDat >::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("MonLaserBlueDat::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("MonLaserBlueDat::writeArrayDB(): "+e.getMessage()));
230  }
231 }
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:28
const double w
Definition: UKUtility.cc:23
bool getTaskStatus() const
int fetchID()
Definition: MonRunIOV.cc:118
oracle::occi::SQLException SQLException
Definition: HcalDbOmds.cc:27
int getLogicID() const
Definition: EcalLogicID.cc:41
float getAPDRMS() const
float getAPDMean() const
void checkPrepare()
Definition: IDataItem.h:31
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:82
float getAPDOverPNMean() const
float getAPDOverPNRMS() const
void checkConnection() const
Definition: IDBObject.h:41
void MonLaserBlueDat::writeDB ( const EcalLogicID ecid,
const MonLaserBlueDat item,
MonRunIOV iov 
)
throw (std::runtime_error
)
private

Definition at line 51 of file MonLaserBlueDat.cc.

References alignCSCRings::e, and o2o::iov.

53 {
54  this->checkConnection();
55  this->checkPrepare();
56 
57  int iovID = iov->fetchID();
58  if (!iovID) { throw(std::runtime_error("MonLaserBlueDat::writeDB: IOV not in DB")); }
59 
60  int logicID = ecid->getLogicID();
61  if (!logicID) { throw(std::runtime_error("MonLaserBlueDat::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("MonLaserBlueDat::writeDB(): "+e.getMessage()));
76  }
77 }
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:28
bool getTaskStatus() const
int fetchID()
Definition: MonRunIOV.cc:118
oracle::occi::SQLException SQLException
Definition: HcalDbOmds.cc:27
int getLogicID() const
Definition: EcalLogicID.cc:41
float getAPDRMS() const
float getAPDMean() const
void checkPrepare()
Definition: IDataItem.h:31
float getAPDOverPNMean() const
float getAPDOverPNRMS() const
void checkConnection() const
Definition: IDBObject.h:41

Friends And Related Function Documentation

friend class EcalCondDBInterface
friend

Definition at line 14 of file MonLaserBlueDat.h.

Member Data Documentation

float MonLaserBlueDat::m_apdMean
private

Definition at line 51 of file MonLaserBlueDat.h.

Referenced by getAPDMean(), and setAPDMean().

float MonLaserBlueDat::m_apdOverPNMean
private

Definition at line 53 of file MonLaserBlueDat.h.

Referenced by getAPDOverPNMean(), and setAPDOverPNMean().

float MonLaserBlueDat::m_apdOverPNRMS
private

Definition at line 54 of file MonLaserBlueDat.h.

Referenced by getAPDOverPNRMS(), and setAPDOverPNRMS().

float MonLaserBlueDat::m_apdRMS
private

Definition at line 52 of file MonLaserBlueDat.h.

Referenced by getAPDRMS(), and setAPDRMS().

bool MonLaserBlueDat::m_taskStatus
private

Definition at line 55 of file MonLaserBlueDat.h.

Referenced by getTaskStatus(), and setTaskStatus().