5 #include <dballe/db/trace.h> 47 bool explain_queries =
false;
74 void init_after_connect();
76 DB(std::unique_ptr<dballe::sql::Connection> conn);
97 db::Format
format()
const {
return V6; }
120 std::unique_ptr<dballe::Transaction> transaction()
override;
135 void reset(
const char* repinfo_file = 0);
140 void delete_tables();
159 void update_repinfo(
const char* repinfo_file,
int* added,
int* deleted,
int* updated);
161 std::map<std::string, int> get_repinfo_priorities();
166 int rep_cod_from_memo(
const char* memo);
186 std::unique_ptr<db::CursorStation> query_stations(
const Query& query);
187 std::unique_ptr<db::CursorStationData> query_station_data(
const Query& query)
override;
188 std::unique_ptr<db::CursorData> query_data(
const Query& query);
189 std::unique_ptr<db::CursorSummary> query_summary(
const Query& query);
191 void attr_query_station(
int data_id, std::function<
void(std::unique_ptr<wreport::Var>)>&& dest)
override;
192 void attr_query_data(
int data_id, std::function<
void(std::unique_ptr<wreport::Var>)>&& dest)
override;
195 void attr_remove_station(
dballe::Transaction& transaction,
int data_id,
const db::AttrList& qcs)
override;
196 void attr_remove_data(
dballe::Transaction& transaction,
int data_id,
const db::AttrList& qcs)
override;
200 bool export_msgs(
dballe::Transaction& transaction,
const Query& query, std::function<
bool(std::unique_ptr<Message>&&)> dest)
override;
205 void dump(FILE* out);
struct v6::DataV6 * m_data
Variable data.
Definition: v6/db.h:69
A RAII transaction interface.
Definition: transaction.h:15
Information about a station.
Definition: values.h:20
struct v6::LevTrCache * m_lev_tr_cache
Level/timerange cache.
Definition: v6/db.h:67
Definition: db/trace.h:39
Trace trace
Database query tracing.
Definition: v6/db.h:45
v6::Driver * m_driver
SQL driver backend.
Definition: v6/db.h:51
A set of measured values.
Definition: values.h:303
A bulletin that has been decoded and physically interpreted.
Definition: message.h:28
db::Format format() const
Return the format of this DB.
Definition: v6/db.h:97
Copyright (C) 2008–2010 ARPA-SIM urpsim@smr.arpa.emr.it
Definition: cmdline.h:17
Definition: v6/driver.h:52
struct v6::AttrV6 * m_attr
Variable attributes.
Definition: v6/db.h:71
dballe::sql::Connection * conn
Database connection.
Definition: v6/db.h:43
Definition: v6/levtr.h:62
Functions used to connect to DB-All.e and insert, query and delete data.
struct v6::Repinfo * m_repinfo
Accessors for the various parts of the database.
Definition: v6/db.h:61
Precompiled queries to manipulate the lev_tr table.
Definition: v6/levtr.h:22
Query used to filter DB-All.e data.
Definition: query.h:14
struct v6::Station * m_station
Station information.
Definition: v6/db.h:63
A set of station values.
Definition: values.h:273
DB-ALLe database connection, database format V6.
Definition: v6/db.h:39
Fast cached access to the repinfo table.
Definition: v6/repinfo.h:76
Precompiled queries to manipulate the attr table.
Definition: attrv6.h:26
Definition: v6/station.h:18
Collection of Value objects, indexed by wreport::Varcode.
Definition: values.h:202
Precompiled query to manipulate the data table.
Definition: datav6.h:31
struct v6::LevTr * m_lev_tr
Level/timerange information.
Definition: v6/db.h:65