Belle II Software development
PyDBArray Class Reference

Class to access a DB Array from Python. More...

#include <PyDBArray.h>

Inheritance diagram for PyDBArray:
DBAccessorBase

Public Member Functions

 PyDBArray (const std::string &name, bool required=true)
 Construct the array from the name of the payload.
 
 PyDBArray (const TClass *objClass, bool required=true)
 Construct the array from the type of the payload, payload name will be the class name.
 
 PyDBArray (const std::string &name, const TClass *objClass, bool required=true)
 Construct the array from the name of the payload and make sure the class if compatible with objClass.
 
int getEntries () const
 Get the number of entries.
 
int __len__ () const
 Get the number of entries in a pythonic way to enable len(array)
 
const TObject * _get (int i) const
 Element access.
 
PyObject * getIntraRunBoundariesList () const
 Get the intra-run boundaries, if any, as a python list.
 
bool isValid () const
 Check whether a valid object was obtained from the database.
 
bool hasChanged ()
 Check whether the object has changed since the last call to hasChanged of the accessor).
 

Private Member Functions

const std::string & getName () const
 Return name under which the object is saved in the DBStore.
 
 operator bool () const
 Imitate pointer functionality.
 
virtual bool operator== (const DBAccessorBase &other) const
 Check if two store accessors point to the same object/array.
 
virtual bool operator!= (const DBAccessorBase &other) const
 Check if two store accessors point to a different object/array.
 
void addCallback (std::function< void(const std::string &)> callback, bool onDestruction=false)
 Add a callback method.
 
void addCallback (std::function< void()> callback, bool onDestruction=false)
 Add a callback method.
 
template<class T >
void addCallback (T *object, void(T::*callback)())
 Add a callback method of an object.
 
const std::string & getGlobaltag () const
 Return the globaltag name (or testing payloads path) this object is loaded from.
 
unsigned int getRevision () const
 Return current revision of the object.
 
IntervalOfValidity getIoV () const
 Return current IoV of the object.
 
const std::string & getChecksum () const
 Get current checksum.
 
const std::string & getFilename () const
 Get the filename this object is loaded from.
 
bool isIntraRunDependent () const
 Check wether this conditions object has some intra-run dependencies.
 
const std::vector< unsigned int > getIntraRunBoundaries () const
 Get the intra-run boundaries, if any.
 
bool isRequired () const
 Check whether this conditions object is required (at least one user declared it as required)
 
template<class T = TObject>
const T * getObject () const
 Return a pointer to the Object already cast to the correct type.
 
bool ensureAttached () const
 Make sure we are attached to the the DBStore.
 
void storeEntryChanged (bool destructed)
 Callback function which gets called by the DBStoreEntry object if it changes.
 

Private Attributes

const DBStoreEntry::EPayloadType m_type
 Type of the payload.
 
const std::string m_name
 Name of the payload in the database.
 
const TClass * m_objClass
 Class of the payload if type is c_Object.
 
const bool m_isArray
 True if the payload is an array of objects.
 
const bool m_isRequired
 True if the payload is required, otherwise no errors will be raised if it cannot be found.
 
DBStoreEntrym_entry
 Pointer to the entry in the DBStore.
 
bool m_changed {false}
 Internal flag whether the object has changed since we last checked.
 
std::vector< std::pair< std::function< void(const std::string &)>, bool > > m_callbacks
 List of all registered callback functions.
 

Detailed Description

Class to access a DB Array from Python.

In contrast to the C++ DBArray we don't have templates but python will handle the typing dynamically.

from ROOT import Belle2
bklmmapping = Belle2.PyDBArray('BKLMElectronicMapping')
# Alternative: simhits = Belle2.PyDBArray(Belle2.BKLMElectronicMapping.Class())
# Or with name and type: beamparams = Belle2.PyDBArray("BKLMElectronicMapping, Belle2.BKLMElectronicMapping.Class())
for mapping in bklmmapping:
print(mapping.getCopperId())
Class to access a DB Array from Python.
Definition: PyDBArray.h:43
Warning
Be aware that PyDBArray objects are only usable during event flow, that is in the initialize() or event() calls of a module as there is no Conditions data available otherwise.
See also
the object version PyDBObj as well as the interface classes to the DataStore, PyStoreArray and PyStoreObj

Definition at line 43 of file PyDBArray.h.

Constructor & Destructor Documentation

◆ PyDBArray() [1/3]

