CMS 3D CMS Logo
List of all members | Public Member Functions | Private Member Functions | Private Attributes | Friends
FEConfigTimingDat Class Reference

#include <FEConfigTimingDat.h>

Inheritance diagram for FEConfigTimingDat:
IDataItem IDBObject

Public Member Functions

 FEConfigTimingDat ()
 
std::string getTable () override
 
int getTimingPar1 () const
 
int getTimingPar2 () const
 
void setTimingPar1 (int x)
 
void setTimingPar2 (int x)
 
 ~FEConfigTimingDat () 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, FEConfigTimingDat > *fillMap, FEConfigTimingInfo *iconf) noexcept(false)
 
void prepareWrite () noexcept(false) override
 
void writeArrayDB (const std::map< EcalLogicID, FEConfigTimingDat > *data, FEConfigTimingInfo *iconf) noexcept(false)
 
void writeDB (const EcalLogicID *ecid, const FEConfigTimingDat *item, FEConfigTimingInfo *iconf) noexcept(false)
 

Private Attributes

int m_par1
 
int m_par2
 

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 11 of file FEConfigTimingDat.h.

Constructor & Destructor Documentation

FEConfigTimingDat::FEConfigTimingDat ( )

Definition at line 11 of file FEConfigTimingDat.cc.

11  {
12  m_env = nullptr;
13  m_conn = nullptr;
14  m_writeStmt = nullptr;
15  m_readStmt = nullptr;
16 
17  m_par1 = 0;
18  m_par2 = 0;
19 }
IDBObject::m_env
oracle::occi::Environment * m_env
Definition: IDBObject.h:33
IDataItem::m_writeStmt
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:23
IDBObject::m_conn
oracle::occi::Connection * m_conn
Definition: IDBObject.h:34
IDataItem::m_readStmt
oracle::occi::Statement * m_readStmt
Definition: IDataItem.h:24
FEConfigTimingDat::~FEConfigTimingDat ( )
override

Definition at line 21 of file FEConfigTimingDat.cc.

21 {}

Member Function Documentation

void FEConfigTimingDat::fetchData ( std::map< EcalLogicID, FEConfigTimingDat > *  fillMap,
FEConfigTimingInfo *  iconf 
)
privatenoexcept

Definition at line 64 of file FEConfigTimingDat.cc.

References MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, setTimingPar1(), and setTimingPar2().

Referenced by getTimingPar2().

65  {
66  this->checkConnection();
67  fillMap->clear();
68 
69  iconf->setConnection(m_env, m_conn);
70  int iconfID = iconf->fetchID();
71  if (!iconfID) {
72  return;
73  }
74 
75  try {
76  m_readStmt->setSQL(
77  "SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
78  "d.time_par1, d.time_par2 "
79  "FROM channelview cv JOIN " +
80  getTable() +
81  " d ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
82  "WHERE tim_conf_id = :tim_conf_id");
83  m_readStmt->setInt(1, iconfID);
84  ResultSet* rset = m_readStmt->executeQuery();
85 
86  std::pair<EcalLogicID, FEConfigTimingDat> p;
87  FEConfigTimingDat dat;
88  while (rset->next()) {
89  p.first = EcalLogicID(rset->getString(1), // name
90  rset->getInt(2), // logic_id
91  rset->getInt(3), // id1
92  rset->getInt(4), // id2
93  rset->getInt(5), // id3
94  rset->getString(6)); // maps_to
95 
96  dat.setTimingPar1(rset->getInt(7));
97  dat.setTimingPar2(rset->getInt(8));
98 
99  p.second = dat;
100  fillMap->insert(p);
101  }
102  } catch (SQLException& e) {
103  throw(std::runtime_error("FEConfigTimingDat::fetchData: " + e.getMessage()));
104  }
105 }
IDBObject::m_env
oracle::occi::Environment * m_env
Definition: IDBObject.h:33
IDBObject::m_conn
oracle::occi::Connection * m_conn
Definition: IDBObject.h:34
AlCaHLTBitMon_ParallelJobs.p
p
Definition: AlCaHLTBitMon_ParallelJobs.py:153
FEConfigTimingDat::setTimingPar2
void setTimingPar2(int x)
Definition: FEConfigTimingDat.h:22
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37
FEConfigTimingDat::getTable
std::string getTable() override
Definition: FEConfigTimingDat.h:18
IDBObject::checkConnection
void checkConnection() const noexcept(false)
Definition: IDBObject.h:36
FEConfigTimingDat::setTimingPar1
void setTimingPar1(int x)
Definition: FEConfigTimingDat.h:20
IDataItem::m_readStmt
oracle::occi::Statement * m_readStmt
Definition: IDataItem.h:24
FEConfigTimingInfo::fetchID
int fetchID() noexcept(false)
Definition: FEConfigTimingInfo.cc:156
IDBObject::setConnection
void setConnection(oracle::occi::Environment *env, oracle::occi::Connection *conn)
Definition: IDBObject.h:23
std::string FEConfigTimingDat::getTable ( )
inlineoverridevirtual

