Back to home page

Project CMSSW displayed by LXR

 
 

    


File indexing completed on 2021-02-14 13:32:06

0001 #include <stdexcept>
0002 #include "OnlineDB/Oracle/interface/Oracle.h"
0003 
0004 #include "OnlineDB/EcalCondDB/interface/ODDCUCycle.h"
0005 
0006 using namespace std;
0007 using namespace oracle::occi;
0008 
0009 ODDCUCycle::ODDCUCycle() {
0010   m_env = nullptr;
0011   m_conn = nullptr;
0012   m_writeStmt = nullptr;
0013   m_readStmt = nullptr;
0014   //
0015   m_ID = 0;
0016   m_dcu_config_id = 0;
0017 }
0018 
0019 ODDCUCycle::~ODDCUCycle() {}
0020 
0021 void ODDCUCycle::prepareWrite() noexcept(false) {
0022   this->checkConnection();
0023 
0024   try {
0025     m_writeStmt = m_conn->createStatement();
0026     m_writeStmt->setSQL(
0027         "INSERT INTO ECAL_DCU_Cycle (cycle_id, dcu_configuration_id ) "
0028         "VALUES (:1, :2 )");
0029   } catch (SQLException &e) {
0030     throw(std::runtime_error("ODDCUCycle::prepareWrite():  " + e.getMessage()));
0031   }
0032 }
0033 
0034 void ODDCUCycle::writeDB() noexcept(false) {
0035   this->checkConnection();
0036   this->checkPrepare();
0037 
0038   try {
0039     m_writeStmt->setInt(1, this->getId());
0040     m_writeStmt->setInt(2, this->getDCUConfigurationID());
0041 
0042     m_writeStmt->executeUpdate();
0043 
0044   } catch (SQLException &e) {
0045     throw(std::runtime_error("ODDCUCycle::writeDB:  " + e.getMessage()));
0046   }
0047 
0048   // Now get the ID
0049   if (!this->fetchID()) {
0050     throw(std::runtime_error("ODDCUCycle::writeDB:  Failed to write"));
0051   }
0052 }
0053 
0054 void ODDCUCycle::clear() { m_dcu_config_id = 0; }
0055 
0056 int ODDCUCycle::fetchID() noexcept(false) {
0057   // Return from memory if available
0058   if (m_ID) {
0059     return m_ID;
0060   }
0061 
0062   this->checkConnection();
0063 
0064   try {
0065     Statement *stmt = m_conn->createStatement();
0066     stmt->setSQL(
0067         "SELECT cycle_id, dcu_configuration_id FROM ecal_dcu_cycle "
0068         "WHERE cycle_id = :1 ");
0069     stmt->setInt(1, m_ID);
0070     ResultSet *rset = stmt->executeQuery();
0071 
0072     if (rset->next()) {
0073       m_ID = rset->getInt(1);
0074       m_dcu_config_id = rset->getInt(2);
0075     } else {
0076       m_ID = 0;
0077     }
0078     m_conn->terminateStatement(stmt);
0079   } catch (SQLException &e) {
0080     throw(std::runtime_error("ODDCUCycle::fetchID:  " + e.getMessage()));
0081   }
0082 
0083   return m_ID;
0084 }
0085 
0086 void ODDCUCycle::setByID(int id) noexcept(false) {
0087   this->checkConnection();
0088 
0089   try {
0090     Statement *stmt = m_conn->createStatement();
0091     stmt->setSQL(
0092         "SELECT cycle_id, dcu_configuration_id FROM ecal_dcu_cycle "
0093         "WHERE cycle_id = :1 ");
0094     stmt->setInt(1, id);
0095     ResultSet *rset = stmt->executeQuery();
0096 
0097     if (rset->next()) {
0098       m_ID = rset->getInt(1);
0099       m_dcu_config_id = rset->getInt(2);
0100     } else {
0101       m_ID = 0;
0102     }
0103     m_conn->terminateStatement(stmt);
0104   } catch (SQLException &e) {
0105     throw(std::runtime_error("ODDCUCycle::fetchID:  " + e.getMessage()));
0106   }
0107 }
0108 
0109 void ODDCUCycle::fetchData(ODDCUCycle *result) noexcept(false) {
0110   this->checkConnection();
0111   result->clear();
0112 
0113   if (result->getId() == 0) {
0114     throw(std::runtime_error("ODDCUConfig::fetchData(): no Id defined for this ODDCUConfig "));
0115   }
0116 
0117   try {
0118     m_readStmt->setSQL(
0119         "SELECT  dcu_configuration_id FROM ecal_dcu_cycle "
0120         "WHERE cycle_id = :1 ");
0121 
0122     m_readStmt->setInt(1, result->getId());
0123     ResultSet *rset = m_readStmt->executeQuery();
0124 
0125     rset->next();
0126 
0127     result->setDCUConfigurationID(rset->getInt(1));
0128 
0129   } catch (SQLException &e) {
0130     throw(std::runtime_error("ODDCUCycle::fetchData():  " + e.getMessage()));
0131   }
0132 }
0133 
0134 void ODDCUCycle::insertConfig() noexcept(false) {
0135   try {
0136     prepareWrite();
0137     writeDB();
0138     m_conn->commit();
0139     terminateWriteStatement();
0140   } catch (std::runtime_error &e) {
0141     m_conn->rollback();
0142     throw(e);
0143   } catch (...) {
0144     m_conn->rollback();
0145     throw(std::runtime_error("EcalCondDBInterface::insertDataSet:  Unknown exception caught"));
0146   }
0147 }