|
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
#include "FWCore/PluginManager/interface/PluginManager.h"
#include "FWCore/PluginManager/interface/standard.h"
#include "FWCore/PluginManager/interface/SharedLibrary.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/ServiceRegistry/interface/ServiceRegistry.h"
//
#include "CondCore/CondDB/interface/ConnectionPool.h"
//
#include <fstream>
#include <iomanip>
#include <cstdlib>
#include <iostream>
using namespace cond::persistency;
int readIov(IOVProxy& proxy, cond::Time_t targetTime, bool expectedOk) {
bool found = false;
cond::Iov_t iov;
std::cout << "#Testing tag " << proxy.tagInfo().name << std::endl;
try {
iov = proxy.getInterval(targetTime);
if (iov.since < cond::time::MAX_VAL)
found = true;
} catch (const Exception& e) {
std::cout << "# IOV " << targetTime << " not found: " << e.what() << std::endl;
}
if (expectedOk) {
if (found) {
std::cout << "#OK: found iov with since " << iov.since << " - till " << iov.till << " for time " << targetTime
<< std::endl;
return 0;
} else {
std::cout << "#OK: no valid iov found for time " << targetTime << std::endl;
return -1;
}
} else {
if (found) {
std::cout << "#ERROR: found iov=" << iov.since << " for time " << targetTime << std::endl;
return -1;
} else {
std::cout << "#OK: no valid iov found for time " << targetTime << std::endl;
return 0;
}
}
}
int run(const std::string& connectionString) {
try {
//*************
std::cout << "> Connecting with db in " << connectionString << std::endl;
ConnectionPool connPool;
connPool.setMessageVerbosity(coral::Debug);
Session session = connPool.createSession(connectionString, true);
session.transaction().start(false);
std::string pay0("Payload #0");
std::string pay1("Payload #1");
auto p0 = session.storePayload(pay0);
auto p1 = session.storePayload(pay1);
IOVEditor editor;
std::string tag0("MyTag0");
if (!session.existsIov(tag0)) {
editor = session.createIov<std::string>(tag0, cond::runnumber);
editor.setDescription(tag0 + " Test for timestamp selection");
editor.insert(100, p0);
editor.insert(200, p1);
editor.insert(1001, p0);
editor.insert(1500, p1);
editor.insert(2100, p0);
editor.insert(2500, p1);
editor.insert(10000, p0);
std::cout << "> inserted 7 iovs..." << std::endl;
editor.flush();
std::cout << "> iov changes flushed..." << std::endl;
}
std::string tag1("MyTag1");
if (!session.existsIov(tag1)) {
editor = session.createIov<std::string>(tag1, cond::runnumber);
editor.setDescription(tag1 + " Test for timestamp selection");
editor.insert(100, p0);
std::cout << "> inserted 1 iovs..." << std::endl;
editor.flush();
std::cout << "> iov changes flushed..." << std::endl;
}
session.transaction().commit();
std::cout << "> iov changes committed!..." << std::endl;
::sleep(2);
session.transaction().start();
IOVProxy proxy = session.readIov(tag0);
auto md = proxy.getMetadata();
std::cout << tag0 << " description is \"" << std::get<0>(md) << "\"" << std::endl;
readIov(proxy, 1, false);
readIov(proxy, 100, true);
readIov(proxy, 1499, true);
readIov(proxy, 1500, true);
readIov(proxy, 20000, true);
IOVArray iovs = proxy.selectAll();
iovs.find(101);
for (const auto i : iovs) {
std::cout << "# iov since " << i.since << " - till " << i.till << std::endl;
}
proxy = session.readIov(tag1);
md = proxy.getMetadata();
std::cout << tag1 << " description is \"" << std::get<0>(md) << "\"" << std::endl;
readIov(proxy, 1, false);
readIov(proxy, 100, true);
session.transaction().commit();
session.transaction().start(false);
auto ed = session.editIov(tag1);
ed.setDescription("Changed description for tag " + tag1);
ed.flush();
session.transaction().commit();
session.transaction().start();
md = session.readIov(tag1).getMetadata();
std::cout << tag1 << " description is \"" << std::get<0>(md) << "\"" << std::endl;
session.transaction().commit();
} catch (const std::exception& e) {
std::cout << "ERROR: " << e.what() << std::endl;
return -1;
} catch (...) {
std::cout << "UNEXPECTED FAILURE." << std::endl;
return -1;
}
std::cout << "## Run successfully completed." << std::endl;
return 0;
}
int main(int argc, char** argv) {
int ret = 0;
edmplugin::PluginManager::Config config;
edmplugin::PluginManager::configure(edmplugin::standard::config());
std::string connectionString0("sqlite_file:cms_conditions_2.db");
ret = run(connectionString0);
return ret;
}
|