PyDBArray ( const std::string &  name,
bool  required = true 
)
explicit

Construct the array from the name of the payload.

Definition at line 44 of file PyDBArray.cc.

44: PyDBArray(name, getDefaultClass(name), required) {}

◆ PyDBArray() [2/3]

PyDBArray ( const TClass *  objClass,
bool  required = true 
)
explicit

Construct the array from the type of the payload, payload name will be the class name.

Definition at line 46 of file PyDBArray.cc.

46: PyDBArray(DataStore::defaultArrayName(objClass), objClass, required) {}
static std::string defaultArrayName()
Return the default storage name for an array of the given type.
Definition: DataStore.h:157

◆ PyDBArray() [3/3]

PyDBArray ( const std::string &  name,
const TClass *  objClass,
bool  required = true 
)
explicit

Construct the array from the name of the payload and make sure the class if compatible with objClass.

Definition at line 48 of file PyDBArray.cc.

48 : DBAccessorBase(name, objClass, true,
49 required) {}
Base class for DBObjPtr and DBArray for easier common treatment.

Member Function Documentation

◆ __len__()

int __len__ ( ) const
inline

Get the number of entries in a pythonic way to enable len(array)

Definition at line 61 of file PyDBArray.h.

61{ return getEntries(); }
int getEntries() const
Get the number of entries.
Definition: PyDBArray.cc:39

◆ _get()

const TObject * _get ( int  i) const

Element access.

Sadly the const in the return value is lost in python so this is a protected method and we add a pure python method to wrap the object in something to guarantee constness in framework/scripts/basf2.py

Definition at line 34 of file PyDBArray.cc.

35{
36 return getObject<TClonesArray>()->At(i);
37}

◆ addCallback() [1/3]

void addCallback ( std::function< void()>  callback,
bool  onDestruction = false 
)
inlineinherited

Add a callback method.

The given method will be called whenever there is a new database entry for this DBAccessor.

Parameters
callbackfunction pointer to a callback function
onDestructionif true the callback will not be called for each change but only when the Database entry is deleted and can be used to remove dangling pointers to the entry.

Definition at line 118 of file DBAccessorBase.h.

119 {
120 addCallback([callback](const std::string&) -> void { callback(); }, onDestruction);
121 }
void addCallback(std::function< void(const std::string &)> callback, bool onDestruction=false)
Add a callback method.

◆ addCallback() [2/3]

void addCallback ( std::function< void(const std::string &)>  callback,
bool  onDestruction = false 
)
inlineinherited

Add a callback method.

