libdballe  8.3
db/v7/data.h
1 #ifndef DBALLE_DB_V7_DATAV7_H
2 #define DBALLE_DB_V7_DATAV7_H
3 
4 #include <dballe/fwd.h>
5 #include <dballe/values.h>
6 #include <dballe/core/fwd.h>
7 #include <dballe/core/defs.h>
8 #include <dballe/sql/fwd.h>
9 #include <dballe/db/defs.h>
10 #include <dballe/db/v7/fwd.h>
11 #include <wreport/var.h>
12 #include <memory>
13 #include <vector>
14 #include <list>
15 #include <cstdio>
16 #include <functional>
17 
18 namespace dballe {
19 namespace db {
20 namespace v7 {
21 
22 template<typename Traits>
24 {
25 protected:
26  typedef typename Traits::BatchValue BatchValue;
27  static const char* table_name;
28 
29  v7::Transaction& tr;
30 
34  void read_attrs_into_values(Tracer<>& trc, int id_data, Values& values);
35 
40  void read_attrs_into_values(Tracer<>& trc, int id_data, Values& values, const db::AttrList& exclude);
41 
45  virtual void write_attrs(Tracer<>& trc, int id_data, const Values& values) = 0;
46 
50  virtual void remove_all_attrs(Tracer<>& trc, int id_data) = 0;
51 
52 public:
53  DataCommon(v7::Transaction& tr) : tr(tr) {}
54  virtual ~DataCommon() {}
55 
65  virtual void read_attrs(Tracer<>& trc, int id_data, std::function<void(std::unique_ptr<wreport::Var>)> dest) = 0;
66 
75  void merge_attrs(Tracer<>& trc, int id_data, const Values& attrs);
76 
80  void remove_attrs(Tracer<>& trc, int data_id, const db::AttrList& attrs);
81 
83  virtual void update(Tracer<>& trc, std::vector<typename Traits::BatchValue>& vars, bool with_attrs) = 0;
84 
86  virtual void remove(Tracer<>& trc, const v7::IdQueryBuilder& qb) = 0;
87 
89  virtual void remove_by_id(Tracer<>& trc, int id) = 0;
90 
92  virtual void dump(FILE* out) = 0;
93 
94  virtual void clear_cache() = 0;
95 };
96 
97 
99 {
100  unsigned count = 0;
101  FILE* out;
102 
103  StationDataDumper(FILE* out);
104 
105  void print_head();
106  void print_row(int id, int id_station, wreport::Varcode code, const char* val, const std::vector<uint8_t>& attrs);
107  void print_tail();
108 };
109 
111 {
112  unsigned count = 0;
113  FILE* out;
114 
115  DataDumper(FILE* out);
116 
117  void print_head();
118  void print_row(int id, int id_station, int id_levtr, const Datetime& dt, wreport::Varcode code, const char* val, const std::vector<uint8_t>& attrs);
119  void print_tail();
120 };
121 
123 {
125  static const char* table_name;
126 };
127 
129 {
131  static const char* table_name;
132 };
133 
134 extern template class DataCommon<StationDataTraits>;
135 extern template class DataCommon<DataTraits>;
136 
138 {
140 
142  virtual void insert(Tracer<>& trc, int id_station, std::vector<batch::StationDatum>& vars, bool with_attrs) = 0;
143 
145  virtual void query(Tracer<>& trc, int id_station, std::function<void(int id, wreport::Varcode code)> dest) = 0;
146 
150  virtual void run_station_data_query(Tracer<>& trc, const v7::DataQueryBuilder& qb, std::function<void(const dballe::DBStation& station, int id_data, std::unique_ptr<wreport::Var> var)>) = 0;
151 };
152 
154 {
156 
158  virtual void insert(Tracer<>& trc, int id_station, const Datetime& datetime, std::vector<batch::MeasuredDatum>& vars, bool with_attrs) = 0;
159 
161  virtual void query(Tracer<>& trc, int id_station, const Datetime& datetime, std::function<void(int id, int id_levtr, wreport::Varcode code)> dest) = 0;
162 
166  virtual void run_data_query(Tracer<>& trc, const v7::DataQueryBuilder& qb, std::function<void(const dballe::DBStation& station, int id_levtr, const Datetime& datetime, int id_data, std::unique_ptr<wreport::Var> var)>) = 0;
167 
171  virtual void run_summary_query(Tracer<>& trc, const v7::SummaryQueryBuilder& qb, std::function<void(const dballe::DBStation& station, int id_levtr, wreport::Varcode code, const DatetimeRange& datetime, size_t size)>) = 0;
172 };
173 
174 }
175 }
176 }
177 #endif
Forward declarations for public dballe/sql names.
Definition: qbuilder.h:124
virtual void dump(FILE *out)=0
Dump the entire contents of the table to an output stream.
Definition: db/v7/data.h:110
Definition: qbuilder.h:115
void remove_attrs(Tracer<> &trc, int data_id, const db::AttrList &attrs)
Remove the given attributes from the given variable, if they exist.
Definition: db/v7/data.h:23
virtual void remove_all_attrs(Tracer<> &trc, int id_data)=0
Remove all attributes from a variable.
Definition: cmdline.h:18
virtual void read_attrs(Tracer<> &trc, int id_data, std::function< void(std::unique_ptr< wreport::Var >)> dest)=0
Load from the database all the attributes for var.
uint16_t Varcode
Range of datetimes.
Definition: types.h:291
virtual void write_attrs(Tracer<> &trc, int id_data, const Values &values)=0
Replace the attributes of a variable with those in Values.
Definition: transaction.h:15
Definition: db/v7/data.h:122
Smart pointer for trace::Step objects, which calls done() when going out of scope.
Definition: db/v7/fwd.h:45
Definition: db/v7/data.h:137
Date and time.
Definition: types.h:164
virtual void remove_by_id(Tracer<> &trc, int id)=0
Run the query to delete the record with the given ID.
Definition: db/v7/data.h:128
virtual void update(Tracer<> &trc, std::vector< typename Traits::BatchValue > &vars, bool with_attrs)=0
Bulk variable update.
void merge_attrs(Tracer<> &trc, int id_data, const Values &attrs)
Merge the given attributes with the existing attributes of the given variable:
Definition: types.h:847
Common definitions.
Structures used as input to database insert functions.
Definition: db/v7/data.h:98
void read_attrs_into_values(Tracer<> &trc, int id_data, Values &values)
Load attributes from the database into a Values.
Collection of Value objects, indexed by wreport::Varcode.
Definition: values.h:176
Definition: db/v7/data.h:153
Definition: qbuilder.h:91