CMS 3D CMS Logo

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

#include <RunCrystalErrorsDat.h>

Inheritance diagram for RunCrystalErrorsDat:
IDataItem IDBObject

Public Member Functions

uint64_t getErrorBits () const
 
std::string getTable () override
 
 RunCrystalErrorsDat ()
 
void setErrorBits (uint64_t bits)
 
 ~RunCrystalErrorsDat () 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, RunCrystalErrorsDat > *fillMap, RunIOV *iov) noexcept(false)
 
void prepareWrite () noexcept(false) override
 
void writeDB (const EcalLogicID *ecid, const RunCrystalErrorsDat *item, RunIOV *iov) noexcept(false)
 

Private Attributes

uint64_t m_errorBits
 

Friends

class EcalCondDBInterface
 

Additional Inherited Members

- Static Public Attributes inherited from IDBObject
static const int 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 RunCrystalErrorsDat.h.

Constructor & Destructor Documentation

◆ RunCrystalErrorsDat()

RunCrystalErrorsDat::RunCrystalErrorsDat ( )

Definition at line 12 of file RunCrystalErrorsDat.cc.

12  {
13  m_env = nullptr;
14  m_conn = nullptr;
15  m_writeStmt = nullptr;
16  m_errorBits = 0;
17 }

◆ ~RunCrystalErrorsDat()

RunCrystalErrorsDat::~RunCrystalErrorsDat ( )
override

Definition at line 19 of file RunCrystalErrorsDat.cc.

19 {}

Member Function Documentation

◆ fetchData()

void RunCrystalErrorsDat::fetchData ( std::map< EcalLogicID, RunCrystalErrorsDat > *  fillMap,
RunIOV iov 
)
privatenoexcept

Definition at line 63 of file RunCrystalErrorsDat.cc.

63  {
64  this->checkConnection();
65  fillMap->clear();
66 
67  iov->setConnection(m_env, m_conn);
68  int iovID = iov->fetchID();
69  if (!iovID) {
70  // throw(std::runtime_error("RunCrystalErrorsDat::writeDB: IOV not in DB"));
71  return;
72  }
73 
74  try {
75  Statement* stmt = m_conn->createStatement();
76  /* Using TO_CHAR because OCCI does not support 64-bit integers well */
77  stmt->setSQL(
78  "SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
79  "to_char(d.error_bits) "
80  "FROM channelview cv JOIN run_crystal_errors_dat d "
81  "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
82  "WHERE d.iov_id = :iov_id");
83  stmt->setInt(1, iovID);
84  ResultSet* rset = stmt->executeQuery();
85 
86  std::pair<EcalLogicID, RunCrystalErrorsDat> p;
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.setErrorBits(boost::lexical_cast<uint64_t>(rset->getString(7)));
97 
98  p.second = dat;
99  fillMap->insert(p);
100  }
101  m_conn->terminateStatement(stmt);
102 
103  } catch (SQLException& e) {
104  throw(std::runtime_error("RunCrystalErrorsDat::fetchData(): " + e.getMessage()));
105  }
106 }

References MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, and setErrorBits().

◆ getErrorBits()

uint64_t RunCrystalErrorsDat::getErrorBits ( ) const
inline

Definition at line 22 of file RunCrystalErrorsDat.h.

22 { return m_errorBits; }

References m_errorBits.

◆ getTable()

std::string RunCrystalErrorsDat::getTable ( )
inlineoverridevirtual

Implements IDataItem.

Definition at line 19 of file RunCrystalErrorsDat.h.

19 { return "RUN_CRYSTAL_ERRORS_DAT"; }

◆ prepareWrite()

void RunCrystalErrorsDat::prepareWrite ( )
overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 21 of file RunCrystalErrorsDat.cc.