The given method will be called whenever there is a new database entry for this DBAccessor. The one parameter is the name of the DB entry which changed (in case the same callback method is to be used for multiple payloads.

Parameters
callbackfunction pointer to a callback function
onDestructionif true the callback will not be called for each change but only when the Database entry is deleted and can be used to remove dangling pointers to the entry.

Definition at line 105 of file DBAccessorBase.h.

106 {
107 m_callbacks.emplace_back(callback, onDestruction);
108 }
std::vector< std::pair< std::function< void(const std::string &)>, bool > > m_callbacks
List of all registered callback functions.

◆ addCallback() [3/3]

void addCallback ( T *  object,
void(T::*)()  callback 
)
inlineinherited

Add a callback method of an object.

The given method will be called whenever there is a new database entry for this DBAccessor.

Parameters
objectThe object with the callback method.
callbackThe callback method.

Definition at line 130 of file DBAccessorBase.h.

131 {
132 addCallback([ = ](const std::string&) {(*object.*callback)();});
133 }

◆ ensureAttached()

bool ensureAttached ( ) const
inlineprotectedinherited

Make sure we are attached to the the DBStore.

If not try to reconnect

Definition at line 171 of file DBAccessorBase.h.

172 {
173 if (!m_entry) {
174 B2DEBUG(32, "DBAccessor " << m_name << " lost connection, reattaching");
176 m_changed = true;
177 if (!m_entry) return false;
178 m_entry->registerAccessor(const_cast<DBAccessorBase*>(this));
179 }
180 return true;
181 }
bool m_changed
Internal flag whether the object has changed since we last checked.
const TClass * m_objClass
Class of the payload if type is c_Object.
DBAccessorBase(const std::string &name, const TClass *objClass, bool isArray, bool isRequired)
Constructor to access an object in the DBStore.
const std::string m_name
Name of the payload in the database.
DBStoreEntry * m_entry
Pointer to the entry in the DBStore.
const bool m_isArray
True if the payload is an array of objects.
const DBStoreEntry::EPayloadType m_type
Type of the payload.
const bool m_isRequired
True if the payload is required, otherwise no errors will be raised if it cannot be found.
void registerAccessor(DBAccessorBase *object)
Register an Accessor object to be notified on changes by calling DBAccessorBase::storeEntryChanged()
Definition: DBStoreEntry.h:123
static DBStore & Instance()
Instance of a singleton DBStore.
Definition: DBStore.cc:28
DBStoreEntry * getEntry(DBStoreEntry::EPayloadType payloadType, const std::string &name, const TClass *objClass, bool array, bool required=true)
Returns the entry with the requested name in the DBStore.
Definition: DBStore.cc:34

◆ getChecksum()

const std::string & getChecksum ( ) const
inlineinherited

Get current checksum.

Definition at line 145 of file DBAccessorBase.h.

145{ ensureAttached(); return m_entry->getChecksum(); }
bool ensureAttached() const
Make sure we are attached to the the DBStore.
const std::string & getChecksum() const
get the checksum of the payload.
Definition: DBStoreEntry.h:104

◆ getEntries()

int getEntries ( ) const

Get the number of entries.

Definition at line 39 of file PyDBArray.cc.

40{
41 return isValid() ? (getObject<TClonesArray>()->GetEntriesFast()) : 0;
42}
bool isValid() const
Check whether a valid object was obtained from the database.

◆ getFilename()

const std::string & getFilename ( ) const
inlineinherited

Get the filename this object is loaded from.

Definition at line 148 of file DBAccessorBase.h.

148{ ensureAttached(); return m_entry->getFilename(); }
const std::string & getFilename() const
get the filename for this payload
Definition: DBStoreEntry.h:101

◆ getGlobaltag()

const std::string & getGlobaltag ( ) const
inlineinherited

Return the globaltag name (or testing payloads path) this object is loaded from.

Definition at line 136 of file DBAccessorBase.h.

136{ ensureAttached(); return m_entry->getGlobaltag(); }
const std::string & getGlobaltag() const
get the globaltag name (or testing payloads path) from which the payload is picked.
Definition: DBStoreEntry.h:94

◆ getIntraRunBoundaries()

const std::vector< unsigned int > getIntraRunBoundaries ( ) const
inlineinherited

Get the intra-run boundaries, if any.

If the intra-run dependency is by event number, the event numbers used as boundaries are returned.

Definition at line 157 of file DBAccessorBase.h.

const std::vector< unsigned int > getIntraRunBoundaries() const
return the boundaries of the intra-run changes of the payload, if any
Definition: DBStoreEntry.h:121

◆ getIntraRunBoundariesList()

PyObject * getIntraRunBoundariesList ( ) const

Get the intra-run boundaries, if any, as a python list.

Definition at line 51 of file PyDBArray.cc.

52{
53 PyObject* list = PyList_New(0);
54 // Currently, the boundaries are defined only as unsigned int.
55 // If in the future this will change, this method has to be updated accordingly.
56 for (auto boundary : getIntraRunBoundaries())
57 PyList_Append(list, PyLong_FromUnsignedLong(boundary));
58 return list;
59}
const std::vector< unsigned int > getIntraRunBoundaries() const
Get the intra-run boundaries, if any.

◆ getIoV()

IntervalOfValidity getIoV ( ) const
inlineinherited

Return current IoV of the object.

Definition at line 142 of file DBAccessorBase.h.

142{ ensureAttached(); return m_entry->getIoV(); }
IntervalOfValidity getIoV() const
get the validity of the payload
Definition: DBStoreEntry.h:99

◆ getName()

const std::string & getName ( ) const
inlineinherited

Return name under which the object is saved in the DBStore.

Definition at line 66 of file DBAccessorBase.h.

66{ return m_name; }

◆ getObject()

const T * getObject ( ) const
inlineprotectedinherited

Return a pointer to the Object already cast to the correct type.

Definition at line 164 of file DBAccessorBase.h.

165 {
166 if (!ensureAttached()) return nullptr;
167 return reinterpret_cast<const T*>(m_entry->getObject());
168 }
const TObject * getObject() const
get the object for this payload, can be nullptr if the payload is not loaded or not of type c_Object
Definition: DBStoreEntry.h:107

◆ getRevision()

unsigned int getRevision ( ) const
inlineinherited

Return current revision of the object.

Definition at line 139 of file DBAccessorBase.h.

139{ ensureAttached(); return m_entry->getRevision(); }
unsigned int getRevision() const
get the revision of the payload, this is an abitrary number which indicates the conditions version
Definition: DBStoreEntry.h:97

◆ hasChanged()

bool hasChanged ( )
inline

Check whether the object has changed since the last call to hasChanged of the accessor).

