dqi::DatabaseConfig Class Reference

#include <DatabaseConfig.h>

Collaboration diagram for dqi::DatabaseConfig:

Public Member Functions
	DatabaseConfig (std::string connectionString, long runNumber)
nlohmann::json	GetPayload (const std::string &tag)
bool	IsConnected () const
void	Disconnect ()

Private Member Functions
long	GetRunNumber () const
nlohmann::json	LoadPayload (const std::string &tag)
void	Connect ()

Private Attributes
const std::string	m_connectionString
const long	m_runNumber {}
bool	m_dbConnected {}
bool	m_folderConnected {}
std::unordered_map< std::string, nlohmann::json >	m_jsonData
cool::IFolderPtr	m_folder
cool::IDatabasePtr	m_database

Detailed Description

Definition at line 15 of file DatabaseConfig.h.

Constructor & Destructor Documentation

DatabaseConfig()

dqi::DatabaseConfig::DatabaseConfig	(	std::string	connectionString,
		long	runNumber
	)

Definition at line 20 of file DatabaseConfig.cxx.

  : m_connectionString(std::move(connectionString))
  , m_runNumber((runNumber << 32) + 1)
  , m_dbConnected(false)
  , m_folderConnected(false)
{
}

Member Function Documentation

Connect()

void dqi::DatabaseConfig::Connect ( )

private

Definition at line 41 of file DatabaseConfig.cxx.

{
  try {
    cool::IDatabaseSvc& dbSvc = cool::DatabaseSvcFactory::databaseService();
    m_database = dbSvc.openDatabase(m_connectionString, true);
 
  } catch (std::exception& e) {
    std::cerr << "Unable to open database -> " << e.what() << '\n';
    return;
  }
  m_dbConnected = true;
  try {
    m_folder= m_database->getFolder("/GLOBAL/DQM/REFERENCES");
 
  } catch (std::exception& e) {
    std::cerr << "Unable loading folder for this tag/run-> " << e.what() << '\n';
    return;
  }
  m_folderConnected = true;
}

Disconnect()

void dqi::DatabaseConfig::Disconnect

(

)

Definition at line 30 of file DatabaseConfig.cxx.

{
    if(m_dbConnected) {
      m_database->closeDatabase();
      m_dbConnected = false;
      m_folderConnected = false;
    }
}

GetPayload()

nlohmann::json dqi::DatabaseConfig::GetPayload

(

const std::string &

tag

)

Definition at line 64 of file DatabaseConfig.cxx.

{
  if(!m_dbConnected && !m_folderConnected) {
    Connect();
  }
  if(m_jsonData.find(tag) == m_jsonData.end()) {
    return LoadPayload(tag);
  }
  return m_jsonData.at(tag);
}

GetRunNumber()

long dqi::DatabaseConfig::GetRunNumber ( ) const

private

Definition at line 104 of file DatabaseConfig.cxx.

{
  return m_runNumber;
}

IsConnected()

bool dqi::DatabaseConfig::IsConnected

(

)

const

Definition at line 97 of file DatabaseConfig.cxx.

{
  return m_dbConnected && m_folderConnected;
}

LoadPayload()

nlohmann::json dqi::DatabaseConfig::LoadPayload ( const std::string &  tag )

private

Definition at line 77 of file DatabaseConfig.cxx.

{
  nlohmann::json jsonData;
  if(m_dbConnected && m_folderConnected) {
    try {
      cool::IObjectPtr object = m_folder->findObject(GetRunNumber(), 1, tag);
 
      std::string data = object->payloadValue("jsonData");
      jsonData = nlohmann::json::parse(data);
      m_jsonData[tag] = jsonData;
 
    } catch (std::exception& e) {
      std::cerr << "Error: Failed loading payload for this tag/run-> " << e.what() << '\n';
    }
  }
  return jsonData;
}

Member Data Documentation

m_connectionString

const std::string dqi::DatabaseConfig::m_connectionString

private

Definition at line 25 of file DatabaseConfig.h.

m_database

cool::IDatabasePtr dqi::DatabaseConfig::m_database

private

Definition at line 33 of file DatabaseConfig.h.

m_dbConnected

bool dqi::DatabaseConfig::m_dbConnected {}

private

Definition at line 28 of file DatabaseConfig.h.

m_folder

cool::IFolderPtr dqi::DatabaseConfig::m_folder

private

Definition at line 32 of file DatabaseConfig.h.

m_folderConnected

bool dqi::DatabaseConfig::m_folderConnected {}

private

Definition at line 29 of file DatabaseConfig.h.

m_jsonData

std::unordered_map<std::string, nlohmann::json> dqi::DatabaseConfig::m_jsonData

private

Definition at line 31 of file DatabaseConfig.h.

m_runNumber

const long dqi::DatabaseConfig::m_runNumber {}

private

Definition at line 26 of file DatabaseConfig.h.

---

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

• DatabaseConfig.h
• DatabaseConfig.cxx