libdballe  9.11
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 
67  virtual void read_attrs(Tracer<>& trc, int id_data, std::function<void(std::unique_ptr<wreport::Var>)> dest) = 0;
68 
77  void merge_attrs(Tracer<>& trc, int id_data, const Values& attrs);
78 
82  void remove_attrs(Tracer<>& trc, int data_id, const db::AttrList& attrs);
83 
85  virtual void update(Tracer<>& trc, std::vector<typename Traits::BatchValue>& vars, bool with_attrs) = 0;
86 
88  virtual void remove(Tracer<>& trc, const v7::IdQueryBuilder& qb) = 0;
89 
91  virtual void remove_by_id(Tracer<>& trc, int id) = 0;
92 
94  virtual void dump(FILE* out) = 0;
95 
96  virtual void clear_cache() = 0;
97 };
98 
99 
101 {
102  unsigned count = 0;
103  FILE* out;
104 
105  StationDataDumper(FILE* out);
106 
107  void print_head();
108  void print_row(int id, int id_station, wreport::Varcode code, const char* val, const std::vector<uint8_t>& attrs);
109  void print_tail();
110 };
111 
113 {
114  unsigned count = 0;
115  FILE* out;
116 
117  DataDumper(FILE* out);
118 
119  void print_head();
120  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);
121  void print_tail();
122 };
123 
125 {
127  static const char* table_name;
128 };
129 
131 {
133  static const char* table_name;
134 };
135 
136 extern template class DataCommon<StationDataTraits>;
137 extern template class DataCommon<DataTraits>;
138 
140 {
142 
144  virtual void insert(Tracer<>& trc, int id_station, std::vector<batch::StationDatum>& vars, bool with_attrs) = 0;
145 
147  virtual void query(Tracer<>& trc, int id_station, std::function<void(int id, wreport::Varcode code)> dest) = 0;
148 
152  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;
153 };
154 
156 {
158 
160  virtual void insert(Tracer<>& trc, int id_station, const Datetime& datetime, std::vector<batch::MeasuredDatum>& vars, bool with_attrs) = 0;
161 
163  virtual void query(Tracer<>& trc, int id_station, const Datetime& datetime, std::function<void(int id, int id_levtr, wreport::Varcode code)> dest) = 0;
164 
168  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;
169 
173  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;
174 };
175 
176 }
177 }
178 }
179 #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:112
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:294
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:124
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:139
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:130
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:850
Common definitions.
Structures used as input to database insert functions.
Definition: db/v7/data.h:100
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:155
Definition: qbuilder.h:91