Back to home page

Project CMSSW displayed by LXR

 
 

    


File indexing completed on 2021-02-14 13:31:58

0001 #include <stdexcept>
0002 #include <string>
0003 #include "OnlineDB/Oracle/interface/Oracle.h"
0004 
0005 #include "OnlineDB/EcalCondDB/interface/FEConfigBadXTDat.h"
0006 
0007 using namespace std;
0008 using namespace oracle::occi;
0009 
0010 FEConfigBadXTDat::FEConfigBadXTDat() {
0011   m_env = nullptr;
0012   m_conn = nullptr;
0013   m_writeStmt = nullptr;
0014   m_readStmt = nullptr;
0015 
0016   m_tcc = 0;
0017   m_fed = 0;
0018   m_tt = 0;
0019   m_xt = 0;
0020   m_t1 = 0;
0021 }
0022 
0023 FEConfigBadXTDat::~FEConfigBadXTDat() {}
0024 
0025 void FEConfigBadXTDat::prepareWrite() noexcept(false) {
0026   this->checkConnection();
0027 
0028   try {
0029     m_writeStmt = m_conn->createStatement();
0030     m_writeStmt->setSQL("INSERT INTO " + getTable() +
0031                         " (rec_id, tcc_id,fed_id, tt_id, CRY_id, status ) "
0032                         "VALUES (:1, :2, :3, :4, :5 ,:6 )");
0033   } catch (SQLException& e) {
0034     throw(std::runtime_error("FEConfigBadXTDat::prepareWrite():  " + e.getMessage()));
0035   }
0036 }
0037 
0038 void FEConfigBadXTDat::writeDB(const FEConfigBadXTDat* item, FEConfigBadXTInfo* iov) noexcept(false) {
0039   this->checkConnection();
0040 
0041   try {
0042     m_writeStmt->setInt(1, item->getId());
0043     m_writeStmt->setInt(2, item->getTCCId());
0044     m_writeStmt->setInt(3, item->getFedId());
0045     m_writeStmt->setInt(4, item->getTTId());
0046     m_writeStmt->setInt(5, item->getXTId());
0047     m_writeStmt->setInt(6, item->getStatus());
0048 
0049     m_writeStmt->executeUpdate();
0050   } catch (SQLException& e) {
0051     throw(std::runtime_error("FEConfigBadXTDat::writeDB():  " + e.getMessage()));
0052   }
0053 }
0054 
0055 void FEConfigBadXTDat::fetchData(std::vector<FEConfigBadXTDat>* p, FEConfigBadXTInfo* iov) noexcept(false) {
0056   this->checkConnection();
0057 
0058   iov->setConnection(m_env, m_conn);
0059   int iovID = iov->fetchID();
0060   if (!iovID) {
0061     //  throw(std::runtime_error("FEConfigBadXTDat::writeDB:  IOV not in DB"));
0062     return;
0063   }
0064 
0065   try {
0066     m_readStmt->setSQL("SELECT * FROM " + getTable() +
0067                        " WHERE rec_id = :rec_id order by tcc_id, fed_id, tt_id , cry_id ");
0068     m_readStmt->setInt(1, iovID);
0069     ResultSet* rset = m_readStmt->executeQuery();
0070 
0071     //    std::vector< FEConfigBadXTDat > p;
0072     FEConfigBadXTDat dat;
0073     while (rset->next()) {
0074       // dat.setId( rset->getInt(1) );
0075       dat.setTCCId(rset->getInt(2));
0076       dat.setFedId(rset->getInt(3));
0077       dat.setTTId(rset->getInt(4));
0078       dat.setXTId(rset->getInt(5));
0079       dat.setStatus(rset->getInt(6));
0080 
0081       p->push_back(dat);
0082     }
0083   } catch (SQLException& e) {
0084     throw(std::runtime_error("FEConfigBadXTDat::fetchData():  " + e.getMessage()));
0085   }
0086 }
0087 
0088 //  ************************************************************************   //
0089 
0090 void FEConfigBadXTDat::writeArrayDB(const std::vector<FEConfigBadXTDat>& data, FEConfigBadXTInfo* iov) noexcept(false) {
0091   this->checkConnection();
0092 
0093   int iovID = iov->fetchID();
0094   if (!iovID) {
0095     throw(std::runtime_error("FEConfigDelays::writeArrayDB:  FEConfigBadXTInfo not in DB"));
0096   }
0097 
0098   int nrows = data.size();
0099   int* ids = new int[nrows];
0100   int* xx = new int[nrows];
0101   int* yy = new int[nrows];
0102   int* zz = new int[nrows];
0103   int* z1 = new int[nrows];
0104   int* st = new int[nrows];
0105 
0106   ub2* ids_len = new ub2[nrows];
0107   ub2* x_len = new ub2[nrows];
0108   ub2* y_len = new ub2[nrows];
0109   ub2* z_len = new ub2[nrows];
0110   ub2* z1_len = new ub2[nrows];
0111   ub2* st_len = new ub2[nrows];
0112 
0113   FEConfigBadXTDat dataitem;
0114 
0115   for (size_t count = 0; count != data.size(); count++) {
0116     dataitem = data[count];
0117     ids[count] = iovID;
0118     xx[count] = dataitem.getTCCId();
0119     yy[count] = dataitem.getFedId();
0120     zz[count] = dataitem.getTTId();
0121     z1[count] = dataitem.getXTId();
0122     st[count] = dataitem.getStatus();
0123 
0124     ids_len[count] = sizeof(ids[count]);
0125     x_len[count] = sizeof(xx[count]);
0126     y_len[count] = sizeof(yy[count]);
0127     z_len[count] = sizeof(zz[count]);
0128     z1_len[count] = sizeof(z1[count]);
0129     st_len[count] = sizeof(st[count]);
0130   }
0131 
0132   try {
0133     m_writeStmt->setDataBuffer(1, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len);
0134     m_writeStmt->setDataBuffer(2, (dvoid*)xx, OCCIINT, sizeof(xx[0]), x_len);
0135     m_writeStmt->setDataBuffer(3, (dvoid*)yy, OCCIINT, sizeof(yy[0]), y_len);
0136     m_writeStmt->setDataBuffer(4, (dvoid*)zz, OCCIINT, sizeof(zz[0]), z_len);
0137     m_writeStmt->setDataBuffer(5, (dvoid*)z1, OCCIINT, sizeof(z1[0]), z1_len);
0138     m_writeStmt->setDataBuffer(6, (dvoid*)st, OCCIINT, sizeof(st[0]), st_len);
0139 
0140     m_writeStmt->executeArrayUpdate(nrows);
0141 
0142     delete[] ids;
0143     delete[] xx;
0144     delete[] yy;
0145     delete[] zz;
0146     delete[] z1;
0147     delete[] st;
0148 
0149     delete[] ids_len;
0150     delete[] x_len;
0151     delete[] y_len;
0152     delete[] z_len;
0153     delete[] z1_len;
0154     delete[] st_len;
0155 
0156   } catch (SQLException& e) {
0157     throw(std::runtime_error("FEConfigBadXTDat::writeArrayDB():  " + e.getMessage()));
0158   }
0159 }