CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
ODFEDelaysInfo.cc
Go to the documentation of this file.
1 #include <stdexcept>
2 #include <cstdlib>
3 #include <string>
4 #include <string.h>
6 
8 
9 using namespace std;
10 using namespace oracle::occi;
11 
13 {
14  m_env = NULL;
15  m_conn = NULL;
16  m_writeStmt = NULL;
17  m_readStmt = NULL;
18  m_config_tag="";
19  m_version=0;
20  m_ID=0;
21  clear();
22 }
23 
24 
26 
27 }
28 
29 
30 
32 {
33 }
34 
35 
36 
37 int ODFEDelaysInfo::fetchNextId() throw(std::runtime_error) {
38 
39  int result=0;
40  try {
41  this->checkConnection();
42 
43  m_readStmt = m_conn->createStatement();
44  m_readStmt->setSQL("select COND2CONF_INFO_SQ.NextVal from DUAL ");
45  ResultSet* rset = m_readStmt->executeQuery();
46  while (rset->next ()){
47  result= rset->getInt(1);
48  }
49  result++;
50  m_conn->terminateStatement(m_readStmt);
51  std::cout << " the id is going to be : "<< result<< endl;
52  return result;
53 
54  } catch (SQLException &e) {
55  throw(std::runtime_error("ODFEDelaysInfo::fetchNextId(): "+e.getMessage()));
56  }
57 
58 }
59 
61  throw(std::runtime_error)
62 {
63  this->checkConnection();
64 
65  int next_id=0;
66  if(getId()==0){
67  next_id=fetchNextId();
68  }
69 
70  try {
71  m_writeStmt = m_conn->createStatement();
72  m_writeStmt->setSQL("INSERT INTO "+getTable()+" ( rec_id, tag, version) "
73  " VALUES ( :1, :2, :3 ) " );
74 
75  m_writeStmt->setInt(1, next_id);
76  m_ID=next_id;
77 
78  } catch (SQLException &e) {
79  throw(std::runtime_error("ODFEDelaysInfo::prepareWrite(): "+e.getMessage()));
80  }
81 
82 }
83 
84 void ODFEDelaysInfo::setParameters(const std::map<string,string>& my_keys_map){
85 
86  // parses the result of the XML parser that is a map of
87  // string string with variable name variable value
88 
89  for( std::map<std::string, std::string >::const_iterator ci=
90  my_keys_map.begin(); ci!=my_keys_map.end(); ci++ ) {
91 
92  if(ci->first== "VERSION") setVersion(atoi(ci->second.c_str()) );
93  if(ci->first== "TAG") setConfigTag(ci->second);
94 
95  }
96 
97 }
98 
100  throw(std::runtime_error)
101 {
102  this->checkConnection();
103  this->checkPrepare();
104 
105  try {
106 
107  // number 1 is the id
108  m_writeStmt->setString(2, this->getConfigTag());
109  m_writeStmt->setInt(3, this->getVersion());
110 
111  m_writeStmt->executeUpdate();
112 
113 
114  } catch (SQLException &e) {
115  throw(std::runtime_error("ODFEDelaysInfo::writeDB(): "+e.getMessage()));
116  }
117 
118  // Now get the ID
119  if (!this->fetchID()) {
120  throw(std::runtime_error("ODFEDelaysInfo::writeDB: Failed to write"));
121  } else {
122  int old_version=this->getVersion();
123  m_readStmt = m_conn->createStatement();
124  this->fetchData (this);
125  m_conn->terminateStatement(m_readStmt);
126  if(this->getVersion()!=old_version) std::cout << "ODFEDelaysInfo>>WARNING version is "<< getVersion()<< endl;
127  }
128 }
129 
130 
132  throw(std::runtime_error)
133 {
134 
135  this->checkConnection();
136 
137  result->clear();
138  if(result->getId()==0 && (result->getConfigTag()=="") ){
139  throw(std::runtime_error("ODFEDelaysInfo::fetchData(): no Id defined for this ODFEDelaysInfo "));
140  }
141 
142  try {
143  if(result->getId()!=0) {
144  m_readStmt->setSQL("SELECT * FROM " + getTable() +
145  " where rec_id = :1 ");
146  m_readStmt->setInt(1, result->getId());
147  } else if (result->getConfigTag()!="") {
148  m_readStmt->setSQL("SELECT * FROM " + getTable() +
149  " where tag=:1 AND version=:2 " );
150  m_readStmt->setString(1, result->getConfigTag());
151  m_readStmt->setInt(2, result->getVersion());
152  } else {
153  // we should never pass here
154  throw(std::runtime_error("ODFEDelaysInfo::fetchData(): no Id defined for this ODFEDelaysInfo "));
155  }
156 
157  ResultSet* rset = m_readStmt->executeQuery();
158  rset->next();
159 
160  // 1 is the id and 2 is the config tag and 3 is the version
161 
162  result->setId(rset->getInt(1));
163  result->setConfigTag(rset->getString(2));
164  result->setVersion(rset->getInt(3));
165 
166  } catch (SQLException &e) {
167  throw(std::runtime_error("ODFEDelaysInfo::fetchData(): "+e.getMessage()));
168  }
169 }
170 
171 int ODFEDelaysInfo::fetchID() throw(std::runtime_error)
172 {
173  // Return from memory if available
174  if (m_ID!=0) {
175  return m_ID;
176  }
177 
178  this->checkConnection();
179 
180  try {
181  Statement* stmt = m_conn->createStatement();
182  stmt->setSQL("SELECT rec_id FROM "+ getTable()+
183  "WHERE tag=:1 and version=:2 " );
184 
185  stmt->setString(1, getConfigTag() );
186  stmt->setInt(2, getVersion() );
187 
188  ResultSet* rset = stmt->executeQuery();
189 
190  if (rset->next()) {
191  m_ID = rset->getInt(1);
192  } else {
193  m_ID = 0;
194  }
195  m_conn->terminateStatement(stmt);
196  } catch (SQLException &e) {
197  throw(std::runtime_error("ODFEDelaysInfo::fetchID: "+e.getMessage()));
198  }
199 
200  return m_ID;
201 }
static unsigned int getId(void)
#define NULL
Definition: scimark2.h:8
void fetchData(ODFEDelaysInfo *result)
void setParameters(const std::map< std::string, std::string > &my_keys_map)
void clear(CLHEP::HepGenMatrix &m)
Helper function: Reset all elements of a matrix to 0.
Definition: matutil.cc:167
tuple result
Definition: query.py:137
oracle::occi::Statement Statement
Definition: IODConfig.h:23
oracle::occi::ResultSet ResultSet
Definition: HcalDbOmds.cc:26
oracle::occi::SQLException SQLException
Definition: IODConfig.h:22
tuple cout
Definition: gather_cfg.py:121