dbe::config::api::rwdacc Class Reference

#include <config_direct_access.hpp>

Static Private Member Functions
static std::vector< dunedaq::conffwk::ConfigObject >	query_class (std::string const &classname, std::string const &query)
static dunedaq::conffwk::ConfigObject	create_object (std::string const &fn, std::string const &cn, std::string const &name)
static dunedaq::conffwk::ConfigObject	get_object (std::string const &, std::string const &)
static tref	set_object (tref newobj, dbe::t_config_object_preimage::type_attrmap const &attributes, dbe::t_config_object_preimage::type_relmap const &relations)
static void	rename_object (dunedaq::conffwk::ConfigObject &object, std::string const &newname)
static void	destroy_object (dunedaq::conffwk::ConfigObject &)

Friends
class	inner::dbcontroller

Detailed Description

Direct access to Config layer through ConfigObjects

Definition at line 32 of file config_direct_access.hpp.

Member Function Documentation

create_object()

ConfigObject dbe::config::api::rwdacc::create_object ( std::string const & fn, std::string const & cn, std::string const & name )

staticprivate

Creates the object in the database ( changes are not committed)

Parameters

fn	is the file where the object is to be created in
cn	is the name of the class that the object belongs to
name	is the UID that should be given to the object
attributes	are the attributes of the object to be created
relations	are the relations for the object

Returns

a copy of the thin wrapper ConfigObject

Definition at line 45 of file rwdacc.cpp.

{
  if (info::onclass::definition(cn, false).p_abstract) {
    ERROR("Create Object: Was not possible to create object ",
          "Abstract classes cannot hold objects",
          uid,
          "for abstract class",
          cn);
 
    throw daq::dbe::ObjectChangeWasNotSuccessful(ERS_HERE);
  }
 
  // An empty object, if its creation does not succeed this object will be returned
  ConfigObject newobj;
 
  try {
    dbaccessor::dbptr()->create(fn, cn, uid, newobj);
  } catch (dunedaq::conffwk::Exception const& ex) {
    FAIL("Object creation failed", dbe::config::errors::parse(ex), "\n\nObject UID:", uid);
 
    throw daq::dbe::ObjectChangeWasNotSuccessful(ERS_HERE);
  }
 
  return newobj;
}

destroy_object()

void dbe::config::api::rwdacc::destroy_object ( dunedaq::conffwk::ConfigObject & todelete )

staticprivate

Destroys the object in the online database ( changes are not committed)

Parameters

the	object definition to create in the database

Definition at line 285 of file rwdacc.cpp.

{
  try {
    dbaccessor::dbptr()->destroy_obj(todelete);
  } catch (dunedaq::conffwk::Exception const& ex) {
    WARN("Object deletion did not succeed for object", errors::parse(ex).c_str(), todelete.UID().c_str());
 
    throw daq::dbe::ObjectChangeWasNotSuccessful(ERS_HERE);
  }
}

get_object()

ConfigObject dbe::config::api::rwdacc::get_object ( std::string const & classname, std::string const & objectname )

staticprivate

Retrieve an object by class name and uid

Parameters

class	name
object	uid

Returns

a config object that is not null only if it exists in the database

Definition at line 299 of file rwdacc.cpp.

{
  if (dbaccessor::is_loaded()) {
    try {
      ConfigObject object;
      dbaccessor::dbptr()->get(classname, objectname, object);
      return object;
    } catch (dunedaq::conffwk::NotFound const& e) {
      TLOG_DEBUG(3) << "Object not found";
    } catch (dunedaq::conffwk::Generic const& e) {
      ERROR("Generic exception caught", dbe::config::errors::parse(e).c_str());
      TLOG_DEBUG(3) << "Generic Exception Caught";
    } catch (...) {
      ERROR("Unknown exception caught", "");
      TLOG_DEBUG(3) << "Unknown exception caught!";
    }
  }
  return {};
}

query_class()

std::vector< ConfigObject > dbe::config::api::rwdacc::query_class ( std::string const & classname, std::string const & query )

staticprivate

Retrieve objects of class matching a query string (regex)

Parameters

classname	is the class to query for
query	is a regular expression to match against the objects in the given class

Returns

a list of configobjects

Definition at line 322 of file rwdacc.cpp.

{
  std::vector<ConfigObject> objects;
  if (dbaccessor::is_loaded()) {
    try {
      dbaccessor::dbptr()->get(classname, objects, query);
    } catch (dunedaq::conffwk::NotFound const& e) {
      TLOG_DEBUG(3) << "Object not found";
    } catch (dunedaq::conffwk::Generic const& e) {
      ERROR("Generic exception caught", dbe::config::errors::parse(e).c_str());
      TLOG_DEBUG(3) << "Generic Exception Caught";
    } catch (...) {
      ERROR("Unknown exception caught", "");
      TLOG_DEBUG(3) << "Unknown exception caught!";
    }
  }
  return objects;
}

