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 int const	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

(

)

Definition at line 21 of file ODFEDAQConfig.cc.

References hitfit::clear().

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

ODFEDAQConfig::~ODFEDAQConfig ( )

override

Definition at line 49 of file ODFEDAQConfig.cc.

{
}

Member Function Documentation

void ODFEDAQConfig::clear ( void  )

private

Definition at line 33 of file ODFEDAQConfig.cc.

References MY_NULL.

Referenced by getComment().

                         {
   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="";
}

void ODFEDAQConfig::fetchData ( ODFEDAQConfig *  result )

privatenoexcept

Definition at line 157 of file ODFEDAQConfig.cc.

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

Referenced by EcalCondDBInterface::fetchFEDelaysForRun(), and getComment().

{
  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():  ")+getOraMessage(&e)));
    }
    
    
    
  }

  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(getOraString(rset,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(          getOraString(rset,11) );

  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("ODFEDAQConfig::fetchData():  ")+getOraMessage(&e)));
  }
}

int ODFEDAQConfig::fetchID ( )

privatenoexcept

Definition at line 225 of file ODFEDAQConfig.cc.

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

Referenced by getComment().

{
  // 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:  ")+getOraMessage(&e)));
  }

  return m_ID;
}

int ODFEDAQConfig::fetchNextId ( )

noexcept

Definition at line 55 of file ODFEDAQConfig.cc.

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

Referenced by getComment().

                                                {

  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():  ")+getOraMessage(&e)));
  }

}

int ODFEDAQConfig::getBadTTId ( ) const

inline

Definition at line 36 of file ODFEDAQConfig.h.

References m_btt.

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

{ return m_btt; }

int ODFEDAQConfig::getBadXtId ( ) const

inline

Definition at line 34 of file ODFEDAQConfig.h.

References m_bxt.

{ return m_bxt; }

std::string ODFEDAQConfig::getComment ( ) const

inline

Definition at line 43 of file ODFEDAQConfig.h.

References clear(), fetchData(), fetchID(), fetchNextId(), m_com, noexcept, prepareWrite(), mps_fire::result, setParameters(), and writeDB().

{ return m_com; }

int ODFEDAQConfig::getDelayId ( ) const

inline

Definition at line 29 of file ODFEDAQConfig.h.

References m_del.

Referenced by EcalCondDBInterface::fetchFEDelaysForRun().

{ return m_del; }

int ODFEDAQConfig::getId ( void  ) const

inline

Definition at line 19 of file ODFEDAQConfig.h.

References m_ID.

{ return m_ID; }

int ODFEDAQConfig::getPedestalId ( ) const

inline

Definition at line 27 of file ODFEDAQConfig.h.

References m_ped.

{ return m_ped; }

std::string ODFEDAQConfig::getTable ( )

inlineoverridevirtual

Implements IODConfig.

Definition at line 16 of file ODFEDAQConfig.h.

{ return "FE_DAQ_CONFIG"; }

int ODFEDAQConfig::getTriggerBadTTId ( ) const

inline

Definition at line 40 of file ODFEDAQConfig.h.

References m_tbtt.

{ return m_tbtt; }

int ODFEDAQConfig::getTriggerBadXtId ( ) const

inline

Definition at line 38 of file ODFEDAQConfig.h.

References m_tbxt.

{ return m_tbxt; }

int ODFEDAQConfig::getVersion ( ) const

inline

Definition at line 24 of file ODFEDAQConfig.h.

References m_version.

{ return m_version; }

int ODFEDAQConfig::getWeightId ( ) const

inline

Definition at line 31 of file ODFEDAQConfig.h.

References m_wei.

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

{ return m_wei; }

void ODFEDAQConfig::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IODConfig.

Definition at line 76 of file ODFEDAQConfig.cc.

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

Referenced by getComment().

{
  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():  ")+getOraMessage(&e)));
  }

}

void ODFEDAQConfig::setBadTTId ( int  x )

inline

Definition at line 35 of file ODFEDAQConfig.h.

References m_btt, and x.

