libdballe 9.6
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
18namespace dballe {
19namespace db {
20namespace v7 {
21
22template<typename Traits>
24{
25protected:
26 typedef typename Traits::BatchValue BatchValue;
27 static const char* table_name;
28
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
52public:
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
136extern template class DataCommon<StationDataTraits>;
137extern template class DataCommon<DataTraits>;
138
140{
141 using DataCommon<StationDataTraits>::DataCommon;
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
155struct Data : public DataCommon<DataTraits>
156{
157 using DataCommon<DataTraits>::DataCommon;
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
Definition: db/v7/data.h:24
void read_attrs_into_values(Tracer<> &trc, int id_data, Values &values, const db::AttrList &exclude)
Load attributes from the database into a Values, except those whose Varcode is in exclude
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:
virtual void remove(Tracer<> &trc, const v7::IdQueryBuilder &qb)=0
Run the query to delete all records selected by the given QueryBuilder.
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.
virtual void remove_all_attrs(Tracer<> &trc, int id_data)=0
Remove all attributes from a variable.
virtual void dump(FILE *out)=0
Dump the entire contents of the table to an output stream.
virtual void write_attrs(Tracer<> &trc, int id_data, const Values &values)=0
Replace the attributes of a variable with those in Values.
void read_attrs_into_values(Tracer<> &trc, int id_data, Values &values)
Load attributes from the database into a Values.
void remove_attrs(Tracer<> &trc, int data_id, const db::AttrList &attrs)
Remove the given attributes from the given variable, if they exist.
virtual void remove_by_id(Tracer<> &trc, int id)=0
Run the query to delete the record with the given ID.
Smart pointer for trace::Step objects, which calls done() when going out of scope.
Definition: db/v7/fwd.h:46
Common definitions.
uint16_t Varcode
Forward declarations for public dballe/sql names.
Definition: types.h:851
Range of datetimes.
Definition: types.h:295
Date and time.
Definition: types.h:165
Collection of Value objects, indexed by wreport::Varcode.
Definition: values.h:177
Definition: db/v7/data.h:113
Definition: qbuilder.h:92
Definition: db/v7/data.h:131
Definition: db/v7/data.h:156
virtual void query(Tracer<> &trc, int id_station, const Datetime &datetime, std::function< void(int id, int id_levtr, wreport::Varcode code)> dest)=0
Query contents of the data table.
virtual void insert(Tracer<> &trc, int id_station, const Datetime &datetime, std::vector< batch::MeasuredDatum > &vars, bool with_attrs)=0
Bulk variable insert.
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
Run a data query, iterating on the resulting variables.
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
Run a summary query, iterating on the resulting variables.
Definition: qbuilder.h:116
Definition: db/v7/data.h:101
Definition: db/v7/data.h:125
Definition: db/v7/data.h:140
virtual void insert(Tracer<> &trc, int id_station, std::vector< batch::StationDatum > &vars, bool with_attrs)=0
Bulk variable insert.
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
Run a station data query, iterating on the resulting variables.
virtual void query(Tracer<> &trc, int id_station, std::function< void(int id, wreport::Varcode code)> dest)=0
Query contents of the data table.
Definition: qbuilder.h:125
Definition: transaction.h:16
Structures used as input to database insert functions.