|
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
|
#ifndef CondCore_CondDB_RunInfoSchema_h
#define CondCore_CondDB_RunInfoSchema_h
#include "DbCore.h"
#include "IDbSchema.h"
//
#include <boost/date_time/posix_time/posix_time.hpp>
namespace cond {
namespace persistency {
conddb_table(RUN_INFO) {
conddb_column(RUN_NUMBER, cond::Time_t);
conddb_column(START_TIME, boost::posix_time::ptime);
conddb_column(END_TIME, boost::posix_time::ptime);
struct MAX_RUN_NUMBER {
typedef cond::Time_t type;
static constexpr size_t size = 0;
static std::string tableName() { return RUN_NUMBER::tableName(); }
static std::string fullyQualifiedName() { return "MAX(" + RUN_NUMBER::fullyQualifiedName() + ")"; }
};
struct MIN_RUN_NUMBER {
typedef cond::Time_t type;
static constexpr size_t size = 0;
static std::string tableName() { return RUN_NUMBER::tableName(); }
static std::string fullyQualifiedName() { return "MIN(" + RUN_NUMBER::fullyQualifiedName() + ")"; }
};
struct MIN_START_TIME {
typedef boost::posix_time::ptime type;
static constexpr size_t size = 0;
static std::string tableName() { return START_TIME::tableName(); }
static std::string fullyQualifiedName() { return "MIN(" + START_TIME::fullyQualifiedName() + ")"; }
};
class Table : public IRunInfoTable {
public:
explicit Table(coral::ISchema& schema);
~Table() override {}
bool exists() override;
void create() override;
bool select(cond::Time_t runNumber, boost::posix_time::ptime& start, boost::posix_time::ptime& end) override;
cond::Time_t getLastInserted(boost::posix_time::ptime& start, boost::posix_time::ptime& end) override;
bool getInclusiveRunRange(
cond::Time_t lower,
cond::Time_t upper,
std::vector<std::tuple<cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime> >& runData)
override;
bool getInclusiveTimeRange(
const boost::posix_time::ptime& lower,
const boost::posix_time::ptime& upper,
std::vector<std::tuple<cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime> >& runData)
override;
void insertOne(cond::Time_t runNumber,
const boost::posix_time::ptime& start,
const boost::posix_time::ptime& end) override;
void insert(const std::vector<std::tuple<cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime> >&
runs) override;
void updateEnd(cond::Time_t runNumber, const boost::posix_time::ptime& end) override;
private:
coral::ISchema& m_schema;
};
}
class RunInfoSchema : public IRunInfoSchema {
public:
explicit RunInfoSchema(coral::ISchema& schema);
~RunInfoSchema() override {}
bool exists() override;
bool create() override;
IRunInfoTable& runInfoTable() override;
private:
RUN_INFO::Table m_runInfoTable;
};
} // namespace persistency
} // namespace cond
#endif
|