21  {
22  this->checkConnection();
23 
24  try {
25  m_writeStmt = m_conn->createStatement();
26  /* Using TO_NUMBER because OCCI does not support 64-bit integers well */
27  m_writeStmt->setSQL(
28  "INSERT INTO run_crystal_errors_dat (iov_id, logic_id, "
29  "error_bits) "
30  "VALUES (:iov_id, :logic_id, "
31  "to_number(:error_bits))");
32  } catch (SQLException& e) {
33  throw(std::runtime_error("RunCrystalErrorsDat::prepareWrite(): " + e.getMessage()));
34  }
35 }

References MillePedeFileConverter_cfg::e.

◆ setErrorBits()

void RunCrystalErrorsDat::setErrorBits ( uint64_t  bits)
inline

Definition at line 21 of file RunCrystalErrorsDat.h.

21 { m_errorBits = bits; }

References m_errorBits.

Referenced by fetchData().

◆ writeDB()

void RunCrystalErrorsDat::writeDB ( const EcalLogicID ecid,
const RunCrystalErrorsDat item,
RunIOV iov 
)
privatenoexcept

Definition at line 37 of file RunCrystalErrorsDat.cc.

39  {
40  this->checkConnection();
41  this->checkPrepare();
42 
43  int iovID = iov->fetchID();
44  if (!iovID) {
45  throw(std::runtime_error("RunCrystalErrorsDat::writeDB: IOV not in DB"));
46  }
47 
48  int logicID = ecid->getLogicID();
49  if (!logicID) {
50  throw(std::runtime_error("RunCrystalErrorsDat::writeDB: Bad EcalLogicID"));
51  }
52 
53  try {
54  m_writeStmt->setInt(1, iovID);
55  m_writeStmt->setInt(2, logicID);
56  m_writeStmt->setString(3, std::to_string(item->getErrorBits()));
57  m_writeStmt->executeUpdate();
58  } catch (SQLException& e) {
59  throw(std::runtime_error("RunCrystalErrorsDat::writeDB(): " + e.getMessage()));
60  }
61 }

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

Friends And Related Function Documentation

◆ EcalCondDBInterface

friend class EcalCondDBInterface
friend

Definition at line 14 of file RunCrystalErrorsDat.h.

Member Data Documentation

◆ m_errorBits

uint64_t RunCrystalErrorsDat::m_errorBits
private

Definition at line 32 of file RunCrystalErrorsDat.h.

Referenced by getErrorBits(), and setErrorBits().

RunCrystalErrorsDat::setErrorBits
void setErrorBits(uint64_t bits)
Definition: RunCrystalErrorsDat.h:21
IDataItem::checkPrepare
void checkPrepare() noexcept(false)
Definition: IDataItem.h:26
EcalLogicID::getLogicID
int getLogicID() const
Definition: EcalLogicID.cc:28
RunCrystalErrorsDat
Definition: RunCrystalErrorsDat.h:12
IDataItem::m_writeStmt
oracle::occi::Statement * m_writeStmt
Definition: IDataItem.h:23
IDBObject::m_conn
oracle::occi::Connection * m_conn
Definition: IDBObject.h:34
EcalLogicID
Definition: EcalLogicID.h:7
IDBObject::checkConnection
void checkConnection() const noexcept(false)
Definition: IDBObject.h:36
AlCaHLTBitMon_ParallelJobs.p
def p
Definition: AlCaHLTBitMon_ParallelJobs.py:153
B2GTnPMonitor_cfi.item
item
Definition: B2GTnPMonitor_cfi.py:147
RunCrystalErrorsDat::m_errorBits
uint64_t m_errorBits
Definition: RunCrystalErrorsDat.h:32
RunIOV::fetchID
int fetchID() noexcept(false) override
Definition: RunIOV.cc:60
IDBObject::setConnection
void setConnection(oracle::occi::Environment *env, oracle::occi::Connection *conn)
Definition: IDBObject.h:23
IDBObject::m_env
oracle::occi::Environment * m_env
Definition: IDBObject.h:33
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37