Implements IDataItem.

Definition at line 18 of file FEConfigTimingDat.h.

18 { return "FE_CONFIG_Time_DAT"; }
int FEConfigTimingDat::getTimingPar1 ( ) const
inline

Definition at line 21 of file FEConfigTimingDat.h.

References m_par1.

Referenced by writeArrayDB().

21 { return m_par1; }
int FEConfigTimingDat::getTimingPar2 ( ) const
inline

Definition at line 23 of file FEConfigTimingDat.h.

References data, fetchData(), B2GTnPMonitor_cfi::item, m_par2, noexcept, prepareWrite(), writeArrayDB(), and writeDB().

Referenced by writeArrayDB().

23 { return m_par2; }
void FEConfigTimingDat::prepareWrite ( )
overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 23 of file FEConfigTimingDat.cc.

References MillePedeFileConverter_cfg::e.

Referenced by getTimingPar2().

23  {
24  this->checkConnection();
25 
26  try {
27  m_writeStmt = m_conn->createStatement();
28  m_writeStmt->setSQL("INSERT INTO " + getTable() +
29  " (tim_conf_id, logic_id, "
30  "time_par1, time_par2 ) VALUES (:tim_conf_id, :logic_id, :time_par1, :time_par2 )");
31  } catch (SQLException& e) {
32  throw(std::runtime_error("FEConfigTimingDat::prepareWrite(): " + e.getMessage()));
33  }
34 }
IDataItem::m_writeStmt
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:23
IDBObject::m_conn
oracle::occi::Connection * m_conn
Definition: IDBObject.h:34
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37
FEConfigTimingDat::getTable
std::string getTable() override
Definition: FEConfigTimingDat.h:18
IDBObject::checkConnection
void checkConnection() const noexcept(false)
Definition: IDBObject.h:36
void FEConfigTimingDat::setTimingPar1 ( int  x)
inline

Definition at line 20 of file FEConfigTimingDat.h.

References m_par1, and x.

Referenced by EcalTPGParamBuilder::analyze(), and fetchData().

20 { m_par1 = x; }
void FEConfigTimingDat::setTimingPar2 ( int  x)
inline

Definition at line 22 of file FEConfigTimingDat.h.

References m_par2, and x.

Referenced by EcalTPGParamBuilder::analyze(), and fetchData().

22 { m_par2 = x; }
void FEConfigTimingDat::writeArrayDB ( const std::map< EcalLogicID, FEConfigTimingDat > *  data,
FEConfigTimingInfo *  iconf 
)
privatenoexcept

Definition at line 107 of file FEConfigTimingDat.cc.

References KineDebug3::count(), data, MillePedeFileConverter_cfg::e, EcalLogicID::getLogicID(), getTimingPar1(), getTimingPar2(), photons_cff::ids, AlCaHLTBitMon_ParallelJobs::p, x, geometryCSVtoXML::xx, y, and geometryCSVtoXML::yy.

Referenced by getTimingPar2().

