13 m_writeStmt =
nullptr;
26 this->checkConnection();
29 m_writeStmt = m_conn->createStatement();
30 m_writeStmt->setSQL(
"INSERT INTO " + getTable() +
31 " (rec_id, tcc_id,fed_id, tt_id, CRY_id, status ) " 32 "VALUES (:1, :2, :3, :4, :5 ,:6 )");
34 throw(std::runtime_error(
"FEConfigBadXTDat::prepareWrite(): " +
e.getMessage()));
39 this->checkConnection();
42 m_writeStmt->setInt(1,
item->getId());
43 m_writeStmt->setInt(2,
item->getTCCId());
44 m_writeStmt->setInt(3,
item->getFedId());
45 m_writeStmt->setInt(4,
item->getTTId());
46 m_writeStmt->setInt(5,
item->getXTId());
47 m_writeStmt->setInt(6,
item->getStatus());
49 m_writeStmt->executeUpdate();
51 throw(std::runtime_error(
"FEConfigBadXTDat::writeDB(): " +
e.getMessage()));
56 this->checkConnection();
58 iov->setConnection(m_env, m_conn);
59 int iovID = iov->fetchID();
66 m_readStmt->setSQL(
"SELECT * FROM " + getTable() +
67 " WHERE rec_id = :rec_id order by tcc_id, fed_id, tt_id , cry_id ");
68 m_readStmt->setInt(1, iovID);
69 ResultSet* rset = m_readStmt->executeQuery();
73 while (rset->next()) {
84 throw(std::runtime_error(
"FEConfigBadXTDat::fetchData(): " +
e.getMessage()));
91 this->checkConnection();
93 int iovID = iov->fetchID();
95 throw(std::runtime_error(
"FEConfigDelays::writeArrayDB: FEConfigBadXTInfo not in DB"));
98 int nrows =
data.size();
99 int* ids =
new int[nrows];
100 int*
xx =
new int[nrows];
101 int*
yy =
new int[nrows];
102 int*
zz =
new int[nrows];
103 int*
z1 =
new int[nrows];
104 int* st =
new int[nrows];
106 ub2* ids_len =
new ub2[nrows];
107 ub2* x_len =
new ub2[nrows];
108 ub2* y_len =
new ub2[nrows];
109 ub2* z_len =
new ub2[nrows];
110 ub2* z1_len =
new ub2[nrows];
111 ub2* st_len =
new ub2[nrows];
133 m_writeStmt->setDataBuffer(1, (dvoid*)ids, OCCIINT,
sizeof(ids[0]), ids_len);
134 m_writeStmt->setDataBuffer(2, (dvoid*)
xx, OCCIINT,
sizeof(
xx[0]), x_len);
135 m_writeStmt->setDataBuffer(3, (dvoid*)
yy, OCCIINT,
sizeof(
yy[0]), y_len);
136 m_writeStmt->setDataBuffer(4, (dvoid*)
zz, OCCIINT,
sizeof(
zz[0]), z_len);
137 m_writeStmt->setDataBuffer(5, (dvoid*)
z1, OCCIINT,
sizeof(
z1[0]), z1_len);
138 m_writeStmt->setDataBuffer(6, (dvoid*)st, OCCIINT,
sizeof(st[0]), st_len);
140 m_writeStmt->executeArrayUpdate(nrows);
157 throw(std::runtime_error(
"FEConfigBadXTDat::writeArrayDB(): " +
e.getMessage()));
void prepareWrite() noexcept(false) override
void writeDB(const FEConfigBadXTDat *item, FEConfigBadXTInfo *iov) noexcept(false)
void fetchData(std::vector< FEConfigBadXTDat > *fillMap, FEConfigBadXTInfo *iov) noexcept(false)
void writeArrayDB(const std::vector< FEConfigBadXTDat > &data, FEConfigBadXTInfo *iov) noexcept(false)
~FEConfigBadXTDat() override
char data[epos_bytes_allocation]
oracle::occi::SQLException SQLException