CMS 3D CMS Logo

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