CMS 3D CMS Logo

MonMemChConsistencyDat.cc
Go to the documentation of this file.
1 #include <stdexcept>
2 #include <string>
4 
6 
7 using namespace std;
8 using namespace oracle::occi;
9 
11 {
12  m_env = NULL;
13  m_conn = NULL;
14  m_writeStmt = NULL;
15  m_readStmt = NULL;
16 
17  m_processedEvents = 0;
18  m_problematicEvents = 0;
19  m_problemsID = 0;
20  m_problemsGainZero = 0;
21  m_problemsGainSwitch = 0;
22  m_taskStatus = 0;
23 }
24 
25 
26 
28 {
29 }
30 
31 
32 
35 {
36  this->checkConnection();
37 
38  try {
39  m_writeStmt = m_conn->createStatement();
40  m_writeStmt->setSQL("INSERT INTO mon_mem_ch_consistency_dat (iov_id, logic_id, "
41  "processed_events, problematic_events, problems_id, problems_gain_zero, problems_gain_switch, task_status) "
42  "VALUES (:iov_id, :logic_id, "
43  ":3, :4, :5, :6, :7, :8)");
44  } catch (SQLException &e) {
45  throw(std::runtime_error("MonMemChConsistencyDat::prepareWrite(): "+e.getMessage()));
46  }
47 }
48 
49 
50 
52  noexcept(false)
53 {
54  this->checkConnection();
55  this->checkPrepare();
56 
57  int iovID = iov->fetchID();
58  if (!iovID) { throw(std::runtime_error("MonMemChConsistencyDat::writeDB: IOV not in DB")); }
59 
60  int logicID = ecid->getLogicID();
61  if (!logicID) { throw(std::runtime_error("MonMemChConsistencyDat::writeDB: Bad EcalLogicID")); }
62 
63  try {
64  m_writeStmt->setInt(1, iovID);
65  m_writeStmt->setInt(2, logicID);
66 
67  m_writeStmt->setInt(3, item->getProcessedEvents() );
68  m_writeStmt->setInt(4, item->getProblematicEvents() );
69  m_writeStmt->setInt(5, item->getProblemsID() );
70  m_writeStmt->setInt(6, item->getProblemsGainZero() );
71  m_writeStmt->setInt(7, item->getProblemsGainSwitch() );
72  m_writeStmt->setInt(8, item->getTaskStatus() );
73  m_writeStmt->executeUpdate();
74  } catch (SQLException &e) {
75  throw(std::runtime_error("MonMemChConsistencyDat::writeDB(): "+e.getMessage()));
76  }
77 }
78 
79 
80 
81 void MonMemChConsistencyDat::fetchData(std::map< EcalLogicID, MonMemChConsistencyDat >* fillMap, MonRunIOV* iov)
82  noexcept(false)
83 {
84  this->checkConnection();
85  fillMap->clear();
86 
87  iov->setConnection(m_env, m_conn);
88  int iovID = iov->fetchID();
89  if (!iovID) {
90  // throw(std::runtime_error("MonMemChConsistencyDat::writeDB: IOV not in DB"));
91  return;
92  }
93 
94  try {
95 
96  m_readStmt->setSQL("SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
97  "d.processed_events, d.problematic_events, d.problems_id, d.problems_gain_zero, d.problems_gain_switch, d.task_status "
98  "FROM channelview cv JOIN mon_mem_ch_consistency_dat d "
99  "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
100  "WHERE d.iov_id = :iov_id");
101  m_readStmt->setInt(1, iovID);
102  ResultSet* rset = m_readStmt->executeQuery();
103 
104  std::pair< EcalLogicID, MonMemChConsistencyDat > p;
106  while(rset->next()) {
107  p.first = EcalLogicID( rset->getString(1), // name
108  rset->getInt(2), // logic_id
109  rset->getInt(3), // id1
110  rset->getInt(4), // id2
111  rset->getInt(5), // id3
112  rset->getString(6)); // maps_to
113 
114  dat.setProcessedEvents( rset->getInt(7) );
115  dat.setProblematicEvents( rset->getInt(8) );
116  dat.setProblemsID( rset->getInt(9) );
117  dat.setProblemsGainZero( rset->getInt(10) );
118  dat.setProblemsGainSwitch( rset->getInt(11) );
119  dat.setTaskStatus( rset->getInt(12) );
120 
121  p.second = dat;
122  fillMap->insert(p);
123  }
124  } catch (SQLException &e) {
125  throw(std::runtime_error("MonMemChConsistencyDat::fetchData(): "+e.getMessage()));
126  }
127 }
128 
129 void MonMemChConsistencyDat::writeArrayDB(const std::map< EcalLogicID, MonMemChConsistencyDat >* data, MonRunIOV* iov)
130  noexcept(false)
131 {
132  this->checkConnection();
133  this->checkPrepare();
134 
135  int iovID = iov->fetchID();
136  if (!iovID) { throw(std::runtime_error("MonMemChConsistencyDat::writeArrayDB: IOV not in DB")); }
137 
138 
139  int nrows=data->size();
140  int* ids= new int[nrows];
141  int* iovid_vec= new int[nrows];
142  int* xx= new int[nrows];
143  int* yy= new int[nrows];
144  int* zz= new int[nrows];
145  int* ww= new int[nrows];
146  int* uu= new int[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* u_len= new ub2[nrows];
156  ub2* st_len= new ub2[nrows];
157 
158  const EcalLogicID* channel;
159  const MonMemChConsistencyDat* dataitem;
160  int count=0;
161  typedef map< EcalLogicID, MonMemChConsistencyDat >::const_iterator CI;
162  for (CI p = data->begin(); p != data->end(); ++p) {
163  channel = &(p->first);
164  int logicID = channel->getLogicID();
165  if (!logicID) { throw(std::runtime_error("MonMemChConsistencyDat::writeArrayDB: Bad EcalLogicID")); }
166  ids[count]=logicID;
167  iovid_vec[count]=iovID;
168 
169  dataitem = &(p->second);
170  // dataIface.writeDB( channel, dataitem, iov);
171  int x=dataitem->getProcessedEvents();
172  int y=dataitem->getProblematicEvents();
173  int z=dataitem->getProblemsID();
174  int w=dataitem->getProblemsGainZero();
175  int u=dataitem->getProblemsGainSwitch();
176  int statu=dataitem->getTaskStatus();
177 
178 
179 
180  xx[count]=x;
181  yy[count]=y;
182  zz[count]=z;
183  ww[count]=w;
184  uu[count]=u;
185  st[count]=statu;
186 
187 
188  ids_len[count]=sizeof(ids[count]);
189  iov_len[count]=sizeof(iovid_vec[count]);
190 
191  x_len[count]=sizeof(xx[count]);
192  y_len[count]=sizeof(yy[count]);
193  z_len[count]=sizeof(zz[count]);
194  w_len[count]=sizeof(ww[count]);
195  u_len[count]=sizeof(uu[count]);
196  st_len[count]=sizeof(st[count]);
197 
198  count++;
199  }
200 
201 
202  try {
203  m_writeStmt->setDataBuffer(1, (dvoid*)iovid_vec, OCCIINT, sizeof(iovid_vec[0]),iov_len);
204  m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len );
205  m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIINT , sizeof(xx[0]), x_len );
206  m_writeStmt->setDataBuffer(4, (dvoid*)yy, OCCIINT , sizeof(yy[0]), y_len );
207  m_writeStmt->setDataBuffer(5, (dvoid*)zz, OCCIINT , sizeof(zz[0]), z_len );
208  m_writeStmt->setDataBuffer(6, (dvoid*)ww, OCCIINT , sizeof(ww[0]), w_len );
209  m_writeStmt->setDataBuffer(7, (dvoid*)uu, OCCIINT , sizeof(uu[0]), u_len );
210  m_writeStmt->setDataBuffer(8, (dvoid*)st, OCCIINT , sizeof(st[0]), st_len );
211 
212 
213  m_writeStmt->executeArrayUpdate(nrows);
214 
215  delete [] ids;
216  delete [] iovid_vec;
217  delete [] xx;
218  delete [] yy;
219  delete [] zz;
220  delete [] ww;
221  delete [] uu;
222  delete [] st;
223 
224  delete [] ids_len;
225  delete [] iov_len;
226  delete [] x_len;
227  delete [] y_len;
228  delete [] z_len;
229  delete [] w_len;
230  delete [] u_len;
231  delete [] st_len;
232 
233 
234 
235  } catch (SQLException &e) {
236  throw(std::runtime_error("MonMemChConsistencyDat::writeArrayDB(): "+e.getMessage()));
237  }
238 }
void prepareWrite() noexcept(false)
const double w
Definition: UKUtility.cc:23
#define noexcept
#define NULL
Definition: scimark2.h:8
void writeDB(const EcalLogicID *ecid, const MonMemChConsistencyDat *item, MonRunIOV *iov) noexcept(false)
void writeArrayDB(const std::map< EcalLogicID, MonMemChConsistencyDat > *data, MonRunIOV *iov) noexcept(false)
int getLogicID() const
Definition: EcalLogicID.cc:41
void setTaskStatus(bool status)
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:82
void setProblemsGainSwitch(int prob)
void fetchData(std::map< EcalLogicID, MonMemChConsistencyDat > *fillVec, MonRunIOV *iov) noexcept(false)