libdballe  9.11
db/tests.h
1 #include <dballe/msg/tests.h>
2 #include <dballe/values.h>
3 #include <dballe/core/data.h>
4 #include <dballe/db/fwd.h>
5 #include <dballe/db/v7/fwd.h>
6 #include <dballe/db/db.h>
7 #include <dballe/db/summary.h>
8 #include <dballe/sql/fwd.h>
9 #include <utility>
10 #include <functional>
11 
12 namespace dballe {
13 namespace tests {
14 
15 impl::Messages messages_from_db(std::shared_ptr<db::Transaction> tr, const dballe::Query& query);
16 impl::Messages messages_from_db(std::shared_ptr<db::Transaction> tr, const char* query);
17 
20 {
22  std::map<std::string, core::Data> stations;
24  std::map<std::string, core::Data> data;
25 
26  TestDataSet() {}
27  virtual ~TestDataSet() {}
28 
29  void populate_db(dballe::DB& db);
30  virtual void populate_transaction(Transaction& tr);
31 };
32 
34 {
35  void populate_db();
36 };
37 
40 {
42 };
43 
44 bool has_driver(const std::string& backend);
45 
46 struct V7DB
47 {
48  typedef db::v7::DB DB;
49  typedef db::v7::Transaction TR;
50  static const auto format = db::Format::V7;
51  static std::shared_ptr<DB> create_db(const std::string& backend, bool wipe);
52 };
53 
54 template<typename DB>
55 struct BaseDBFixture : public Fixture
56 {
57  std::string backend;
58  std::shared_ptr<typename DB::DB> db;
59  bool destroys_db = false;
60 
61  BaseDBFixture(const char* backend);
62  virtual ~BaseDBFixture();
63 
64  void test_setup();
65  void test_teardown();
66  virtual void create_db();
67  bool has_driver();
68 };
69 
70 template<typename DB>
72 {
74  std::shared_ptr<typename DB::TR> tr;
75 
76  void test_setup();
77  void test_teardown();
78  void populate(TestDataSet& data_set);
79 };
80 
81 template<typename DB, typename TestData>
83 {
85 
86  TestData test_data;
87 
88  void create_db() override
89  {
91  wassert(test_data.populate_db(*this->db));
92  }
93 };
94 
95 template<typename DB>
96 struct DBFixture : public BaseDBFixture<DB>
97 {
99 
100  void test_setup();
101  void populate_database(TestDataSet& data_set);
102 };
103 
104 
105 struct ActualCursor : public Actual<std::shared_ptr<dballe::Cursor>>
106 {
107  using Actual::Actual;
108 
110  void station_keys_match(const DBStation& expected);
111 
113  void data_context_matches(const Data& expected);
114 
116  void data_var_matches(const Data& expected, wreport::Varcode code) {
117  data_var_matches(core::Data::downcast(expected).values.var(code));
118  }
120  void data_var_matches(const DBValues& expected) {
121  if (auto c = std::dynamic_pointer_cast<dballe::db::CursorStation>(_actual))
122  {
123  DBValues actual_values = c->get_values();
124  if (!actual_values.vars_equal(expected))
125  // Quick hack to get proper formatting of mismatch
126  wassert(actual(c->get_values()) == expected);
127  }
128  else if (auto c = std::dynamic_pointer_cast<dballe::CursorStationData>(_actual))
129  data_var_matches(expected.var(c->get_varcode()));
130  else if (auto c = std::dynamic_pointer_cast<dballe::CursorData>(_actual))
131  data_var_matches(expected.var(c->get_varcode()));
132  else
133  throw wreport::error_consistency("cannot call data_var_matches on this kind of cursor");
134  }
136  void data_var_matches(const Values& expected, wreport::Varcode code) {
137  data_var_matches(expected.var(code));
138  }
140  void data_var_matches(const wreport::Var& expected);
141 
143  void data_matches(const Data& ds)
144  {
145  if (auto c = std::dynamic_pointer_cast<dballe::CursorStationData>(_actual))
146  data_matches(ds, c->get_varcode());
147  else if (auto c = std::dynamic_pointer_cast<dballe::CursorData>(_actual))
148  data_matches(ds, c->get_varcode());
149  else
150  throw wreport::error_consistency("cannot call data_matches on this kind of cursor");
151  }
153  void data_matches(const Data& ds, wreport::Varcode code);
154 };
155 
156 typedef std::function<void(const db::DBSummary&)> result_checker;
157 
158 template<typename DB>
159 struct ActualDB : public Actual<std::shared_ptr<DB>>
160 {
162 
164  void try_data_query(const std::string& query, unsigned expected);
165 
167  void try_data_query(const Query& query, unsigned expected);
168 
170  void try_station_query(const std::string& query, unsigned expected);
171 
173  void try_summary_query(const std::string& query, unsigned expected, result_checker checker=nullptr);
174 };
175 
176 inline ActualCursor actual(std::shared_ptr<dballe::Cursor>& actual) { return ActualCursor(actual); }
177 inline ActualCursor actual(std::shared_ptr<dballe::CursorStation>& actual) { return ActualCursor(actual); }
178 inline ActualCursor actual(std::shared_ptr<dballe::CursorStationData>& actual) { return ActualCursor(actual); }
179 inline ActualCursor actual(std::shared_ptr<dballe::CursorData>& actual) { return ActualCursor(actual); }
180 inline ActualCursor actual(std::shared_ptr<dballe::CursorSummary>& actual) { return ActualCursor(actual); }
181 inline ActualDB<dballe::DB> actual(std::shared_ptr<dballe::DB> actual) { return ActualDB<dballe::DB>(actual); }
182 ActualDB<dballe::DB> actual(std::shared_ptr<dballe::db::v7::DB> actual);
183 inline ActualDB<dballe::db::Transaction> actual(std::shared_ptr<dballe::db::Transaction> actual) { return ActualDB<dballe::db::Transaction>(actual); }
184 ActualDB<dballe::db::Transaction> actual(std::shared_ptr<dballe::db::v7::Transaction> actual);
185 
186 extern template class BaseDBFixture<V7DB>;
187 extern template class DBFixture<V7DB>;
188 extern template class EmptyTransactionFixture<V7DB>;
189 extern template class ActualDB<dballe::DB>;
190 extern template class ActualDB<dballe::db::Transaction>;
191 
192 }
193 }
void try_station_query(const std::string &query, unsigned expected)
Check results of a station query.
Forward declarations for public dballe/sql names.
Definition: db.h:149
const wreport::Var & var(wreport::Varcode code) const
Lookup a wreport::Var, throwing an exception if not found.
void data_context_matches(const Data &expected)
Check cursor data context after a query_data.
Definition: db/tests.h:46
void data_var_matches(const DBValues &expected)
Check cursor data variable(s) after a query_data.
Definition: db/tests.h:120
void try_summary_query(const std::string &query, unsigned expected, result_checker checker=nullptr)
Check results of a summary query.
Functions used to connect to DB-All.e and insert, query and delete data.
static const Data & downcast(const dballe::Data &data)
Return a reference to record downcasted as core::Record.
void data_var_matches(const Data &expected, wreport::Varcode code)
Check cursor data variable after a query_data.
Definition: db/tests.h:116
Definition: cmdline.h:18
Collection of DBValue objects, indexed by wreport::Varcode.
Definition: values.h:191
bool vars_equal(const DBValues &o) const
Check if the variables are the same, regardless of the data_id.
Definition: db/tests.h:33
Definition: db/tests.h:96
void data_var_matches(const Values &expected, wreport::Varcode code)
Check cursor data variable after a query_data.
Definition: db/tests.h:136
uint16_t Varcode
Definition: db/tests.h:55
Key/value store where keys are strings and values are wreport variables.
Definition: data.h:17
Definition: transaction.h:15
void try_data_query(const std::string &query, unsigned expected)
Check cursor data context anda variable after a query_data.
Definition: db.h:296
Test fixture used by old DB-All.e db tests.
Definition: db/tests.h:39
std::map< std::string, core::Data > data
Arbitrarily named data values.
Definition: db/tests.h:24
DB-ALLe database connection for database format V7.
Definition: db/v7/db.h:20
void data_matches(const Data &ds)
Check cursor data context and variable after a query_data.
Definition: db/tests.h:143
std::map< std::string, core::Data > stations
Arbitrarily named station values.
Definition: db/tests.h:22
Definition: db/tests.h:82
Definition: types.h:850
Definition: db/tests.h:159
Structures used as input to database insert functions.
Query used to filter DB-All.e data.
Definition: query.h:14
Base for datasets used to populate test databases.
Definition: db/tests.h:19
Collection of Value objects, indexed by wreport::Varcode.
Definition: values.h:176
Definition: db/tests.h:105
void station_keys_match(const DBStation &expected)
Check cursor context after a query_stations.