libdballe 9.6
db/v7/sqlite/data.h
1#ifndef DBALLE_DB_V7_SQLITE_DATA_H
2#define DBALLE_DB_V7_SQLITE_DATA_H
3
4#include <dballe/db/v7/data.h>
5#include <dballe/db/v7/cache.h>
6#include <dballe/sql/fwd.h>
7
8namespace dballe {
9namespace db {
10namespace v7 {
11namespace sqlite {
12struct DB;
13
14// Partial implementation of the common parts of StationData and Data
15template<typename Parent>
16class SQLiteDataCommon : public Parent
17{
18protected:
21
34
35public:
37 SQLiteDataCommon(const SQLiteDataCommon&) = delete;
38 SQLiteDataCommon(const SQLiteDataCommon&&) = delete;
39 SQLiteDataCommon& operator=(const SQLiteDataCommon&) = delete;
41
42 void update(Tracer<>& trc, std::vector<typename Parent::BatchValue>& vars, bool with_attrs) override;
43 void read_attrs(Tracer<>& trc, int id_data, std::function<void(std::unique_ptr<wreport::Var>)> dest) override;
44 void write_attrs(Tracer<>& trc, int id_data, const Values& values) override;
45 void remove_all_attrs(Tracer<>& trc, int id_data) override;
46 void remove(Tracer<>& trc, const v7::IdQueryBuilder& qb) override;
47 void remove_by_id(Tracer<>& trc, int id) override;
48};
49
50extern template class SQLiteDataCommon<StationData>;
51extern template class SQLiteDataCommon<Data>;
52
57{
58public:
59 using SQLiteDataCommon::SQLiteDataCommon;
60
62
63 void query(Tracer<>& trc, int id_station, std::function<void(int id, wreport::Varcode code)> dest) override;
64 void insert(Tracer<>& trc, int id_station, std::vector<batch::StationDatum>& vars, bool with_attrs) override;
65 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)>) override;
66 void dump(FILE* out) override;
67 void clear_cache() override {}
68};
69
74{
75public:
76 using SQLiteDataCommon::SQLiteDataCommon;
77
79
80 void query(Tracer<>& trc, int id_station, const Datetime& datetime, std::function<void(int id, int id_levtr, wreport::Varcode code)> dest) override;
81 void insert(Tracer<>& trc, int id_station, const Datetime& datetime, std::vector<batch::MeasuredDatum>& vars, bool with_attrs) override;
82 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)>) override;
83 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)>) override;
84 void dump(FILE* out) override;
85 void clear_cache() override {}
86};
87
88}
89}
90}
91}
92#endif
Smart pointer for trace::Step objects, which calls done() when going out of scope.
Definition: db/v7/fwd.h:46
Definition: db/v7/sqlite/data.h:17
dballe::sql::SQLiteStatement * istm
Precompiled insert statement.
Definition: db/v7/sqlite/data.h:31
dballe::sql::SQLiteStatement * remove_attrs_stm
Precompiled remove attributes statement.
Definition: db/v7/sqlite/data.h:27
dballe::sql::SQLiteStatement * sstm
Precompiled select statement.
Definition: db/v7/sqlite/data.h:29
dballe::sql::SQLiteStatement * read_attrs_stm
Precompiled read attributes statement.
Definition: db/v7/sqlite/data.h:23
dballe::sql::SQLiteStatement * write_attrs_stm
Precompiled write attributes statement.
Definition: db/v7/sqlite/data.h:25
dballe::sql::SQLiteStatement * ustm
Precompiled update statement.
Definition: db/v7/sqlite/data.h:33
dballe::sql::SQLiteConnection & conn
DB connection.
Definition: db/v7/sqlite/data.h:20
Precompiled query to manipulate the data table.
Definition: db/v7/sqlite/data.h:74
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)>) override
Run a data query, iterating on the resulting variables.
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)>) override
Run a summary query, iterating on the resulting variables.
void query(Tracer<> &trc, int id_station, const Datetime &datetime, std::function< void(int id, int id_levtr, wreport::Varcode code)> dest) override
Query contents of the data table.
void insert(Tracer<> &trc, int id_station, const Datetime &datetime, std::vector< batch::MeasuredDatum > &vars, bool with_attrs) override
Bulk variable insert.
void dump(FILE *out) override
Dump the entire contents of the table to an output stream.
Precompiled query to manipulate the station data table.
Definition: db/v7/sqlite/data.h:57
void dump(FILE *out) override
Dump the entire contents of the table to an output stream.
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)>) override
Run a station data query, iterating on the resulting variables.
void insert(Tracer<> &trc, int id_station, std::vector< batch::StationDatum > &vars, bool with_attrs) override
Bulk variable insert.
void query(Tracer<> &trc, int id_station, std::function< void(int id, wreport::Varcode code)> dest) override
Query contents of the data table.
Database connection.
Definition: sqlite.h:35
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: qbuilder.h:92
Definition: qbuilder.h:116
Definition: qbuilder.h:125
Definition: transaction.h:16
SQLite statement.
Definition: sqlite.h:116