CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
FEConfigWeightDat.cc
Go to the documentation of this file.
1 #include <stdexcept>
2 #include <string>
4 
7 
8 using namespace std;
9 using namespace oracle::occi;
10 
12 {
13  m_env = NULL;
14  m_conn = NULL;
15  m_writeStmt = NULL;
16  m_readStmt = NULL;
17 
18  m_group_id = 0;
19 
20 }
21 
22 
23 
25 {
26 }
27 
28 
29 
31  throw(std::runtime_error)
32 {
33  this->checkConnection();
34 
35  try {
36  m_writeStmt = m_conn->createStatement();
37  m_writeStmt->setSQL("INSERT INTO fe_config_weight_dat (wei_conf_id, logic_id, "
38  "group_id ) "
39  "VALUES (:wei_conf_id, :logic_id, "
40  ":group_id )" );
41  } catch (SQLException &e) {
42  throw(std::runtime_error("FEConfigWeightDat::prepareWrite(): "+e.getMessage()));
43  }
44 }
45 
46 
48  throw(std::runtime_error)
49 {
50  this->checkConnection();
51  this->checkPrepare();
52 
53  int iconfID = iconf->fetchID();
54  if (!iconfID) { throw(std::runtime_error("FEConfigWeightDat::writeDB: ICONF not in DB")); }
55 
56  int logicID = ecid->getLogicID();
57  if (!logicID) { throw(std::runtime_error("FEConfigWeightDat::writeDB: Bad EcalLogicID")); }
58 
59  try {
60  m_writeStmt->setInt(1, iconfID);
61  m_writeStmt->setInt(2, logicID);
62  m_writeStmt->setInt(3, item->getWeightGroupId());
63 
64  m_writeStmt->executeUpdate();
65  } catch (SQLException &e) {
66  throw(std::runtime_error("FEConfigWeightDat::writeDB(): "+e.getMessage()));
67  }
68 }
69 
70 
71 
72 void FEConfigWeightDat::fetchData(map< EcalLogicID, FEConfigWeightDat >* fillMap, FEConfigWeightInfo* iconf)
73  throw(std::runtime_error)
74 {
75  this->checkConnection();
76  fillMap->clear();
77 
78  iconf->setConnection(m_env, m_conn);
79  int iconfID = iconf->fetchID();
80  if (!iconfID) {
81  // throw(std::runtime_error("FEConfigWeightDat::writeDB: ICONF not in DB"));
82  return;
83  }
84 
85  try {
86 
87  m_readStmt->setSQL("SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
88  "d.group_id "
89  "FROM channelview cv JOIN fe_config_weight_dat d "
90  "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
91  "WHERE wei_conf_id = :wei_conf_id");
92  m_readStmt->setInt(1, iconfID);
93  ResultSet* rset = m_readStmt->executeQuery();
94 
95  std::pair< EcalLogicID, FEConfigWeightDat > p;
97  while(rset->next()) {
98  p.first = EcalLogicID( rset->getString(1), // name
99  rset->getInt(2), // logic_id
100  rset->getInt(3), // id1
101  rset->getInt(4), // id2
102  rset->getInt(5), // id3
103  rset->getString(6)); // maps_to
104 
105  dat.setWeightGroupId( rset->getInt(7) );
106 
107  p.second = dat;
108  fillMap->insert(p);
109  }
110  } catch (SQLException &e) {
111  throw(std::runtime_error("FEConfigWeightDat::fetchData: "+e.getMessage()));
112  }
113 }
114 
115 void FEConfigWeightDat::writeArrayDB(const std::map< EcalLogicID, FEConfigWeightDat >* data, FEConfigWeightInfo* iconf)
116  throw(std::runtime_error)
117 {
118  this->checkConnection();
119  this->checkPrepare();
120 
121  int iconfID = iconf->fetchID();
122  if (!iconfID) { throw(std::runtime_error("FEConfigWeightDat::writeArrayDB: ICONF not in DB")); }
123 
124 
125  int nrows=data->size();
126  int* ids= new int[nrows];
127  int* iconfid_vec= new int[nrows];
128  int* xx= new int[nrows];
129 
130  ub2* ids_len= new ub2[nrows];
131  ub2* iconf_len= new ub2[nrows];
132  ub2* x_len= new ub2[nrows];
133 
134 
135  const EcalLogicID* channel;
136  const FEConfigWeightDat* dataitem;
137  int count=0;
138  typedef map< EcalLogicID, FEConfigWeightDat >::const_iterator CI;
139  for (CI p = data->begin(); p != data->end(); ++p) {
140  channel = &(p->first);
141  int logicID = channel->getLogicID();
142  if (!logicID) { throw(std::runtime_error("FEConfigWeightDat::writeArrayDB: Bad EcalLogicID")); }
143  ids[count]=logicID;
144  iconfid_vec[count]=iconfID;
145 
146  dataitem = &(p->second);
147  // dataIface.writeDB( channel, dataitem, iconf);
148  int x=dataitem->getWeightGroupId();
149 
150  xx[count]=x;
151 
152  ids_len[count]=sizeof(ids[count]);
153  iconf_len[count]=sizeof(iconfid_vec[count]);
154 
155  x_len[count]=sizeof(xx[count]);
156 
157  count++;
158  }
159 
160 
161  try {
162  m_writeStmt->setDataBuffer(1, (dvoid*)iconfid_vec, OCCIINT, sizeof(iconfid_vec[0]),iconf_len);
163  m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len );
164  m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIINT , sizeof(xx[0]), x_len );
165 
166  m_writeStmt->executeArrayUpdate(nrows);
167 
168  delete [] ids;
169  delete [] iconfid_vec;
170  delete [] xx;
171 
172  delete [] ids_len;
173  delete [] iconf_len;
174  delete [] x_len;
175 
176  } catch (SQLException &e) {
177  throw(std::runtime_error("FEConfigWeightDat::writeArrayDB(): "+e.getMessage()));
178  }
179 }
#define NULL
Definition: scimark2.h:8
void writeArrayDB(const std::map< EcalLogicID, FEConfigWeightDat > *data, FEConfigWeightInfo *iconf)
oracle::occi::SQLException SQLException
Definition: HcalDbOmds.cc:27
void writeDB(const EcalLogicID *ecid, const FEConfigWeightDat *item, FEConfigWeightInfo *iconf)
int getLogicID() const
Definition: EcalLogicID.cc:41
oracle::occi::ResultSet ResultSet
Definition: HcalDbOmds.cc:26
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:82
void fetchData(std::map< EcalLogicID, FEConfigWeightDat > *fillMap, FEConfigWeightInfo *iconf)
int getWeightGroupId() const
void setWeightGroupId(int x)