16 m_writeStmt =
nullptr;
35 this->checkConnection();
38 m_writeStmt = m_conn->createStatement();
39 m_writeStmt->setSQL(
"INSERT INTO mon_delays_tt_dat (iov_id, logic_id, " 40 "delay_mean, delay_rms, task_status) " 41 "VALUES (:iov_id, :logic_id, " 42 ":delay_mean, :delay_rms, :task_status)");
43 }
catch (SQLException &
e) {
44 throw(std::runtime_error(
std::string(
"MonDelaysTTDat::prepareWrite(): ")+getOraMessage(&e)));
53 this->checkConnection();
56 int iovID = iov->fetchID();
57 if (!iovID) {
throw(std::runtime_error(
"MonDelaysTTDat::writeDB: IOV not in DB")); }
59 int logicID = ecid->getLogicID();
60 if (!logicID) {
throw(std::runtime_error(
"MonDelaysTTDat::writeDB: Bad EcalLogicID")); }
63 m_writeStmt->setInt(1, iovID);
64 m_writeStmt->setInt(2, logicID);
66 m_writeStmt->setFloat(3, item->getDelayMean() );
67 m_writeStmt->setFloat(4, item->getDelayRMS() );
68 m_writeStmt->setInt(5, item->getTaskStatus() );
70 m_writeStmt->executeUpdate();
71 }
catch (SQLException &
e) {
72 throw(std::runtime_error(
std::string(
"MonDelaysTTDat::writeDB(): ")+getOraMessage(&e)));
81 this->checkConnection();
84 iov->setConnection(m_env, m_conn);
85 int iovID = iov->fetchID();
93 m_readStmt->setSQL(
"SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, " 94 "d.delay_mean, d.delay_rms, d.task_status " 95 "FROM channelview cv JOIN mon_delays_tt_dat d " 96 "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to " 97 "WHERE d.iov_id = :iov_id");
98 m_readStmt->setInt(1, iovID);
99 ResultSet* rset = m_readStmt->executeQuery();
101 std::pair< EcalLogicID, MonDelaysTTDat >
p;
103 while(rset->next()) {
109 getOraString(rset,6));
119 }
catch (SQLException &
e) {
120 throw(std::runtime_error(
std::string(
"MonDelaysTTDat::fetchData(): ")+getOraMessage(&e)));
127 this->checkConnection();
128 this->checkPrepare();
130 int iovID = iov->fetchID();
131 if (!iovID) {
throw(std::runtime_error(
"MonDelaysTTDat::writeArrayDB: IOV not in DB")); }
134 int nrows=
data->size();
135 int* ids=
new int[nrows];
136 int* iovid_vec=
new int[nrows];
137 float*
xx=
new float[nrows];
138 float*
yy=
new float[nrows];
139 int* st=
new int[nrows];
141 ub2* ids_len=
new ub2[nrows];
142 ub2* iov_len=
new ub2[nrows];
143 ub2* x_len=
new ub2[nrows];
144 ub2* y_len=
new ub2[nrows];
145 ub2* st_len=
new ub2[nrows];
150 typedef map< EcalLogicID, MonDelaysTTDat >::const_iterator CI;
151 for (CI
p =
data->begin();
p !=
data->end(); ++
p) {
152 channel = &(
p->first);
154 if (!logicID) {
throw(std::runtime_error(
"MonDelaysTTDat::writeArrayDB: Bad EcalLogicID")); }
156 iovid_vec[
count]=iovID;
158 dataitem = &(
p->second);
183 m_writeStmt->setDataBuffer(1, (dvoid*)iovid_vec, OCCIINT,
sizeof(iovid_vec[0]),iov_len);
184 m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT,
sizeof(ids[0]), ids_len );
185 m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIFLOAT ,
sizeof(xx[0]), x_len );
186 m_writeStmt->setDataBuffer(4, (dvoid*)yy, OCCIFLOAT ,
sizeof(yy[0]), y_len );
187 m_writeStmt->setDataBuffer(5, (dvoid*)st, OCCIINT ,
sizeof(st[0]), st_len );
190 m_writeStmt->executeArrayUpdate(nrows);
206 }
catch (SQLException &
e) {
207 throw(std::runtime_error(
std::string(
"MonDelaysTTDat::writeArrayDB(): ")+getOraMessage(&e)));
void fetchData(std::map< EcalLogicID, MonDelaysTTDat > *fillVec, MonRunIOV *iov) noexcept(false)
~MonDelaysTTDat() override
void setDelayRMS(float rms)
float getDelayRMS() const
void setTaskStatus(bool status)
bool getTaskStatus() const
float getDelayMean() const
void writeArrayDB(const std::map< EcalLogicID, MonDelaysTTDat > *data, MonRunIOV *iov) noexcept(false)
char data[epos_bytes_allocation]
void writeDB(const EcalLogicID *ecid, const MonDelaysTTDat *item, MonRunIOV *iov) noexcept(false)
void prepareWrite() noexcept(false) override
void setDelayMean(float mean)