ODFEDAQConfig Class Reference

#include <ODFEDAQConfig.h>

Inheritance diagram for ODFEDAQConfig:

Public Member Functions
int	fetchNextId () noexcept(false)
int	getBadTTId () const
int	getBadXtId () const
std::string	getComment () const
int	getDelayId () const
int	getId () const
int	getPedestalId () const
std::string	getTable () override
int	getTriggerBadTTId () const
int	getTriggerBadXtId () const
int	getVersion () const
int	getWeightId () const
	ODFEDAQConfig ()
void	setBadTTId (int x)
void	setBadXtId (int x)
void	setComment (std::string x)
void	setDelayId (int x)
void	setId (int id)
void	setParameters (const std::map< std::string, std::string > &my_keys_map)
void	setPedestalId (int x)
void	setTriggerBadTTId (int x)
void	setTriggerBadXtId (int x)
void	setVersion (int id)
void	setWeightId (int x)
	~ODFEDAQConfig () override
Public Member Functions inherited from IODConfig
std::string	getConfigTag ()
void	setConfigTag (std::string x)
Public Member Functions inherited from IDBObject
oracle::occi::Connection *	getConn () const
oracle::occi::Environment *	getEnv () const
void	setConnection (oracle::occi::Environment *env, oracle::occi::Connection *conn)
virtual	~IDBObject ()

Private Member Functions
void	clear ()
void	fetchData (ODFEDAQConfig *result) noexcept(false)
int	fetchID () noexcept(false)
void	prepareWrite () noexcept(false) override
void	writeDB () noexcept(false)

Private Attributes
int	m_btt
int	m_bxt
std::string	m_com
int	m_del
int	m_ID
int	m_ped
int	m_tbtt
int	m_tbxt
int	m_version
int	m_wei

Friends
class	EcalCondDBInterface

Additional Inherited Members
Public Types inherited from IODConfig
typedef oracle::occi::Clob	Clob
typedef oracle::occi::SQLException	SQLException
typedef oracle::occi::Statement	Statement
typedef oracle::occi::Stream	Stream
Public Attributes inherited from IODConfig
std::string	m_config_tag
Static Public Attributes inherited from IDBObject
static const int	ECALDB_NROWS = 1024
Protected Member Functions inherited from IODConfig
void	checkPrepare () noexcept(false)
void	createReadStatement () noexcept(false)
void	populateClob (Clob &clob, std::string fname, unsigned int bufsize) noexcept(false)
unsigned char *	readClob (Clob &clob, int size) noexcept(false)
void	setPrefetchRowCount (int ncount) noexcept(false)
void	terminateReadStatement () noexcept(false)
void	terminateWriteStatement () noexcept(false)
Protected Member Functions inherited from IDBObject
void	checkConnection () const noexcept(false)
Protected Attributes inherited from IODConfig
Statement *	m_readStmt
Statement *	m_writeStmt
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Detailed Description

Definition at line 9 of file ODFEDAQConfig.h.

Constructor & Destructor Documentation

ODFEDAQConfig()

ODFEDAQConfig::ODFEDAQConfig

(

)

Definition at line 28 of file ODFEDAQConfig.cc.

                             {
  m_env = nullptr;
  m_conn = nullptr;
  m_writeStmt = nullptr;
  m_readStmt = nullptr;
  m_config_tag = "";
  m_ID = 0;
  clear();
}

References clear().

~ODFEDAQConfig()

ODFEDAQConfig::~ODFEDAQConfig ( )

override

Definition at line 52 of file ODFEDAQConfig.cc.

{}

Member Function Documentation

clear()

void ODFEDAQConfig::clear ( void  )

private

Definition at line 38 of file ODFEDAQConfig.cc.

                          {
  m_del = MY_NULL;
  m_wei = MY_NULL;
  m_ped = MY_NULL;
 
  m_bxt = MY_NULL;
  m_btt = MY_NULL;
  m_tbtt = MY_NULL;
  m_tbxt = MY_NULL;
 
  m_version = 0;
  m_com = "";
}

References MY_NULL.

fetchData()

void ODFEDAQConfig::fetchData ( ODFEDAQConfig *  result )

privatenoexcept

