00001 #include <stdexcept>
00002 #include <string>
00003 #include "OnlineDB/Oracle/interface/Oracle.h"
00004
00005 #include "OnlineDB/EcalCondDB/interface/LMFMatacqBlueDat.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 LMFMatacqBlueDat::LMFMatacqBlueDat()
00013 {
00014 m_env = NULL;
00015 m_conn = NULL;
00016 m_writeStmt = NULL;
00017 m_readStmt = NULL;
00018
00019 m_amplitude = 0;
00020 m_timeoffset = 0;
00021 m_width = 0;
00022 }
00023
00024
00025
00026 LMFMatacqBlueDat::~LMFMatacqBlueDat()
00027 {
00028 }
00029
00030
00031
00032 void LMFMatacqBlueDat::prepareWrite()
00033 throw(runtime_error)
00034 {
00035 this->checkConnection();
00036
00037 try {
00038 m_writeStmt = m_conn->createStatement();
00039 m_writeStmt->setSQL("INSERT INTO lmf_matacq_blue_dat (iov_id, logic_id, "
00040 "amplitude, width, timeoffset) "
00041 "VALUES (:iov_id, :logic_id, "
00042 ":3, :4, :5)");
00043 } catch (SQLException &e) {
00044 throw(runtime_error("LMFMatacqBlueDat::prepareWrite(): "+e.getMessage()));
00045 }
00046 }
00047
00048
00049
00050 void LMFMatacqBlueDat::writeDB(const EcalLogicID* ecid, const LMFMatacqBlueDat* item, LMFRunIOV* iov)
00051 throw(runtime_error)
00052 {
00053 this->checkConnection();
00054 this->checkPrepare();
00055
00056 int iovID = iov->fetchID();
00057 if (!iovID) { throw(runtime_error("LMFMatacqBlueDat::writeDB: IOV not in DB")); }
00058
00059 int logicID = ecid->getLogicID();
00060 if (!logicID) { throw(runtime_error("LMFMatacqBlueDat::writeDB: Bad EcalLogicID")); }
00061
00062 try {
00063 m_writeStmt->setInt(1, iovID);
00064 m_writeStmt->setInt(2, logicID);
00065
00066 m_writeStmt->setFloat(3, item->getAmplitude() );
00067 m_writeStmt->setFloat(4, item->getWidth() );
00068 m_writeStmt->setFloat(5, item->getTimeOffset() );
00069
00070 m_writeStmt->executeUpdate();
00071 } catch (SQLException &e) {
00072 throw(runtime_error("LMFMatacqBlueDat::writeDB(): "+e.getMessage()));
00073 }
00074 }
00075
00076
00077
00078 void LMFMatacqBlueDat::fetchData(std::map< EcalLogicID, LMFMatacqBlueDat >* fillMap, LMFRunIOV* iov)
00079 throw(runtime_error)
00080 {
00081 this->checkConnection();
00082 fillMap->clear();
00083
00084 iov->setConnection(m_env, m_conn);
00085 int iovID = iov->fetchID();
00086 if (!iovID) {
00087
00088 return;
00089 }
00090
00091 try {
00092
00093 m_readStmt->setSQL("SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
00094 "d.amplitude, d.width, d.timeoffset "
00095 "FROM channelview cv JOIN lmf_matacq_blue_dat d "
00096 "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
00097 "WHERE d.iov_id = :iov_id");
00098 m_readStmt->setInt(1, iovID);
00099 ResultSet* rset = m_readStmt->executeQuery();
00100
00101 std::pair< EcalLogicID, LMFMatacqBlueDat > p;
00102 LMFMatacqBlueDat dat;
00103 while(rset->next()) {
00104 p.first = EcalLogicID( rset->getString(1),
00105 rset->getInt(2),
00106 rset->getInt(3),
00107 rset->getInt(4),
00108 rset->getInt(5),
00109 rset->getString(6));
00110
00111 dat.setAmplitude( rset->getFloat(7) );
00112 dat.setWidth( rset->getFloat(8) );
00113 dat.setTimeOffset( rset->getFloat(9) );
00114
00115 p.second = dat;
00116 fillMap->insert(p);
00117 }
00118
00119 } catch (SQLException &e) {
00120 throw(runtime_error("LMFMatacqBlueDat::fetchData(): "+e.getMessage()));
00121 }
00122 }