00001 #include <stdexcept>
00002 #include <string>
00003 #include "OnlineDB/Oracle/interface/Oracle.h"
00004
00005 #include "OnlineDB/EcalCondDB/interface/LMFLaserBlueTimeDat.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 LMFLaserBlueTimeDat::LMFLaserBlueTimeDat()
00013 {
00014 m_env = NULL;
00015 m_conn = NULL;
00016 m_writeStmt = NULL;
00017 m_readStmt = NULL;
00018
00019 m_timing = 0;
00020 }
00021
00022
00023
00024 LMFLaserBlueTimeDat::~LMFLaserBlueTimeDat()
00025 {
00026 }
00027
00028
00029
00030 void LMFLaserBlueTimeDat::prepareWrite()
00031 throw(runtime_error)
00032 {
00033 this->checkConnection();
00034
00035 try {
00036 m_writeStmt = m_conn->createStatement();
00037 m_writeStmt->setSQL("INSERT INTO lmf_laser_blue_time_dat (iov_id, logic_id, "
00038 "timing ) "
00039 "VALUES (:iov_id, :logic_id, "
00040 ":3 )");
00041 } catch (SQLException &e) {
00042 throw(runtime_error("LMFLaserBlueTimeDat::prepareWrite(): "+e.getMessage()));
00043 }
00044 }
00045
00046
00047
00048 void LMFLaserBlueTimeDat::writeDB(const EcalLogicID* ecid, const LMFLaserBlueTimeDat* item, LMFRunIOV* iov)
00049 throw(runtime_error)
00050 {
00051 this->checkConnection();
00052 this->checkPrepare();
00053
00054 int iovID = iov->fetchID();
00055 if (!iovID) { throw(runtime_error("LMFLaserBlueTimeDat::writeDB: IOV not in DB")); }
00056
00057 int logicID = ecid->getLogicID();
00058 if (!logicID) { throw(runtime_error("LMFLaserBlueTimeDat::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->getTiming() );
00065
00066 m_writeStmt->executeUpdate();
00067 } catch (SQLException &e) {
00068 throw(runtime_error("LMFLaserBlueTimeDat::writeDB(): "+e.getMessage()));
00069 }
00070 }
00071
00072
00073
00074 void LMFLaserBlueTimeDat::fetchData(std::map< EcalLogicID, LMFLaserBlueTimeDat >* fillMap, LMFRunIOV* iov)
00075 throw(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
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.timing "
00091 "FROM channelview cv JOIN lmf_laser_blue_time_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, LMFLaserBlueTimeDat > p;
00098 LMFLaserBlueTimeDat dat;
00099 while(rset->next()) {
00100 p.first = EcalLogicID( rset->getString(1),
00101 rset->getInt(2),
00102 rset->getInt(3),
00103 rset->getInt(4),
00104 rset->getInt(5),
00105 rset->getString(6));
00106
00107 dat.setTiming( rset->getFloat(7) );
00108
00109
00110 p.second = dat;
00111 fillMap->insert(p);
00112 }
00113
00114 } catch (SQLException &e) {
00115 throw(runtime_error("LMFLaserBlueTimeDat::fetchData(): "+e.getMessage()));
00116 }
00117 }