Definition at line 149 of file ODFEDAQConfig.cc.

                                                                   {
  this->checkConnection();
  result->clear();
  if (result->getId() == 0 && (result->getConfigTag().empty())) {
    throw(std::runtime_error("ODFEDAQConfig::fetchData(): no Id defined for this ODFEDAQConfig "));
  }
 
  m_readStmt = m_conn->createStatement();
  if (!result->getConfigTag().empty() && result->getVersion() == 0) {
    int new_version = 0;
    std::cout << "using new method : retrieving last version for this tag " << endl;
    try {
      this->checkConnection();
 
      m_readStmt->setSQL("select max(version) from " + getTable() + " where tag=:tag ");
      m_readStmt->setString(1, result->getConfigTag());
      std::cout << "Getting last ver" << std::endl << std::flush;
      ResultSet* rset = m_readStmt->executeQuery();
      while (rset->next()) {
        new_version = rset->getInt(1);
      }
      m_conn->terminateStatement(m_readStmt);
 
      //      m_readStmt = m_conn->createStatement();
 
      result->setVersion(new_version);
 
    } catch (SQLException& e) {
      throw(std::runtime_error(std::string("ODFEDAQConfig::fetchData():  ") + e.getMessage()));
    }
  }
 
  try {
    m_readStmt->setSQL("SELECT * FROM " + getTable() + " where ( config_id = :1 or (tag=:2 AND version=:3 ) )");
    m_readStmt->setInt(1, result->getId());
    m_readStmt->setString(2, result->getConfigTag());
    m_readStmt->setInt(3, result->getVersion());
    ResultSet* rset = m_readStmt->executeQuery();
 
    rset->next();
 
    // 1 is the id and 2 is the config tag and 3 is the version
 
    result->setId(rset->getInt(1));
    result->setConfigTag(rset->getString(2));
    result->setVersion(rset->getInt(3));
 
    result->setPedestalId(getInt(rset, 4));
    result->setDelayId(getInt(rset, 5));
    result->setWeightId(getInt(rset, 6));
    result->setBadXtId(getInt(rset, 7));
    result->setBadTTId(getInt(rset, 8));
    result->setTriggerBadXtId(getInt(rset, 9));
    result->setTriggerBadTTId(getInt(rset, 10));
    result->setComment(rset->getString(11));
 
  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODFEDAQConfig::fetchData():  ") + e.getMessage()));
  }
}

References gather_cfg::cout, MillePedeFileConverter_cfg::e, getInt(), mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by EcalCondDBInterface::fetchFEDelaysForRun().

fetchID()

int ODFEDAQConfig::fetchID ( )

privatenoexcept

Definition at line 210 of file ODFEDAQConfig.cc.

                                           {
  // Return from memory if available
  if (m_ID != 0) {
    return m_ID;
  }
 
  this->checkConnection();
 
  try {
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL("SELECT config_id FROM " + getTable() + "WHERE  tag=:1 and version=:2 ");
 
    stmt->setString(1, getConfigTag());
    stmt->setInt(2, getVersion());
 
    ResultSet* rset = stmt->executeQuery();
 
    if (rset->next()) {
      m_ID = rset->getInt(1);
    } else {
      m_ID = 0;
    }
    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODFEDAQConfig::fetchID:  ") + e.getMessage()));
  }
 
  return m_ID;
}

References MillePedeFileConverter_cfg::e, and AlCaHLTBitMon_QueryRunRegistry::string.

fetchNextId()

int ODFEDAQConfig::fetchNextId ( )

noexcept

Definition at line 54 of file ODFEDAQConfig.cc.

                                               {
  int result = 0;
  try {
    this->checkConnection();
 
    m_readStmt = m_conn->createStatement();
    m_readStmt->setSQL("select fe_daq_conDfig_sq.nextVal from dual");
    ResultSet* rset = m_readStmt->executeQuery();
    while (rset->next()) {
      result = rset->getInt(1);
    }
    m_conn->terminateStatement(m_readStmt);
    return result;
 
  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODFEDAQConfig::fetchNextId():  ") + e.getMessage()));
  }
}

References MillePedeFileConverter_cfg::e, mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

getBadTTId()

int ODFEDAQConfig::getBadTTId ( ) const

inline

Definition at line 36 of file ODFEDAQConfig.h.

{ return m_btt; }

References m_btt.

Referenced by popcon::EcalChannelStatusHandler::daqOut(), and popcon::EcalDAQHandler::getNewObjects().

getBadXtId()

int ODFEDAQConfig::getBadXtId ( ) const

inline

Definition at line 34 of file ODFEDAQConfig.h.

{ return m_bxt; }

References m_bxt.

getComment()

std::string ODFEDAQConfig::getComment ( ) const

inline

Definition at line 43 of file ODFEDAQConfig.h.

{ return m_com; }

References m_com.

getDelayId()

int ODFEDAQConfig::getDelayId ( ) const

inline

Definition at line 29 of file ODFEDAQConfig.h.

{ return m_del; }

References m_del.

getId()

int ODFEDAQConfig::getId ( void  ) const

inline

Definition at line 19 of file ODFEDAQConfig.h.

