#include <OnlineDB/EcalCondDB/interface/DCUIDarkDat.h>
Public Member Functions | |
DCUIDarkDat () | |
float | getAPDIDark () const |
std::string | getTable () |
void | setAPDIDark (float i) |
~DCUIDarkDat () | |
Private Member Functions | |
void | fetchData (std::map< EcalLogicID, DCUIDarkDat > *fillVec, DCUIOV *iov) throw (std::runtime_error) |
void | prepareWrite () throw (std::runtime_error) |
void | writeArrayDB (const std::map< EcalLogicID, DCUIDarkDat > *data, DCUIOV *iov) throw (std::runtime_error) |
void | writeDB (const EcalLogicID *ecid, const DCUIDarkDat *item, DCUIOV *iov) throw (std::runtime_error) |
Private Attributes | |
float | m_apdIDark |
Friends | |
class | EcalCondDBInterface |
Definition at line 12 of file DCUIDarkDat.h.
DCUIDarkDat::DCUIDarkDat | ( | ) |
Definition at line 12 of file DCUIDarkDat.cc.
References m_apdIDark, 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_apdIDark = 0; 00020 }
DCUIDarkDat::~DCUIDarkDat | ( | ) |
void DCUIDarkDat::fetchData | ( | std::map< EcalLogicID, DCUIDarkDat > * | fillVec, | |
DCUIOV * | iov | |||
) | throw (std::runtime_error) [private] |
Definition at line 74 of file DCUIDarkDat.cc.
References IDBObject::checkConnection(), e, IDBObject::m_conn, IDBObject::m_env, IDataItem::m_readStmt, p, and setAPDIDark().
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("DCUIDarkDat::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.apd_idark " 00091 "FROM channelview cv JOIN dcu_idark_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, DCUIDarkDat > p; 00098 DCUIDarkDat 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.setAPDIDark( rset->getFloat(7) ); 00108 00109 p.second = dat; 00110 fillMap->insert(p); 00111 } 00112 } catch (SQLException &e) { 00113 throw(runtime_error("DCUIDarkDat::fetchData(): "+e.getMessage())); 00114 } 00115 }
float DCUIDarkDat::getAPDIDark | ( | ) | const [inline] |
Definition at line 22 of file DCUIDarkDat.h.
References m_apdIDark.
Referenced by writeArrayDB().
00022 { return m_apdIDark; }
std::string DCUIDarkDat::getTable | ( | ) | [inline, virtual] |
void DCUIDarkDat::prepareWrite | ( | ) | throw (std::runtime_error) [private, virtual] |
Implements IDataItem.
Definition at line 30 of file DCUIDarkDat.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_idark_dat (iov_id, logic_id, " 00038 "apd_idark) " 00039 "VALUES (:iov_id, :logic_id, " 00040 ":apd_idark)"); 00041 } catch (SQLException &e) { 00042 throw(runtime_error("DCUIDarkDat::prepareWrite(): "+e.getMessage())); 00043 } 00044 }
void DCUIDarkDat::setAPDIDark | ( | float | i | ) | [inline] |
Definition at line 21 of file DCUIDarkDat.h.
References m_apdIDark.
Referenced by fetchData().
00021 { m_apdIDark = i; }
void DCUIDarkDat::writeArrayDB | ( | const std::map< EcalLogicID, DCUIDarkDat > * | data, | |
DCUIOV * | iov | |||
) | throw (std::runtime_error) [private] |
Definition at line 116 of file DCUIDarkDat.cc.
References IDBObject::checkConnection(), IDataItem::checkPrepare(), count, data, e, getAPDIDark(), 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("DCUIDarkDat::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 DCUIDarkDat* dataitem; 00137 int count=0; 00138 typedef map< EcalLogicID, DCUIDarkDat >::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("DCUIDarkDat::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->getAPDIDark(); 00149 00150 xx[count]=x; 00151 00152 ids_len[count]=sizeof(ids[count]); 00153 iov_len[count]=sizeof(iovid_vec[count]); 00154 00155 x_len[count]=sizeof(xx[count]); 00156 00157 00158 count++; 00159 } 00160 00161 00162 try { 00163 m_writeStmt->setDataBuffer(1, (dvoid*)iovid_vec, OCCIINT, sizeof(iovid_vec[0]),iov_len); 00164 m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len ); 00165 m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIFLOAT , sizeof(xx[0]), x_len ); 00166 00167 m_writeStmt->executeArrayUpdate(nrows); 00168 00169 delete [] ids; 00170 delete [] iovid_vec; 00171 delete [] xx; 00172 00173 delete [] ids_len; 00174 delete [] iov_len; 00175 delete [] x_len; 00176 00177 00178 } catch (SQLException &e) { 00179 throw(runtime_error("DCUIDarkDat::writeArrayDB(): "+e.getMessage())); 00180 } 00181 }
void DCUIDarkDat::writeDB | ( | const EcalLogicID * | ecid, | |
const DCUIDarkDat * | item, | |||
DCUIOV * | iov | |||
) | throw (std::runtime_error) [private] |
Definition at line 48 of file DCUIDarkDat.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("DCUIDarkDat::writeDB: IOV not in DB")); } 00056 00057 int logicID = ecid->getLogicID(); 00058 if (!logicID) { throw(runtime_error("DCUIDarkDat::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->getAPDIDark() ); 00065 00066 m_writeStmt->executeUpdate(); 00067 } catch (SQLException &e) { 00068 throw(runtime_error("DCUIDarkDat::writeDB(): "+e.getMessage())); 00069 } 00070 }
friend class EcalCondDBInterface [friend] |
float DCUIDarkDat::m_apdIDark [private] |
Definition at line 39 of file DCUIDarkDat.h.
Referenced by DCUIDarkDat(), getAPDIDark(), and setAPDIDark().