Definition at line 89 of file DBAccessorBase.h.

90 {
91 const bool ret = m_changed;
92 m_changed = false;
93 return ret;
94 }

◆ isIntraRunDependent()

bool isIntraRunDependent ( ) const
inlineinherited

Check wether this conditions object has some intra-run dependencies.

Definition at line 151 of file DBAccessorBase.h.

bool isIntraRunDependent() const
return whether or not the payload might change even during the run
Definition: DBStoreEntry.h:119

◆ isRequired()

bool isRequired ( ) const
inlineinherited

Check whether this conditions object is required (at least one user declared it as required)

Definition at line 160 of file DBAccessorBase.h.

160{ ensureAttached(); return m_entry->isRequired(); }
bool isRequired() const
check whether this payload is required for operation
Definition: DBStoreEntry.h:115

◆ isValid()

bool isValid ( ) const
inline

Check whether a valid object was obtained from the database.

Returns
True if the object exists.

Definition at line 72 of file DBAccessorBase.h.

72{if (!ensureAttached()) return false; return (m_entry->getObject() != nullptr);}

◆ operator bool()

operator bool ( ) const
inlineinherited

Imitate pointer functionality.

Definition at line 74 of file DBAccessorBase.h.

◆ operator!=()

virtual bool operator!= ( const DBAccessorBase other) const
inlinevirtualinherited

Check if two store accessors point to a different object/array.

Definition at line 83 of file DBAccessorBase.h.

84 {
85 return !(*this == other);
86 }

◆ operator==()

virtual bool operator== ( const DBAccessorBase other) const
inlinevirtualinherited

Check if two store accessors point to the same object/array.

Definition at line 77 of file DBAccessorBase.h.

78 {
79 return getName() == other.getName();
80 }
const std::string & getName() const
Return name under which the object is saved in the DBStore.

◆ storeEntryChanged()

void storeEntryChanged ( bool  destructed)
inlineprotectedinherited

Callback function which gets called by the DBStoreEntry object if it changes.

Definition at line 184 of file DBAccessorBase.h.

185 {
186 // we obviously changed
187 m_changed = true;
188 // StoreEntry is destructed, remove reference
189 if (destructed) m_entry = nullptr;
190 // Now run all registered callbacks
191 // TODO: We could guard m_callbacks against insertions during callback
192 // execution to prevent exponential growth of callbacks
193 for (const auto& cb : m_callbacks) {
194 if (destructed == cb.second) cb.first(m_name);
195 }
196 }

Member Data Documentation

◆ m_callbacks

std::vector<std::pair<std::function<void(const std::string&)>, bool> > m_callbacks
protectedinherited

List of all registered callback functions.

Definition at line 213 of file DBAccessorBase.h.

◆ m_changed

bool m_changed {false}
mutableprotectedinherited

Internal flag whether the object has changed since we last checked.

Definition at line 211 of file DBAccessorBase.h.

◆ m_entry

DBStoreEntry* m_entry
mutableprotectedinherited

Pointer to the entry in the DBStore.

Definition at line 209 of file DBAccessorBase.h.

◆ m_isArray

const bool m_isArray
protectedinherited

True if the payload is an array of objects.

Definition at line 205 of file DBAccessorBase.h.

◆ m_isRequired

const bool m_isRequired
protectedinherited

True if the payload is required, otherwise no errors will be raised if it cannot be found.

Definition at line 207 of file DBAccessorBase.h.

◆ m_name

const std::string m_name
protectedinherited

Name of the payload in the database.

Definition at line 201 of file DBAccessorBase.h.

◆ m_objClass

const TClass* m_objClass
protectedinherited

Class of the payload if type is c_Object.

Definition at line 203 of file DBAccessorBase.h.

◆ m_type

const DBStoreEntry::EPayloadType m_type
protectedinherited

Type of the payload.

Definition at line 199 of file DBAccessorBase.h.


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