{ return m_ID; }

References m_ID.

getPedestalId()

int ODFEDAQConfig::getPedestalId ( ) const

inline

Definition at line 27 of file ODFEDAQConfig.h.

{ return m_ped; }

References m_ped.

getTable()

std::string ODFEDAQConfig::getTable ( )

inlineoverridevirtual

Implements IODConfig.

Definition at line 16 of file ODFEDAQConfig.h.

{ return "FE_DAQ_CONFIG"; }

getTriggerBadTTId()

int ODFEDAQConfig::getTriggerBadTTId ( ) const

inline

Definition at line 40 of file ODFEDAQConfig.h.

{ return m_tbtt; }

References m_tbtt.

getTriggerBadXtId()

int ODFEDAQConfig::getTriggerBadXtId ( ) const

inline

Definition at line 38 of file ODFEDAQConfig.h.

{ return m_tbxt; }

References m_tbxt.

getVersion()

int ODFEDAQConfig::getVersion ( ) const

inline

Definition at line 24 of file ODFEDAQConfig.h.

{ return m_version; }

References m_version.

getWeightId()

int ODFEDAQConfig::getWeightId ( ) const

inline

Definition at line 31 of file ODFEDAQConfig.h.

{ return m_wei; }

References m_wei.

Referenced by popcon::EcalSRPHandler::getNewObjects().

prepareWrite()

void ODFEDAQConfig::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IODConfig.

Definition at line 73 of file ODFEDAQConfig.cc.

                                                 {
  this->checkConnection();
  int next_id = fetchNextId();
 
  try {
    m_writeStmt = m_conn->createStatement();
    m_writeStmt->setSQL(
        "INSERT INTO FE_DAQ_CONFIG ( config_id, tag, version, ped_id, "
        " del_id, wei_id,bxt_id, btt_id, tr_bxt_id, tr_btt_id, user_comment ) "
        "VALUES ( :1, :2, :3, :4, :5, :6, :7 ,:8, :9, :10, :11 )");
 
    m_writeStmt->setInt(1, next_id);
    m_ID = next_id;
 
  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODFEDAQConfig::prepareWrite():  ") + e.getMessage()));
  }
}

References MillePedeFileConverter_cfg::e, and AlCaHLTBitMon_QueryRunRegistry::string.

setBadTTId()

void ODFEDAQConfig::setBadTTId ( int  x )

inline

Definition at line 35 of file ODFEDAQConfig.h.

{ m_btt = x; }

References m_btt, and x.

setBadXtId()

void ODFEDAQConfig::setBadXtId ( int  x )

inline

Definition at line 33 of file ODFEDAQConfig.h.

{ m_bxt = x; }

References m_bxt, and x.

setComment()

void ODFEDAQConfig::setComment ( std::string  x )

inline

Definition at line 42 of file ODFEDAQConfig.h.

{ m_com = x; }

References m_com, and x.

Referenced by ConfigToolBase.ConfigToolBase::apply().

setDelayId()

void ODFEDAQConfig::setDelayId ( int  x )

inline

Definition at line 28 of file ODFEDAQConfig.h.

{ m_del = x; }

References m_del, and x.

setId()

void ODFEDAQConfig::setId ( int  id )

inline

Definition at line 18 of file ODFEDAQConfig.h.

{ m_ID = id; }

References triggerObjects_cff::id, and m_ID.

Referenced by popcon::EcalChannelStatusHandler::daqOut(), popcon::EcalSRPHandler::getNewObjects(), and popcon::EcalDAQHandler::getNewObjects().

setParameters()

void ODFEDAQConfig::setParameters

(

const std::map< std::string, std::string > &

my_keys_map

)

Definition at line 92 of file ODFEDAQConfig.cc.

                                                                           {
  // parses the result of the XML parser that is a map of
  // string string with variable name variable value
 
  for (std::map<std::string, std::string>::const_iterator ci = my_keys_map.begin(); ci != my_keys_map.end(); ci++) {
    if (ci->first == "VERSION")
      setVersion(atoi(ci->second.c_str()));
    if (ci->first == "PED_ID")
      setPedestalId(atoi(ci->second.c_str()));
    if (ci->first == "DEL_ID")
      setDelayId(atoi(ci->second.c_str()));
    if (ci->first == "WEI_ID")
      setWeightId(atoi(ci->second.c_str()));
 
    if (ci->first == "BXT_ID")
      setBadXtId(atoi(ci->second.c_str()));
    if (ci->first == "BTT_ID")
      setBadTTId(atoi(ci->second.c_str()));
    if (ci->first == "TRIG_BXT_ID")
      setTriggerBadXtId(atoi(ci->second.c_str()));
    if (ci->first == "TRIG_BTT_ID")
      setTriggerBadTTId(atoi(ci->second.c_str()));
 
    if (ci->first == "COMMENT" || ci->first == "USER_COMMENT")
      setComment(ci->second);
  }
}

