|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
#include "CondCore/CondDB/interface/KeyList.h"
#include "CondCore/CondDB/interface/Session.h"
namespace cond {
namespace persistency {
void KeyList::init(IOVProxy iovProxy) {
m_proxy = iovProxy;
m_data.clear();
m_keys.clear();
}
void KeyList::init(KeyList const& originalKeyList) { init(originalKeyList.m_proxy); }
void KeyList::setKeys(const std::vector<unsigned long long>& keys) {
std::shared_ptr<SessionImpl> simpl = m_proxy.session();
if (!simpl.get())
cond::throwException("The KeyList has not been initialized.", "KeyList::setKeys");
Session s(simpl);
s.transaction().start(true);
m_keys = keys;
std::sort(m_keys.begin(), m_keys.end(), std::less<unsigned long long>());
m_data.clear();
m_data.resize(keys.size(), std::make_pair("", std::make_pair(cond::Binary(), cond::Binary())));
IOVArray keyIovs = m_proxy.selectAll();
for (size_t i = 0; i < m_keys.size(); ++i) {
if (m_keys[i] != 0) {
auto p = keyIovs.find(m_keys[i]);
if (p != keyIovs.end()) {
auto& item = m_data[i];
if (!s.fetchPayloadData((*p).payloadId, item.first, item.second.first, item.second.second))
cond::throwException("The Iov contains a broken payload reference.", "KeyList::setKeys");
}
}
}
s.transaction().commit();
}
std::pair<std::string, std::pair<cond::Binary, cond::Binary> > KeyList::loadFromDB(unsigned long long key) const {
std::pair<std::string, std::pair<cond::Binary, cond::Binary> > item;
if (key == 0) {
return item;
}
std::shared_ptr<SessionImpl> simpl = m_proxy.session();
if (!simpl.get())
cond::throwException("The KeyList has not been initialized.", "KeyList::loadFromDB");
Session s(simpl);
s.transaction().start(true);
IOVArray keyIovs = m_proxy.selectAll();
auto p = keyIovs.find(key);
if (p != keyIovs.end()) {
if (!s.fetchPayloadData((*p).payloadId, item.first, item.second.first, item.second.second))
cond::throwException("The Iov contains a broken payload reference.", "KeyList::loadFromDB");
} else {
throwException("Payload for key " + std::to_string(key) + " has not been found.", "KeyList::loadFromDB");
}
s.transaction().commit();
return item;
}
} // namespace persistency
} // namespace cond
|