{ m_btt = x; }

void ODFEDAQConfig::setBadXtId ( int  x )

inline

Definition at line 33 of file ODFEDAQConfig.h.

References m_bxt, and x.

{ m_bxt = x; }

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

inline

Definition at line 42 of file ODFEDAQConfig.h.

References m_com, and x.

{ m_com = x; }

void ODFEDAQConfig::setDelayId ( int  x )

inline

Definition at line 28 of file ODFEDAQConfig.h.

References m_del, and x.

{ m_del = x; }

void ODFEDAQConfig::setId ( int  id )

inline

Definition at line 18 of file ODFEDAQConfig.h.

References triggerObjects_cff::id, and m_ID.

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

{ m_ID = id; }

void ODFEDAQConfig::setParameters

(

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

my_keys_map

)

Definition at line 97 of file ODFEDAQConfig.cc.

Referenced by getComment().

                                                                         {
  
  // 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);
    
  }
  
}

void ODFEDAQConfig::setPedestalId ( int  x )

inline

Definition at line 26 of file ODFEDAQConfig.h.

References m_ped, and x.

{ m_ped = x; }

void ODFEDAQConfig::setTriggerBadTTId ( int  x )

inline

Definition at line 39 of file ODFEDAQConfig.h.

References m_tbtt, and x.

{ m_tbtt = x; }

void ODFEDAQConfig::setTriggerBadXtId ( int  x )

inline

Definition at line 37 of file ODFEDAQConfig.h.

References m_tbxt, and x.

{ m_tbxt = x; }

void ODFEDAQConfig::setVersion ( int  id )

inline

Definition at line 23 of file ODFEDAQConfig.h.

References triggerObjects_cff::id, and m_version.

{ m_version = id; }

void ODFEDAQConfig::setWeightId ( int  x )

inline

Definition at line 30 of file ODFEDAQConfig.h.

References m_wei, and x.

{ m_wei = x; }

void ODFEDAQConfig::writeDB ( )

privatenoexcept

Definition at line 121 of file ODFEDAQConfig.cc.

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

Referenced by getComment().

{
  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():  ")+getOraMessage(&e)));
  }
  // Now get the ID
  if (!this->fetchID()) {
    throw(std::runtime_error("ODFEDAQConfig::writeDB:  Failed to write"));
  }


}

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 11 of file ODFEDAQConfig.h.

Member Data Documentation

int ODFEDAQConfig::m_btt

private

Definition at line 67 of file ODFEDAQConfig.h.

Referenced by getBadTTId(), and setBadTTId().

int ODFEDAQConfig::m_bxt

private

Definition at line 66 of file ODFEDAQConfig.h.

Referenced by getBadXtId(), and setBadXtId().

std::string ODFEDAQConfig::m_com

private

Definition at line 71 of file ODFEDAQConfig.h.

Referenced by getComment(), and setComment().

int ODFEDAQConfig::m_del

private

Definition at line 63 of file ODFEDAQConfig.h.

Referenced by getDelayId(), and setDelayId().

int ODFEDAQConfig::m_ID

private

Definition at line 61 of file ODFEDAQConfig.h.

Referenced by getId(), and setId().

int ODFEDAQConfig::m_ped

private

Definition at line 62 of file ODFEDAQConfig.h.

Referenced by getPedestalId(), and setPedestalId().

int ODFEDAQConfig::m_tbtt

private

Definition at line 69 of file ODFEDAQConfig.h.

Referenced by getTriggerBadTTId(), and setTriggerBadTTId().

int ODFEDAQConfig::m_tbxt

private

Definition at line 68 of file ODFEDAQConfig.h.

Referenced by getTriggerBadXtId(), and setTriggerBadXtId().

int ODFEDAQConfig::m_version

private

Definition at line 70 of file ODFEDAQConfig.h.

Referenced by getVersion(), and setVersion().

int ODFEDAQConfig::m_wei

private

Definition at line 64 of file ODFEDAQConfig.h.

Referenced by getWeightId(), and setWeightId().