CMS 3D CMS Logo

/data/refman/pasoursint/CMSSW_5_2_7_hltpatch1/src/OnlineDB/EcalCondDB/src/DCUCapsuleTempDat.cc

Go to the documentation of this file.
00001 #include <stdexcept>
00002 #include <string>
00003 #include "OnlineDB/Oracle/interface/Oracle.h"
00004 
00005 #include "OnlineDB/EcalCondDB/interface/DCUCapsuleTempDat.h"
00006 #include "OnlineDB/EcalCondDB/interface/RunTag.h"
00007 #include "OnlineDB/EcalCondDB/interface/RunIOV.h"
00008 
00009 using namespace std;
00010 using namespace oracle::occi;
00011 
00012 DCUCapsuleTempDat::DCUCapsuleTempDat()
00013 {
00014   m_env = NULL;
00015   m_conn = NULL;
00016   m_writeStmt = NULL;
00017   m_readStmt = NULL;
00018 
00019   m_capsuleTemp = 0;
00020 }
00021 
00022 
00023 
00024 DCUCapsuleTempDat::~DCUCapsuleTempDat()
00025 {
00026 }
00027 
00028 
00029 
00030 void DCUCapsuleTempDat::prepareWrite()
00031   throw(std::runtime_error)
00032 {
00033   this->checkConnection();
00034 
00035   try {
00036     m_writeStmt = m_conn->createStatement();
00037     m_writeStmt->setSQL("INSERT INTO dcu_capsule_temp_dat (iov_id, logic_id, "
00038                         "capsule_temp) "
00039                         "VALUES (:iov_id, :logic_id, "
00040                         ":capsule_temp)");
00041   } catch (SQLException &e) {
00042     throw(std::runtime_error("DCUCapsuleTempDat::prepareWrite():  "+e.getMessage()));
00043   }
00044 }
00045 
00046 
00047 
00048 void DCUCapsuleTempDat::writeDB(const EcalLogicID* ecid, const DCUCapsuleTempDat* item, DCUIOV* iov)
00049   throw(std::runtime_error)
00050 {
00051   this->checkConnection();
00052   this->checkPrepare();
00053 
00054   int iovID = iov->fetchID();
00055   if (!iovID) { throw(std::runtime_error("DCUCapsuleTempDat::writeDB:  IOV not in DB")); }
00056 
00057   int logicID = ecid->getLogicID();
00058   if (!logicID) { throw(std::runtime_error("DCUCapsuleTempDat::writeDB:  Bad EcalLogicID")); }
00059   
00060   try {
00061     m_writeStmt->setInt(1, iovID);
00062     m_writeStmt->setInt(2, logicID);
00063 
00064     m_writeStmt->setFloat(3, item->getCapsuleTemp() );
00065 
00066     m_writeStmt->executeUpdate();
00067   } catch (SQLException &e) {
00068     throw(std::runtime_error("DCUCapsuleTempDat::writeDB():  "+e.getMessage()));
00069   }
00070 }
00071 
00072 
00073 
00074 void DCUCapsuleTempDat::fetchData(std::map< EcalLogicID, DCUCapsuleTempDat >* fillMap, DCUIOV* iov)
00075   throw(std::runtime_error)
00076 {
00077   this->checkConnection();
00078   fillMap->clear();
00079 
00080   iov->setConnection(m_env, m_conn);
00081   int iovID = iov->fetchID();
00082   if (!iovID) { 
00083     //  throw(std::runtime_error("DCUCapsuleTempDat::writeDB:  IOV not in DB")); 
00084     return;
00085   }
00086 
00087   try {
00088 
00089     m_readStmt->setSQL("SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
00090                  "d.capsule_temp "
00091                  "FROM channelview cv JOIN dcu_capsule_temp_dat d "
00092                  "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
00093                  "WHERE d.iov_id = :iov_id");
00094     m_readStmt->setInt(1, iovID);
00095     ResultSet* rset = m_readStmt->executeQuery();
00096     
00097     std::pair< EcalLogicID, DCUCapsuleTempDat > p;
00098     DCUCapsuleTempDat dat;
00099     while(rset->next()) {
00100       p.first = EcalLogicID( rset->getString(1),     // name
00101                              rset->getInt(2),        // logic_id
00102                              rset->getInt(3),        // id1
00103                              rset->getInt(4),        // id2
00104                              rset->getInt(5),        // id3
00105                              rset->getString(6));    // maps_to
00106 
00107       dat.setCapsuleTemp( rset->getFloat(7) );
00108 
00109       p.second = dat;
00110       fillMap->insert(p);
00111     }
00112   } catch (SQLException &e) {
00113     throw(std::runtime_error("DCUCapsuleTempDat::fetchData():  "+e.getMessage()));
00114   }
00115 }
00116 void DCUCapsuleTempDat::writeArrayDB(const std::map< EcalLogicID, DCUCapsuleTempDat >* data, DCUIOV* iov)
00117   throw(std::runtime_error)
00118 {
00119   this->checkConnection();
00120   this->checkPrepare();
00121 
00122   int iovID = iov->fetchID();
00123   if (!iovID) { throw(std::runtime_error("DCUCapsuleTempDat::writeArrayDB:  IOV not in DB")); }
00124 
00125 
00126   int nrows=data->size(); 
00127   int* ids= new int[nrows];
00128   int* iovid_vec= new int[nrows];
00129   float* xx= new float[nrows];
00130 
00131   ub2* ids_len= new ub2[nrows];
00132   ub2* iov_len= new ub2[nrows];
00133   ub2* x_len= new ub2[nrows];
00134 
00135   const EcalLogicID* channel;
00136   const DCUCapsuleTempDat* dataitem;
00137   int count=0;
00138   typedef map< EcalLogicID, DCUCapsuleTempDat >::const_iterator CI;
00139   for (CI p = data->begin(); p != data->end(); ++p) {
00140         channel = &(p->first);
00141         int logicID = channel->getLogicID();
00142         if (!logicID) { throw(std::runtime_error("DCUCapsuleTempDat::writeArrayDB:  Bad EcalLogicID")); }
00143         ids[count]=logicID;
00144         iovid_vec[count]=iovID;
00145 
00146         dataitem = &(p->second);
00147         // dataIface.writeDB( channel, dataitem, iov);
00148         float x=dataitem->getCapsuleTemp();
00149 
00150         xx[count]=x;
00151 
00152 
00153         ids_len[count]=sizeof(ids[count]);
00154         iov_len[count]=sizeof(iovid_vec[count]);
00155         
00156         x_len[count]=sizeof(xx[count]);
00157 
00158 
00159         count++;
00160      }
00161 
00162 
00163   try {
00164     m_writeStmt->setDataBuffer(1, (dvoid*)iovid_vec, OCCIINT, sizeof(iovid_vec[0]),iov_len);
00165     m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len );
00166     m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIFLOAT , sizeof(xx[0]), x_len );
00167    
00168 
00169     m_writeStmt->executeArrayUpdate(nrows);
00170 
00171     delete [] ids;
00172     delete [] iovid_vec;
00173     delete [] xx;
00174 
00175     delete [] ids_len;
00176     delete [] iov_len;
00177     delete [] x_len;
00178 
00179 
00180   } catch (SQLException &e) {
00181     throw(std::runtime_error("DCUCapsuleTempDat::writeArrayDB():  "+e.getMessage()));
00182   }
00183 }