DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
rwdacc.cpp
Go to the documentation of this file.
1/************************************************************
2 * rwdacc.cpp
3 *
4 * Created on: Feb 4, 2016
5 * Author: Leonidas Georgopoulos
6 ************************************************************/
7#include "dbe/dbaccessor.hpp"
8#include "dbe/config_direct_access.hpp"
9#include "dbe/confobject_desc.hpp"
10#include "dbe/Exceptions.hpp"
11#include "dbe/messenger.hpp"
12#include "dbe/config_api_set.hpp"
13#include "dbe/Conversion.hpp"
14
15#include "conffwk/ConfigObject.hpp"
16#include "conffwk/Configuration.hpp"
17#include "conffwk/Errors.hpp"
18#include "conffwk/Schema.hpp"
19#include "ers/LocalContext.hpp"
20#include "logging/Logging.hpp"
21
22#include <QString>
23#include <QStringList>
24
25#include <functional>
26#include <map>
27#include <stdexcept>
28#include <string>
29#include <vector>
30
31using namespace dunedaq::conffwk;
32
33namespace dbe
34{
35
36namespace config
37{
38
39namespace api
40{
41//------------------------------------------------------------------------------------------
42ConfigObject rwdacc::create_object(std::string const & fn, std::string const & cn,
43 std::string const & uid)
44{
45 if (info::onclass::definition(cn, false).p_abstract)
46 {
47 ERROR("Create Object: Was not possible to create object ",
48 "Abstract classes cannot hold objects", uid, "for abstract class" , cn);
49
50 throw daq::dbe::ObjectChangeWasNotSuccessful(ERS_HERE);
51 }
52
53 // An empty object, if its creation does not succeed this object will be returned
54 ConfigObject newobj;
55
56 try
57 {
58 dbaccessor::dbptr()->create(fn, cn, uid,newobj);
59 }
60 catch (dunedaq::conffwk::Exception const & ex)
61 {
62 FAIL ( "Object creation failed", dbe::config::errors::parse ( ex ), "\n\nObject UID:",
63 uid );
64
65 throw daq::dbe::ObjectChangeWasNotSuccessful(ERS_HERE);
66 }
67
68 return newobj;
69
70}
71//------------------------------------------------------------------------------------------
72
73//------------------------------------------------------------------------------------------
78template<typename RESTYPE, typename KEYTYPE = std::string>
79using mapreader = std::function< RESTYPE (KEYTYPE const &) >;
80//------------------------------------------------------------------------------------------
81
82//------------------------------------------------------------------------------------------
83tref rwdacc::set_object(tref newobj,
84 dbe::t_config_object_preimage::type_attrmap const & attributes,
85 dbe::t_config_object_preimage::type_relmap const & relations)
86{
87 auto relreader = [&relations ]( std::string const & name )
88 {
89 return relations.at(name);
90 };
91
92 auto attreader = [ & attributes ] ( std::string const & name )
93 {
94 return attributes.at(name);
95 };
96
97 if (not newobj.is_null())
98 {
99 dunedaq::conffwk::class_t ClassInfo = dbe::config::api::info::onclass::definition(
100 newobj.class_name(),
101 false);
102 std::vector<dunedaq::conffwk::attribute_t> AttList = ClassInfo.p_attributes;
103 std::vector<dunedaq::conffwk::relationship_t> RelList = ClassInfo.p_relationships;
104
105 for (dunedaq::conffwk::attribute_t const & att : AttList)
106 {
107 try
108 {
109 if(att.p_is_multi_value) {
110 switch(att.p_type) {
111 case dunedaq::conffwk::bool_type:
112 {
113 auto data = dbe::convert::to<std::vector<bool>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
114 set::noactions::attribute(newobj, att, data, true);
115 }
116 break;
117 case dunedaq::conffwk::enum_type:
118 {
119 auto data = dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
120 set::noactions::anenum(newobj, att, data, true);
121 }
122 break;
123 case dunedaq::conffwk::date_type:
124 {
125 auto data = dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
126 set::noactions::adate(newobj, att, data, true);
127 }
128 break;
129 case dunedaq::conffwk::time_type:
130 {
131 auto data = dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
132 set::noactions::atime(newobj, att, data, true);
133 }
134 break;
135 case dunedaq::conffwk::string_type:
136 {
137 auto data = dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
138 set::noactions::attribute(newobj, att, data, true);
139 }
140 break;
141 case dunedaq::conffwk::class_type:
142 {
143 auto data = dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
144 set::noactions::aclass(newobj, att, data, true);
145 }
146 break;
147 case dunedaq::conffwk::float_type:
148 {
149 auto data = dbe::convert::to<std::vector<float>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
150 set::noactions::attribute(newobj, att, data, true);
151 }
152 break;
153 case dunedaq::conffwk::double_type:
154 {
155 auto data = dbe::convert::to<std::vector<double>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
156 set::noactions::attribute(newobj, att, data, true);
157 }
158 break;
159 case dunedaq::conffwk::s8_type:
160 {
161 auto data = dbe::convert::to<std::vector<int8_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
162 set::noactions::attribute(newobj, att, data, true);
163 }
164 break;
165 case dunedaq::conffwk::s16_type:
166 {
167 auto data = dbe::convert::to<std::vector<int16_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
168 set::noactions::attribute(newobj, att, data, true);
169 }
170 break;
171 case dunedaq::conffwk::s32_type:
172 {
173 auto data = dbe::convert::to<std::vector<int32_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
174 set::noactions::attribute(newobj, att, data, true);
175 }
176 break;
177 case dunedaq::conffwk::s64_type:
178 {
179 auto data = dbe::convert::to<std::vector<int64_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
180 set::noactions::attribute(newobj, att, data, true);
181 }
182 break;
183 case dunedaq::conffwk::u8_type:
184 {
185 auto data = dbe::convert::to<std::vector<u_int8_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
186 set::noactions::attribute(newobj, att, data, true);
187 }
188 break;
189 case dunedaq::conffwk::u16_type:
190 {
191 auto data = dbe::convert::to<std::vector<u_int16_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
192 set::noactions::attribute(newobj, att, data, true);
193 }
194 break;
195 case dunedaq::conffwk::u32_type:
196 {
197 auto data = dbe::convert::to<std::vector<u_int32_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
198 set::noactions::attribute(newobj, att, data, true);
199 }
200 break;
201 case dunedaq::conffwk::u64_type:
202 {
203 auto data = dbe::convert::to<std::vector<u_int64_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
204 set::noactions::attribute(newobj, att, data, true);
205 }
206 break;
207 default:
208 break;
209 }
210 } else {
211 switch(att.p_type) {
212 case dunedaq::conffwk::bool_type:
213 {
214 auto data = dbe::convert::to<bool>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
215 set::noactions::attribute(newobj, att, data, true);
216 }
217 break;
218 case dunedaq::conffwk::enum_type:
219 {
220 auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
221 set::noactions::anenum(newobj, att, data, true);
222 }
223 break;
224 case dunedaq::conffwk::date_type:
225 {
226 auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
227 set::noactions::adate(newobj, att, data, true);
228 }
229 break;
230 case dunedaq::conffwk::time_type:
231 {
232 auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
233 set::noactions::atime(newobj, att, data, true);
234 }
235 break;
236 case dunedaq::conffwk::string_type:
237 {
238 auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
239 set::noactions::attribute(newobj, att, data, true);
240 }
241 break;
242 case dunedaq::conffwk::class_type:
243 {
244 auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
245 set::noactions::aclass(newobj, att, data, true);
246 }
247 break;
248 case dunedaq::conffwk::float_type:
249 {
250 auto data = dbe::convert::to<float>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
251 set::noactions::attribute(newobj, att, data, true);
252 }
253 break;
254 case dunedaq::conffwk::double_type:
255 {
256 auto data = dbe::convert::to<double>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
257 set::noactions::attribute(newobj, att, data, true);
258 }
259 break;
260 case dunedaq::conffwk::s8_type:
261 {
262 auto data = dbe::convert::to<int8_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
263 set::noactions::attribute(newobj, att, data, true);
264 }
265 break;
266 case dunedaq::conffwk::s16_type:
267 {
268 auto data = dbe::convert::to<int16_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
269 set::noactions::attribute(newobj, att, data, true);
270 }
271 break;
272 case dunedaq::conffwk::s32_type:
273 {
274 auto data = dbe::convert::to<int32_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
275 set::noactions::attribute(newobj, att, data, true);
276 }
277 break;
278 case dunedaq::conffwk::s64_type:
279 {
280 auto data = dbe::convert::to<int64_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
281 set::noactions::attribute(newobj, att, data, true);
282 }
283 break;
284 case dunedaq::conffwk::u8_type:
285 {
286 auto data = dbe::convert::to<u_int8_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
287 set::noactions::attribute(newobj, att, data, true);
288 }
289 break;
290 case dunedaq::conffwk::u16_type:
291 {
292 auto data = dbe::convert::to<u_int16_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
293 set::noactions::attribute(newobj, att, data, true);
294 }
295 break;
296 case dunedaq::conffwk::u32_type:
297 {
298 auto data = dbe::convert::to<u_int32_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
299 set::noactions::attribute(newobj, att, data, true);
300 }
301 break;
302 case dunedaq::conffwk::u64_type:
303 {
304 auto data = dbe::convert::to<u_int64_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
305 set::noactions::attribute(newobj, att, data, true);
306 }
307 break;
308 default:
309 break;
310 }
311 }
312 }
313 catch (std::out_of_range const & e)
314 {
315 // nothing to do just ignore this , it might be the case that the attribute was not defined
316 }
317 }
318
319 for (dunedaq::conffwk::relationship_t const & rel : RelList)
320 {
321 try
322 {
323 auto data = relreader(rel.p_name);
324 set::noactions::relation(newobj, rel, data);
325 }
326 catch (std::out_of_range const & e)
327 {
328 // nothing to do just ignore this , it might be the case that the relation was not defined
329 }
330 }
331 }
332
333 return newobj;
334}
335//------------------------------------------------------------------------------------------
336
337//------------------------------------------------------------------------------------------
338void rwdacc::destroy_object(ConfigObject & todelete)
339{
340 try
341 {
342 dbaccessor::dbptr()->destroy_obj(todelete);
343 }
344 catch (dunedaq::conffwk::Exception const & ex)
345 {
346 WARN("Object deletion did not succeed for object" , errors::parse(ex).c_str(),
347 todelete.UID().c_str());
348
349 throw daq::dbe::ObjectChangeWasNotSuccessful(ERS_HERE);
350 }
351}
352//------------------------------------------------------------------------------------------
353
354//------------------------------------------------------------------------------------------
355ConfigObject rwdacc::get_object(std::string const & classname,
356 std::string const & objectname)
357{
358 if (dbaccessor::is_loaded())
359 {
360 try
361 {
362 ConfigObject object;
363 dbaccessor::dbptr()->get(classname, objectname, object);
364 return object;
365 }
366 catch (dunedaq::conffwk::NotFound const & e)
367 {
368 TLOG_DEBUG(3) << "Object not found" ;
369 }
370 catch (dunedaq::conffwk::Generic const & e)
371 {
372 ERROR("Generic exception caught", dbe::config::errors::parse(e).c_str());
373 TLOG_DEBUG(3) << "Generic Exception Caught" ;
374 }
375 catch (...)
376 {
377 ERROR("Unknown exception caught", "");
378 TLOG_DEBUG(3) << "Unknown exception caught!" ;
379 }
380 }
381 return
382 {};
383}
384//------------------------------------------------------------------------------------------
385
386//------------------------------------------------------------------------------------------
387std::vector<ConfigObject> rwdacc::query_class(std::string const & classname,
388 std::string const & query)
389{
390 std::vector<ConfigObject> objects;
391 if (dbaccessor::is_loaded())
392 {
393 try
394 {
395 dbaccessor::dbptr()->get(classname, objects, query);
396 }
397 catch (dunedaq::conffwk::NotFound const & e)
398 {
399 TLOG_DEBUG(3) << "Object not found" ;
400 }
401 catch (dunedaq::conffwk::Generic const & e)
402 {
403 ERROR("Generic exception caught", dbe::config::errors::parse(e).c_str());
404 TLOG_DEBUG(3) << "Generic Exception Caught" ;
405 }
406 catch (...)
407 {
408 ERROR("Unknown exception caught", "");
409 TLOG_DEBUG(3) << "Unknown exception caught!" ;
410 }
411 }
412 return objects;
413}
414//------------------------------------------------------------------------------------------
415
416//------------------------------------------------------------------------------------------
417void rwdacc::rename_object(ConfigObject & object, std::string const & newname)
418{
419object.rename(newname);
420}
421//------------------------------------------------------------------------------------------
422
423}// namespace api
424
425} // namespace config
426
427} // namespace dbe
ERS_HERE
#define ERS_HERE
Definition LocalContext.hpp:130
cptr::get
T * get()
Definition cptr.hpp:83
dbe::config::api::info::onclass::definition
static dunedaq::conffwk::class_t definition(std::string const &cn, bool direct_only)
Definition config_api_info.cpp:111
dbe::config::api::rwdacc::set_object
static tref set_object(tref newobj, dbe::t_config_object_preimage::type_attrmap const &attributes, dbe::t_config_object_preimage::type_relmap const &relations)
Definition rwdacc.cpp:83
dbe::config::api::rwdacc::destroy_object
static void destroy_object(dunedaq::conffwk::ConfigObject &)
Definition rwdacc.cpp:338
dbe::config::api::rwdacc::get_object
static dunedaq::conffwk::ConfigObject get_object(std::string const &, std::string const &)
Definition rwdacc.cpp:355
dbe::config::api::rwdacc::query_class
static std::vector< dunedaq::conffwk::ConfigObject > query_class(std::string const &classname, std::string const &query)
Definition rwdacc.cpp:387
dbe::config::api::rwdacc::create_object
static dunedaq::conffwk::ConfigObject create_object(std::string const &fn, std::string const &cn, std::string const &name)
Definition rwdacc.cpp:42
dbe::config::api::rwdacc::rename_object
static void rename_object(dunedaq::conffwk::ConfigObject &object, std::string const &newname)
Definition rwdacc.cpp:417
dbe::dbaccessor::dbptr
static cptr< dunedaq::conffwk::Configuration > dbptr()
Definition dbaccessor.cpp:18
dbe::dbaccessor::is_loaded
static bool is_loaded()
Definition dbaccessor.cpp:26
dunedaq::conffwk::ConfigObject
Represents database objects.
Definition ConfigObject.hpp:46
dunedaq::conffwk::ConfigObject::UID
const std::string & UID() const noexcept
Return object identity.
Definition ConfigObject.hpp:218
dunedaq::conffwk::ConfigObject::rename
void rename(const std::string &new_id)
Rename object.
Definition ConfigObject.cpp:87
Generic
Generic configuration exception.
NotFound
Try to access non-existent object or class.
Definition Errors.hpp:47
Configuration.hpp
conffwk entry point
config_api_set.hpp
config_direct_access.hpp
confobject_desc.hpp
TLOG_DEBUG
#define TLOG_DEBUG(lvl,...)
Definition Logging.hpp:112
ERROR
#define ERROR(...)
Definition messenger.hpp:88
WARN
#define WARN(...)
Definition messenger.hpp:80
FAIL
#define FAIL(...)
Definition messenger.hpp:128
dbe::config::api::mapreader
std::function< RESTYPE(KEYTYPE const &) > mapreader
Definition rwdacc.cpp:79
dbe::config::errors::parse
std::string const parse(ers::Issue const &)
Definition config_api.cpp:108
dbe::convert::to< int8_t >
int8_t to< int8_t >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:110
dbe::convert::to< u_int64_t >
u_int64_t to< u_int64_t >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:330
dbe::convert::to< int16_t >
int16_t to< int16_t >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:198
dbe::convert::to< u_int8_t >
u_int8_t to< u_int8_t >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:66
dbe::convert::to< int64_t >
int64_t to< int64_t >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:374
dbe::convert::to
T to(QStringList const &DataList)
Definition Conversion.hpp:111
dbe::convert::to< QStringList >
QStringList to< QStringList >(std::vector< std::string > const &x)
Definition Conversion.cpp:7
dbe::convert::to< std::string >
std::string to< std::string >(QStringList const &DataList)
Definition Conversion.cpp:18
dbe::convert::to< int32_t >
int32_t to< int32_t >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:286
dbe::convert::to< u_int32_t >
u_int32_t to< u_int32_t >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:242
dbe::convert::to< double >
double to< double >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:444
dbe::convert::to< u_int16_t >
u_int16_t to< u_int16_t >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:154
dbe::convert::to< float >
float to< float >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:418
dbe::convert::to< bool >
bool to< bool >(QStringList const &DataList, dunedaq::conffwk::int_format_t Format)
Definition Conversion.cpp:470
dbe
Include QT Headers.
Definition BatchChangeWidget.hpp:13
dbe::config_object_image::type_attrmap
M< type_str, type_attributes > type_attrmap
Definition confobject_desc.hpp:119
dbe::config_object_image::type_relmap
M< type_str, type_images > type_relmap
Definition confobject_desc.hpp:120
dunedaq::conffwk::attribute_t
Definition Schema.hpp:52
dunedaq::conffwk::class_t
Definition Schema.hpp:155
dunedaq::conffwk::class_t::p_attributes
const std::vector< attribute_t > p_attributes
Definition Schema.hpp:163
dunedaq::conffwk::class_t::p_relationships
const std::vector< relationship_t > p_relationships
Definition Schema.hpp:164
dunedaq::conffwk::relationship_t
Definition Schema.hpp:113
tablepositions::classname
@ classname
Generated on Sat Jun 28 2025 for DUNE-DAQ by doxygen 1.12.0