#include <OnlineDB/EcalCondDB/interface/DCUCapsuleTempDat.h>
Public Member Functions | |
DCUCapsuleTempDat () | |
float | getCapsuleTemp () const |
std::string | getTable () |
void | setCapsuleTemp (float temp) |
~DCUCapsuleTempDat () | |
Private Member Functions | |
void | fetchData (std::map< EcalLogicID, DCUCapsuleTempDat > *fillVec, DCUIOV *iov) throw (std::runtime_error) |
void | prepareWrite () throw (std::runtime_error) |
void | writeArrayDB (const std::map< EcalLogicID, DCUCapsuleTempDat > *data, DCUIOV *iov) throw (std::runtime_error) |
void | writeDB (const EcalLogicID *ecid, const DCUCapsuleTempDat *item, DCUIOV *iov) throw (std::runtime_error) |
Private Attributes | |
float | m_capsuleTemp |
Friends | |
class | EcalCondDBInterface |
Definition at line 12 of file DCUCapsuleTempDat.h.
DCUCapsuleTempDat::DCUCapsuleTempDat | ( | ) |
Definition at line 12 of file DCUCapsuleTempDat.cc.
References m_capsuleTemp, IDBObject::m_conn, IDBObject::m_env, IDataItem::m_readStmt, IDataItem::m_writeStmt, and NULL.
00013 { 00014 m_env = NULL; 00015 m_conn = NULL; 00016 m_writeStmt = NULL; 00017 m_readStmt = NULL; 00018 00019 m_capsuleTemp = 0; 00020 }
DCUCapsuleTempDat::~DCUCapsuleTempDat | ( | ) |
void DCUCapsuleTempDat::fetchData | ( | std::map< EcalLogicID, DCUCapsuleTempDat > * | fillVec, | |
DCUIOV * | iov | |||
) | throw (std::runtime_error) [private] |
Definition at line 74 of file DCUCapsuleTempDat.cc.
References IDBObject::checkConnection(), e, IDBObject::m_conn, IDBObject::m_env, IDataItem::m_readStmt, p, and setCapsuleTemp().
00076 { 00077 this->checkConnection(); 00078 fillMap->clear(); 00079 00080 iov->setConnection(m_env, m_conn); 00081 int iovID = iov->fetchID(); 00082 if (!iovID) { 00083 // throw(runtime_error("DCUCapsuleTempDat::writeDB: IOV not in DB")); 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.capsule_temp " 00091 "FROM channelview cv JOIN dcu_capsule_temp_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, DCUCapsuleTempDat > p; 00098 DCUCapsuleTempDat dat; 00099 while(rset->next()) { 00100 p.first = EcalLogicID( rset->getString(1), // name 00101 rset->getInt(2), // logic_id 00102 rset->getInt(3), // id1 00103 rset->getInt(4), // id2 00104 rset->getInt(5), // id3 00105 rset->getString(6)); // maps_to 00106 00107 dat.setCapsuleTemp( rset->getFloat(7) ); 00108 00109 p.second = dat; 00110 fillMap->insert(p); 00111 } 00112 } catch (SQLException &e) { 00113 throw(runtime_error("DCUCapsuleTempDat::fetchData(): "+e.getMessage())); 00114 } 00115 }
float DCUCapsuleTempDat::getCapsuleTemp | ( | ) | const [inline] |
Definition at line 22 of file DCUCapsuleTempDat.h.
References m_capsuleTemp.
Referenced by writeArrayDB().
00022 { return m_capsuleTemp; }
std::string DCUCapsuleTempDat::getTable | ( | ) | [inline, virtual] |
void DCUCapsuleTempDat::prepareWrite | ( | ) | throw (std::runtime_error) [private, virtual] |
Implements IDataItem.
Definition at line 30 of file DCUCapsuleTempDat.cc.
References IDBObject::checkConnection(), e, IDBObject::m_conn, and IDataItem::m_writeStmt.
00032 { 00033 this->checkConnection(); 00034 00035 try { 00036 m_writeStmt = m_conn->createStatement(); 00037 m_writeStmt->setSQL("INSERT INTO dcu_capsule_temp_dat (iov_id, logic_id, " 00038 "capsule_temp) " 00039 "VALUES (:iov_id, :logic_id, " 00040 ":capsule_temp)"); 00041 } catch (SQLException &e) { 00042 throw(runtime_error("DCUCapsuleTempDat::prepareWrite(): "+e.getMessage())); 00043 } 00044 }
void DCUCapsuleTempDat::setCapsuleTemp | ( | float | temp | ) | [inline] |
Definition at line 21 of file DCUCapsuleTempDat.h.
References m_capsuleTemp.
Referenced by fetchData().
00021 { m_capsuleTemp = temp; }
void DCUCapsuleTempDat::writeArrayDB | ( | const std::map< EcalLogicID, DCUCapsuleTempDat > * | data, | |
DCUIOV * | iov | |||
) | throw (std::runtime_error) [private] |
Definition at line 116 of file DCUCapsuleTempDat.cc.
References IDBObject::checkConnection(), IDataItem::checkPrepare(), count, data, e, getCapsuleTemp(), EcalLogicID::getLogicID(), IDataItem::m_writeStmt, p, and x.
00118 { 00119 this->checkConnection(); 00120 this->checkPrepare(); 00121 00122 int iovID = iov->fetchID(); 00123 if (!iovID) { throw(runtime_error("DCUCapsuleTempDat::writeArrayDB: IOV not in DB")); } 00124 00125 00126 int nrows=data->size(); 00127 int* ids= new int[nrows]; 00128 int* iovid_vec= new int[nrows]; 00129 float* xx= new float[nrows]; 00130 00131 ub2* ids_len= new ub2[nrows]; 00132 ub2* iov_len= new ub2[nrows]; 00133 ub2* x_len= new ub2[nrows]; 00134 00135 const EcalLogicID* channel; 00136 const DCUCapsuleTempDat* dataitem; 00137 int count=0; 00138 typedef map< EcalLogicID, DCUCapsuleTempDat >::const_iterator CI; 00139 for (CI p = data->begin(); p != data->end(); ++p) { 00140 channel = &(p->first); 00141 int logicID = channel->getLogicID(); 00142 if (!logicID) { throw(runtime_error("DCUCapsuleTempDat::writeArrayDB: Bad EcalLogicID")); } 00143 ids[count]=logicID; 00144 iovid_vec[count]=iovID; 00145 00146 dataitem = &(p->second); 00147 // dataIface.writeDB( channel, dataitem, iov); 00148 float x=dataitem->getCapsuleTemp(); 00149 00150 xx[count]=x; 00151 00152 00153 ids_len[count]=sizeof(ids[count]); 00154 iov_len[count]=sizeof(iovid_vec[count]); 00155 00156 x_len[count]=sizeof(xx[count]); 00157 00158 00159 count++; 00160 } 00161 00162 00163 try { 00164 m_writeStmt->setDataBuffer(1, (dvoid*)iovid_vec, OCCIINT, sizeof(iovid_vec[0]),iov_len); 00165 m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len ); 00166 m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIFLOAT , sizeof(xx[0]), x_len ); 00167 00168 00169 m_writeStmt->executeArrayUpdate(nrows); 00170 00171 delete [] ids; 00172 delete [] iovid_vec; 00173 delete [] xx; 00174 00175 delete [] ids_len; 00176 delete [] iov_len; 00177 delete [] x_len; 00178 00179 00180 } catch (SQLException &e) { 00181 throw(runtime_error("DCUCapsuleTempDat::writeArrayDB(): "+e.getMessage())); 00182 } 00183 }
void DCUCapsuleTempDat::writeDB | ( | const EcalLogicID * | ecid, | |
const DCUCapsuleTempDat * | item, | |||
DCUIOV * | iov | |||
) | throw (std::runtime_error) [private] |
Definition at line 48 of file DCUCapsuleTempDat.cc.
References IDBObject::checkConnection(), IDataItem::checkPrepare(), e, and IDataItem::m_writeStmt.
00050 { 00051 this->checkConnection(); 00052 this->checkPrepare(); 00053 00054 int iovID = iov->fetchID(); 00055 if (!iovID) { throw(runtime_error("DCUCapsuleTempDat::writeDB: IOV not in DB")); } 00056 00057 int logicID = ecid->getLogicID(); 00058 if (!logicID) { throw(runtime_error("DCUCapsuleTempDat::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->getCapsuleTemp() ); 00065 00066 m_writeStmt->executeUpdate(); 00067 } catch (SQLException &e) { 00068 throw(runtime_error("DCUCapsuleTempDat::writeDB(): "+e.getMessage())); 00069 } 00070 }
friend class EcalCondDBInterface [friend] |
float DCUCapsuleTempDat::m_capsuleTemp [private] |
Definition at line 38 of file DCUCapsuleTempDat.h.
Referenced by DCUCapsuleTempDat(), getCapsuleTemp(), and setCapsuleTemp().