libdballe  9.11
transaction.h
1 #ifndef DBALLE_DB_V7_TRANSACTION_H
2 #define DBALLE_DB_V7_TRANSACTION_H
3 
4 #include <dballe/db/db.h>
5 #include <dballe/db/v7/fwd.h>
6 #include <dballe/db/v7/data.h>
7 #include <dballe/db/v7/batch.h>
8 #include <dballe/sql/fwd.h>
9 #include <memory>
10 
11 namespace dballe {
12 namespace db {
13 namespace v7 {
14 
16 {
17 protected:
19  v7::Repinfo* m_repinfo = nullptr;
21  v7::Station* m_station = nullptr;
23  v7::LevTr* m_levtr = nullptr;
27  v7::Data* m_data = nullptr;
28 
30  std::vector<std::weak_ptr<dballe::Cursor>> tracked_cursors;
31 
32  void add_msg_to_batch(Tracer<>& trc, const Message& message, const dballe::DBImportOptions& opts);
33  void track_cursor(std::weak_ptr<dballe::Cursor> cursor);
34 
35 public:
36  typedef v7::DB DB;
37 
38  std::shared_ptr<v7::DB> db;
40  std::shared_ptr<dballe::sql::Transaction> sql_transaction;
42  bool fired = false;
47 
48  Transaction(std::shared_ptr<v7::DB> db, std::unique_ptr<dballe::sql::Transaction> sql_transaction);
49  Transaction(const Transaction&) = delete;
50  Transaction(Transaction&&) = delete;
51  Transaction& operator=(const Transaction&) = delete;
52  Transaction& operator=(Transaction&&) = delete;
53  ~Transaction();
54 
60  v7::LevTr& levtr();
64  v7::Data& data();
65 
66  void commit() override;
67  void rollback() override;
68  void rollback_nothrow() noexcept override;
69  void clear_cached_state() override;
70 
71  std::shared_ptr<dballe::CursorStation> query_stations(const Query& query) override;
72  std::shared_ptr<dballe::CursorStationData> query_station_data(const Query& query) override;
73  std::shared_ptr<dballe::CursorData> query_data(const Query& query) override;
74  std::shared_ptr<dballe::CursorSummary> query_summary(const Query& query) override;
75  std::shared_ptr<dballe::CursorMessage> query_messages(const Query& query) override;
76  void attr_query_station(int data_id, std::function<void(std::unique_ptr<wreport::Var>)> dest) override;
77  void attr_query_data(int data_id, std::function<void(std::unique_ptr<wreport::Var>)> dest) override;
78 
79  void insert_station_data(dballe::Data& vals, const dballe::DBInsertOptions& opts=dballe::DBInsertOptions::defaults) override;
80  void insert_data(dballe::Data& vals, const dballe::DBInsertOptions& opts=dballe::DBInsertOptions::defaults) override;
81  void remove_station_data(const Query& query) override;
82  void remove_data(const Query& query) override;
83  void remove_station_data_by_id(int id);
84  void remove_data_by_id(int id);
85  void remove_all() override;
86 
87  void attr_insert_station(int data_id, const Values& attrs) override;
88  void attr_insert_data(int data_id, const Values& attrs) override;
89  void attr_remove_station(int data_id, const db::AttrList& attrs) override;
90  void attr_remove_data(int data_id, const db::AttrList& attrs) override;
91  void import_message(const Message& message, const dballe::DBImportOptions& opts) override;
92  void import_messages(const std::vector<std::shared_ptr<Message>>& msgs, const dballe::DBImportOptions& opts) override;
93  void update_repinfo(const char* repinfo_file, int* added, int* deleted, int* updated) override;
94 
95  static Transaction& downcast(dballe::db::Transaction& transaction);
96 
97  void dump(FILE* out) override;
98 };
99 
101 {
102  using Transaction::Transaction;
103 
104  void commit() override;
105 };
106 
107 }
108 }
109 }
110 #endif
Forward declarations for public dballe/sql names.
v7::Repinfo * m_repinfo
Report information.
Definition: transaction.h:19
void attr_remove_data(int data_id, const db::AttrList &attrs) override
Delete attributes from a data value.
Options controlling how messages are imported in the database.
Definition: db.h:64
Definition: db/db.h:137
void commit() override
Commit this transaction.
void attr_query_data(int data_id, std::function< void(std::unique_ptr< wreport::Var >)> dest) override
Query attributes on a data value.
v7::Tracer< v7::trace::Transaction > trc
Tracing system.
Definition: transaction.h:46
void import_message(const Message &message, const dballe::DBImportOptions &opts) override
Import a Message into the DB-All.e database.
Definition: db/db.h:71
std::shared_ptr< dballe::CursorData > query_data(const Query &query) override
Query the database.
v7::Station & station()
Access the station table.
void insert_station_data(dballe::Data &vals, const dballe::DBInsertOptions &opts=dballe::DBInsertOptions::defaults) override
Insert station values into the database.
void dump(FILE *out) override
Dump the entire contents of the database to an output stream.
v7::Repinfo & repinfo()
Access the repinfo table.
Definition: utils.h:31
std::shared_ptr< dballe::CursorStationData > query_station_data(const Query &query) override
Query the station variables in the database.
void clear_cached_state() override
Clear state information cached during the transaction.
Functions used to connect to DB-All.e and insert, query and delete data.
void attr_insert_station(int data_id, const Values &attrs) override
Insert new attributes on a station value.
Fast cached access to the repinfo table.
Definition: repinfo.h:71
Definition: cmdline.h:18
Definition: station.h:24
void import_messages(const std::vector< std::shared_ptr< Message >> &msgs, const dballe::DBImportOptions &opts) override
Import Messages into the DB-All.e database.
v7::Station * m_station
Station information.
Definition: transaction.h:21
Cursor iterating over messages.
Definition: cursor.h:117
Options controlling how values are inserted in the database.
Definition: db.h:122
std::vector< std::weak_ptr< dballe::Cursor > > tracked_cursors
Track active cursors to invalidate them on commit/rollback.
Definition: transaction.h:30
v7::StationData * m_station_data
Station data.
Definition: transaction.h:25
Definition: db/db.h:58
Definition: db/db.h:104
bool fired
True if commit or rollback have already been called on this transaction.
Definition: transaction.h:42
std::shared_ptr< dballe::sql::Transaction > sql_transaction
SQL-side transaction.
Definition: transaction.h:40
A bulletin that has been decoded and physically interpreted.
Definition: message.h:28
void attr_insert_data(int data_id, const Values &attrs) override
Insert new attributes on a data value.
Definition: transaction.h:15
void remove_all() override
Remove all data from the database.
Definition: db/db.h:151
v7::StationData & station_data()
Access the station_data table.
void rollback() override
Roll back this transaction.
v7::Data & data()
Access the data table.
std::shared_ptr< dballe::CursorSummary > query_summary(const Query &query) override
Query a summary of what the result would be for a query.
Definition: transaction.h:100
v7::Data * m_data
Variable data.
Definition: transaction.h:27
Precompiled queries to manipulate the lev_tr table.
Definition: levtr.h:20
std::shared_ptr< dballe::CursorMessage > query_messages(const Query &query) override
Query the database returning the matching data as Message objects.
Smart pointer for trace::Step objects, which calls done() when going out of scope.
Definition: db/v7/fwd.h:45
void remove_station_data(const Query &query) override
Remove data from the database.
Definition: db/v7/data.h:139
v7::LevTr * m_levtr
Level/timerange information.
Definition: transaction.h:23
DB-ALLe database connection for database format V7.
Definition: db/v7/db.h:20
Definition: batch.h:18
void insert_data(dballe::Data &vals, const dballe::DBInsertOptions &opts=dballe::DBInsertOptions::defaults) override
Insert data values into the database.
void attr_query_station(int data_id, std::function< void(std::unique_ptr< wreport::Var >)> dest) override
Query attributes on a station value.
void update_repinfo(const char *repinfo_file, int *added, int *deleted, int *updated) override
Update the repinfo table in the database, with the data found in the given file.
void remove_data(const Query &query) override
Remove data from the database.
std::shared_ptr< dballe::CursorStation > query_stations(const Query &query) override
Start a query on the station variables archive.
void attr_remove_station(int data_id, const db::AttrList &attrs) override
Delete attributes from a station value.
Query used to filter DB-All.e data.
Definition: query.h:14
void rollback_nothrow() noexcept override
Roll back this transaction.
v7::Batch batch
Batch importer.
Definition: transaction.h:44
Collection of Value objects, indexed by wreport::Varcode.
Definition: values.h:176
v7::LevTr & levtr()
Access the levtr table.
Definition: db/v7/data.h:155