File indexing completed on 2024-04-06 12:23:02
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
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
0072 FEConfigBadXTDat dat;
0073 while (rset->next()) {
0074
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 }