setPedestalId()

void ODFEDAQConfig::setPedestalId ( int  x )

inline

Definition at line 26 of file ODFEDAQConfig.h.

{ m_ped = x; }

References m_ped, and x.

setTriggerBadTTId()

void ODFEDAQConfig::setTriggerBadTTId ( int  x )

inline

Definition at line 39 of file ODFEDAQConfig.h.

{ m_tbtt = x; }

References m_tbtt, and x.

setTriggerBadXtId()

void ODFEDAQConfig::setTriggerBadXtId ( int  x )

inline

Definition at line 37 of file ODFEDAQConfig.h.

{ m_tbxt = x; }

References m_tbxt, and x.

setVersion()

void ODFEDAQConfig::setVersion ( int  id )

inline

Definition at line 23 of file ODFEDAQConfig.h.

{ m_version = id; }

References triggerObjects_cff::id, and m_version.

setWeightId()

void ODFEDAQConfig::setWeightId ( int  x )

inline

Definition at line 30 of file ODFEDAQConfig.h.

{ m_wei = x; }

References m_wei, and x.

writeDB()

void ODFEDAQConfig::writeDB ( )

privatenoexcept

Definition at line 120 of file ODFEDAQConfig.cc.

                                            {
  this->checkConnection();
  this->checkPrepare();
 
  try {
    // number 1 is the id
    m_writeStmt->setString(2, this->getConfigTag());
    m_writeStmt->setInt(3, this->getVersion());
    SET_INT(m_writeStmt, 4, this->getPedestalId());
    SET_INT(m_writeStmt, 5, this->getDelayId());
    SET_INT(m_writeStmt, 6, this->getWeightId());
    SET_INT(m_writeStmt, 7, this->getBadXtId());
    SET_INT(m_writeStmt, 8, this->getBadTTId());
    SET_INT(m_writeStmt, 9, this->getTriggerBadXtId());
    SET_INT(m_writeStmt, 10, this->getTriggerBadTTId());
 
    m_writeStmt->setString(11, this->getComment());
 
    m_writeStmt->executeUpdate();
 
  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODFEDAQConfig::writeDB():  ") + e.getMessage()));
  }
  // Now get the ID
  if (!this->fetchID()) {
    throw(std::runtime_error("ODFEDAQConfig::writeDB:  Failed to write"));
  }
}

References MillePedeFileConverter_cfg::e, SET_INT, and AlCaHLTBitMon_QueryRunRegistry::string.

Friends And Related Function Documentation

EcalCondDBInterface

friend class EcalCondDBInterface

friend

Definition at line 11 of file ODFEDAQConfig.h.

Member Data Documentation

m_btt

int ODFEDAQConfig::m_btt

private

Definition at line 66 of file ODFEDAQConfig.h.

Referenced by getBadTTId(), and setBadTTId().

m_bxt

int ODFEDAQConfig::m_bxt

private

Definition at line 65 of file ODFEDAQConfig.h.

Referenced by getBadXtId(), and setBadXtId().

m_com

std::string ODFEDAQConfig::m_com

private

Definition at line 70 of file ODFEDAQConfig.h.

Referenced by getComment(), and setComment().

m_del

int ODFEDAQConfig::m_del

private

Definition at line 62 of file ODFEDAQConfig.h.

Referenced by getDelayId(), and setDelayId().

m_ID

int ODFEDAQConfig::m_ID

private

Definition at line 60 of file ODFEDAQConfig.h.

Referenced by getId(), and setId().

m_ped

int ODFEDAQConfig::m_ped

private

Definition at line 61 of file ODFEDAQConfig.h.

Referenced by getPedestalId(), and setPedestalId().

m_tbtt

int ODFEDAQConfig::m_tbtt

private

Definition at line 68 of file ODFEDAQConfig.h.

Referenced by getTriggerBadTTId(), and setTriggerBadTTId().

m_tbxt

int ODFEDAQConfig::m_tbxt

private

Definition at line 67 of file ODFEDAQConfig.h.

Referenced by getTriggerBadXtId(), and setTriggerBadXtId().

m_version

int ODFEDAQConfig::m_version

private

Definition at line 69 of file ODFEDAQConfig.h.

Referenced by getVersion(), and setVersion().

m_wei

int ODFEDAQConfig::m_wei

private

Definition at line 63 of file ODFEDAQConfig.h.

Referenced by getWeightId(), and setWeightId().