rename_object()

void dbe::config::api::rwdacc::rename_object ( dunedaq::conffwk::ConfigObject & object, std::string const & newname )

staticprivate

Rename an object in the database

Parameters

object	reference to rename
newname	as a string

Returns

a reference with the object

Definition at line 344 of file rwdacc.cpp.

{
  object.rename(newname);
}

set_object()

tref dbe::config::api::rwdacc::set_object ( tref newobj, dbe::t_config_object_preimage::type_attrmap const & attributes, dbe::t_config_object_preimage::type_relmap const & relations )

staticprivate

Given a reference to an object set its attributes and relations

Parameters

newobj	to set
attributes	to set in the object
relations	to set in the object

Returns

an empty tref in case of failure

Definition at line 83 of file rwdacc.cpp.

{
  auto relreader = [&relations](std::string const& name) { return relations.at(name); };
 
  auto attreader = [&attributes](std::string const& name) { return attributes.at(name); };
 
  if (not newobj.is_null()) {
    dunedaq::conffwk::class_t ClassInfo = dbe::config::api::info::onclass::definition(newobj.class_name(), false);
    std::vector<dunedaq::conffwk::attribute_t> AttList = ClassInfo.p_attributes;
    std::vector<dunedaq::conffwk::relationship_t> RelList = ClassInfo.p_relationships;
 
    for (dunedaq::conffwk::attribute_t const& att : AttList) {
      try {
        if (att.p_is_multi_value) {
          switch (att.p_type) {
            case dunedaq::conffwk::bool_type: {
              auto data = dbe::convert::to<std::vector<bool>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                              att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::enum_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::anenum(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::date_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::adate(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::time_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::atime(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::string_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::class_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::aclass(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::float_type: {
              auto data = dbe::convert::to<std::vector<float>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                               att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::double_type: {
              auto data = dbe::convert::to<std::vector<double>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s8_type: {
              auto data = dbe::convert::to<std::vector<int8_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s16_type: {
              auto data = dbe::convert::to<std::vector<int16_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                 att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s32_type: {
              auto data = dbe::convert::to<std::vector<int32_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                 att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s64_type: {
              auto data = dbe::convert::to<std::vector<int64_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                 att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u8_type: {
              auto data = dbe::convert::to<std::vector<u_int8_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                  att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u16_type: {
              auto data = dbe::convert::to<std::vector<u_int16_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                   att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u32_type: {
              auto data = dbe::convert::to<std::vector<u_int32_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                   att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u64_type: {
              auto data = dbe::convert::to<std::vector<u_int64_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                   att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            default:
              break;
          }
        } else {
          switch (att.p_type) {
            case dunedaq::conffwk::bool_type: {
              auto data =
                dbe::convert::to<bool>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::enum_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::anenum(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::date_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::adate(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::time_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::atime(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::string_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::class_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::aclass(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::float_type: {
              auto data =
                dbe::convert::to<float>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::double_type: {
              auto data =
                dbe::convert::to<double>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s8_type: {
              auto data =
                dbe::convert::to<int8_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s16_type: {
              auto data =
                dbe::convert::to<int16_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s32_type: {
              auto data =
                dbe::convert::to<int32_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s64_type: {
              auto data =
                dbe::convert::to<int64_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u8_type: {
              auto data =
                dbe::convert::to<u_int8_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u16_type: {
              auto data =
                dbe::convert::to<u_int16_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u32_type: {
              auto data =
                dbe::convert::to<u_int32_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u64_type: {
              auto data =
                dbe::convert::to<u_int64_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            default:
              break;
          }
        }
      } catch (std::out_of_range const& e) {
        // nothing to do just ignore this , it might be the case that the attribute was not defined
      }
    }
 
    for (dunedaq::conffwk::relationship_t const& rel : RelList) {
      try {
        auto data = relreader(rel.p_name);
        set::noactions::relation(newobj, rel, data);
      } catch (std::out_of_range const& e) {
        // nothing to do just ignore this , it might be the case that the relation was not defined
      }
    }
  }
 
  return newobj;
}

Friends And Related Symbol Documentation

inner::dbcontroller

friend class inner::dbcontroller

friend

Definition at line 96 of file config_direct_access.hpp.

---

The documentation for this class was generated from the following files:

• /github/workspace/dunedaq/sourcecode/dbe/include/dbe/config_direct_access.hpp
• /github/workspace/dunedaq/sourcecode/dbe/src/internal/rwdacc.cpp