108  {
109  this->checkConnection();
110  this->checkPrepare();
111 
112  int iconfID = iconf->fetchID();
113  if (!iconfID) {
114  throw(std::runtime_error("FEConfigTimingDat::writeArrayDB: tim_conf_id not in DB"));
115  }
116 
117  int nrows = data->size();
118  int* ids = new int[nrows];
119  int* iconfid_vec = new int[nrows];
120  int* xx = new int[nrows];
121  int* yy = new int[nrows];
122 
123  ub2* ids_len = new ub2[nrows];
124  ub2* iconf_len = new ub2[nrows];
125  ub2* x_len = new ub2[nrows];
126  ub2* y_len = new ub2[nrows];
127 
128  const EcalLogicID* channel;
129  const FEConfigTimingDat* dataitem;
130  int count = 0;
131  typedef map<EcalLogicID, FEConfigTimingDat>::const_iterator CI;
132  for (CI p = data->begin(); p != data->end(); ++p) {
133  channel = &(p->first);
134  int logicID = channel->getLogicID();
135  if (!logicID) {
136  throw(std::runtime_error("FEConfigTimingDat::writeArrayDB: Bad EcalLogicID"));
137  }
138  ids[count] = logicID;
139  iconfid_vec[count] = iconfID;
140 
141  dataitem = &(p->second);
142  // dataIface.writeDB( channel, dataitem, iconf);
143  int x = dataitem->getTimingPar1();
144  int y = dataitem->getTimingPar2();
145 
146  xx[count] = x;
147  yy[count] = y;
148 
149  ids_len[count] = sizeof(ids[count]);
150  iconf_len[count] = sizeof(iconfid_vec[count]);
151 
152  x_len[count] = sizeof(xx[count]);
153  y_len[count] = sizeof(yy[count]);
154 
155  count++;
156  }
157 
158  try {
159  m_writeStmt->setDataBuffer(1, (dvoid*)iconfid_vec, OCCIINT, sizeof(iconfid_vec[0]), iconf_len);
160  m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len);
161  m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIINT, sizeof(xx[0]), x_len);
162  m_writeStmt->setDataBuffer(4, (dvoid*)yy, OCCIINT, sizeof(yy[0]), y_len);
163 
164  m_writeStmt->executeArrayUpdate(nrows);
165 
166  delete[] ids;
167  delete[] iconfid_vec;
168  delete[] xx;
169  delete[] yy;
170 
171  delete[] ids_len;
172  delete[] iconf_len;
173  delete[] x_len;
174  delete[] y_len;
175 
176  } catch (SQLException& e) {
177  throw(std::runtime_error("FEConfigTimingDat::writeArrayDB(): " + e.getMessage()));
178  }
179 }
IDataItem::m_writeStmt
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:23
AlCaHLTBitMon_ParallelJobs.p
p
Definition: AlCaHLTBitMon_ParallelJobs.py:153
IDataItem::checkPrepare
void checkPrepare() noexcept(false)
Definition: IDataItem.h:26
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37
IDBObject::checkConnection
void checkConnection() const noexcept(false)
Definition: IDBObject.h:36
EcalLogicID::getLogicID
int getLogicID() const
Definition: EcalLogicID.cc:28
FEConfigTimingDat::getTimingPar2
int getTimingPar2() const
Definition: FEConfigTimingDat.h:23
photons_cff.ids
ids
Definition: photons_cff.py:50
FEConfigTimingDat::getTimingPar1
int getTimingPar1() const
Definition: FEConfigTimingDat.h:21
FEConfigTimingInfo::fetchID
int fetchID() noexcept(false)
Definition: FEConfigTimingInfo.cc:156
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:79
void FEConfigTimingDat::writeDB ( const EcalLogicID *  ecid,
const FEConfigTimingDat *  item,
FEConfigTimingInfo *  iconf 
)
privatenoexcept

Definition at line 36 of file FEConfigTimingDat.cc.

References MillePedeFileConverter_cfg::e, and B2GTnPMonitor_cfi::item.

Referenced by getTimingPar2().

38  {
39  this->checkConnection();
40  this->checkPrepare();
41 
42  int iconfID = iconf->fetchID();
43  if (!iconfID) {
44  throw(std::runtime_error("FEConfigTimingDat::writeDB: ICONF not in DB"));
45  }
46 
47  int logicID = ecid->getLogicID();
48  if (!logicID) {
49  throw(std::runtime_error("FEConfigTimingDat::writeDB: Bad EcalLogicID"));
50  }
51 
52  try {
53  m_writeStmt->setInt(1, iconfID);
54  m_writeStmt->setInt(2, logicID);
55  m_writeStmt->setInt(3, item->getTimingPar1());
56  m_writeStmt->setInt(4, item->getTimingPar2());
57 
58  m_writeStmt->executeUpdate();
59  } catch (SQLException& e) {
60  throw(std::runtime_error("FEConfigTimingDat::writeDB(): " + e.getMessage()));
61  }
62 }
IDataItem::m_writeStmt
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:23
IDataItem::checkPrepare
void checkPrepare() noexcept(false)
Definition: IDataItem.h:26
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37
IDBObject::checkConnection
void checkConnection() const noexcept(false)
Definition: IDBObject.h:36
EcalLogicID::getLogicID
int getLogicID() const
Definition: EcalLogicID.cc:28
FEConfigTimingDat::getTimingPar2
int getTimingPar2() const
Definition: FEConfigTimingDat.h:23
FEConfigTimingDat::getTimingPar1
int getTimingPar1() const
Definition: FEConfigTimingDat.h:21
FEConfigTimingInfo::fetchID
int fetchID() noexcept(false)
Definition: FEConfigTimingInfo.cc:156

Friends And Related Function Documentation

friend class EcalCondDBInterface
friend

Definition at line 13 of file FEConfigTimingDat.h.

Member Data Documentation

int FEConfigTimingDat::m_par1
private

Definition at line 35 of file FEConfigTimingDat.h.

Referenced by getTimingPar1(), and setTimingPar1().

int FEConfigTimingDat::m_par2
private

Definition at line 36 of file FEConfigTimingDat.h.

Referenced by getTimingPar2(), and setTimingPar2().

Generated for CMSSW Reference Manual by doxygen 1.8.11