IODConfig Class Reference

#include <IODConfig.h>

Inheritance diagram for IODConfig:

Public Types
typedef oracle::occi::Clob	Clob
typedef oracle::occi::SQLException	SQLException
typedef oracle::occi::Statement	Statement
typedef oracle::occi::Stream	Stream

Public Member Functions
std::string	getConfigTag ()
virtual std::string	getTable ()=0
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 ()

Public Attributes
std::string	m_config_tag

Protected Member Functions
void	checkPrepare () noexcept(false)
void	createReadStatement () noexcept(false)
void	populateClob (Clob &clob, std::string fname, unsigned int bufsize) noexcept(false)
virtual void	prepareWrite () noexcept(false)=0
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
Statement *	m_readStmt
Statement *	m_writeStmt
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Additional Inherited Members
Static Public Attributes inherited from IDBObject
static int const	ECALDB_NROWS =1024

Detailed Description

Abstract interface for data in the conditions DB

Definition at line 19 of file IODConfig.h.

Member Typedef Documentation

typedef oracle::occi::Clob IODConfig::Clob

Definition at line 25 of file IODConfig.h.

typedef oracle::occi::SQLException IODConfig::SQLException

Definition at line 22 of file IODConfig.h.

typedef oracle::occi::Statement IODConfig::Statement

Definition at line 23 of file IODConfig.h.

typedef oracle::occi::Stream IODConfig::Stream

Definition at line 24 of file IODConfig.h.

Member Function Documentation

void IODConfig::checkPrepare ( )

inlineprotectednoexcept

Definition at line 39 of file IODConfig.h.

    {
      if (m_writeStmt == nullptr) {
    throw(std::runtime_error("Write statement not prepared"));
      }
    }

void IODConfig::createReadStatement ( )

inlineprotectednoexcept

Definition at line 56 of file IODConfig.h.

References IDBObject::m_conn.

  {
      m_readStmt=m_conn->createStatement();
  }

std::string IODConfig::getConfigTag ( )

inline

Definition at line 32 of file IODConfig.h.

References m_config_tag.

{return m_config_tag;}

virtual std::string IODConfig::getTable ( )

pure virtual

Implemented in FEConfigMainInfo, ODSRPConfig, ODDCCConfig, ODDCUConfig, ODLaserConfig, ODLTCConfig, ODRunConfigCycleInfo, ODRunConfigSeqInfo, ODTCCConfig, ODTCCEEConfig, ODTTCciConfig, ODTTCFConfig, ODLTCCycle, ODScanCycle, FEConfigFgrInfo, FEConfigLinInfo, FEConfigLUTInfo, FEConfigPedInfo, FEConfigSlidingInfo, FEConfigSpikeInfo, FEConfigTimingInfo, FEConfigWeightInfo, ODCCSCycle, ODCond2ConfInfo, ODDCCCycle, ODDCUCycle, ODJBH4Cycle, ODLaserCycle, ODLTSCycle, ODSRPCycle, ODTCCCycle, ODTCCEECycle, ODTTCciCycle, ODTTCFCycle, ODWeightsDat, ODWeightsSamplesDat, ODGolBiasCurrentDat, ODPedestalOffsetsDat, ODRunConfigInfo, ODTowersToByPassDat, ODVfeToRejectDat, FEConfigBadStripDat, FEConfigBadTTDat, FEConfigBadXTDat, ODBadTTDat, ODBadXTDat, ODDelaysDat, ODEcalCycle, FEConfigBadStripInfo, FEConfigBadTTInfo, FEConfigBadXTInfo, ODBadTTInfo, ODBadXTInfo, ODCCSConfig, ODFEDAQConfig, ODFEDelaysInfo, ODFEPedestalOffsetInfo, ODFEWeightsInfo, ODGolBiasCurrentInfo, ODJBH4Config, ODLTSConfig, ODScanConfig, ODTowersToByPassInfo, and ODVfeToRejectInfo.

void IODConfig::populateClob ( Clob &  clob, std::string  fname, unsigned int  bufsize  )

inlineprotectednoexcept

Definition at line 83 of file IODConfig.h.

References edmScanValgrind::buffer, gather_cfg::cout, MillePedeFileConverter_cfg::e, end, FrontierConditions_GlobalTag_cff::file, alignmentValidation::fname, recoMuon::in, findQualityFiles::size, and AlCaHLTBitMon_QueryRunRegistry::string.

{

  try{
      // Uses stream here
      std::cout << "Populating the Clob using writeBuffer(Stream) method" << std::endl;
      std::cout<<"we are here0"<<std::endl; 

      const char *file = fname.c_str();
      std::cout<<"we are here0.5 file is:"<<fname<<std::endl; 

      std::ifstream inFile;
      inFile.open(file,std::ios::in);
      if (!inFile)
    {
          std::cout << fname <<" file not found\n";
      inFile.close();

      std::string fname2="/nfshome0/ecaldev/francesca/null_file.txt";
      inFile.open(fname2.c_str(),std::ios::in);
      

          
    }
      if(bufsize==0){


    inFile.seekg( 0,std::ios::end ); 
    bufsize = inFile.tellg(); 
    std::cout <<" bufsize ="<<bufsize<< std::endl;
    // set file pointer to start again 
    inFile.seekg( 0,std::ios::beg ); 
    
      }

      char *buffer = new char[bufsize + 1];


      std::cout<<"we are here1"<<std::endl; 
      unsigned int size;
      Stream *strm=clob.getStream();
      std::cout<<"we are here2"<<std::endl; 
      //    while(inFile)
      //    {
      int buf=0;
      memset (buffer, buf, bufsize + 1);
      inFile.read(buffer,bufsize);
      std::cout<<"we are here2.5"<<std::endl; 
      
      strm->writeBuffer(buffer,strlen(buffer));
      std::cout<<"we are here2.6"<<std::endl; 

      //}
      std::cout<<"we are here3"<<std::endl; 
      strcpy(buffer," ");
      size=strlen(buffer);
      strm->writeLastBuffer(buffer,size);
      clob.closeStream(strm);
      inFile.close();
      std::cout<<"we are here4"<<std::endl; 
      delete[] buffer;


  }catch (SQLException &e) {
    throw(std::runtime_error(std::string("populateClob():  ")+e.getMessage()));
  }

  std::cout << "Populating the Clob - Success" << std::endl;
}

virtual void IODConfig::prepareWrite ( )

protectedpure virtualnoexcept

Implemented in ODLaserConfig, FEConfigMainInfo, ODRunConfigInfo, ODCCSConfig, ODEcalCycle, ODRunConfigSeqInfo, ODRunConfigCycleInfo, ODSRPConfig, FEConfigFgrInfo, FEConfigLinInfo, FEConfigLUTInfo, FEConfigPedInfo, FEConfigSlidingInfo, FEConfigWeightInfo, ODTCCEEConfig, ODWeightsDat, FEConfigSpikeInfo, FEConfigTimingInfo, ODTCCConfig, ODCond2ConfInfo, ODDCCConfig, ODFEDAQConfig, ODJBH4Config, ODTTCciConfig, ODPedestalOffsetsDat, ODGolBiasCurrentDat, ODTTCFConfig, ODTowersToByPassDat, ODVfeToRejectDat, FEConfigBadStripDat, FEConfigBadXTDat, ODBadTTDat, ODBadXTDat, ODCCSCycle, ODLTCConfig, ODLTCCycle, ODScanConfig, ODScanCycle, ODDCCCycle, ODDCUCycle, ODJBH4Cycle, ODLaserCycle, ODLTSCycle, ODSRPCycle, ODTCCCycle, ODTCCEECycle, ODTTCciCycle, ODTTCFCycle, ODWeightsSamplesDat, FEConfigBadTTDat, ODDelaysDat, ODLTSConfig, FEConfigBadStripInfo, FEConfigBadTTInfo, FEConfigBadXTInfo, ODBadTTInfo, ODBadXTInfo, ODFEDelaysInfo, ODFEPedestalOffsetInfo, ODFEWeightsInfo, ODGolBiasCurrentInfo, ODTowersToByPassInfo, ODVfeToRejectInfo, and ODDCUConfig.

Referenced by terminateReadStatement().

unsigned char* IODConfig::readClob ( Clob &  clob, int  size  )

inlineprotectednoexcept

Definition at line 154 of file IODConfig.h.

References edmScanValgrind::buffer, gather_cfg::cout, MillePedeFileConverter_cfg::e, mps_fire::i, findQualityFiles::size, and AlCaHLTBitMon_QueryRunRegistry::string.

{

  try{
    Stream *instream = clob.getStream (1,0);
    unsigned char *buffer= new unsigned char[size]; 
    int buf=0;
    memset (buffer, buf, size);
    
    instream->readBuffer ((char*)buffer, size);
    std::cout << "remember to delete the char* at the end of the program ";
       for (int i = 0; i < size; ++i)
       std::cout << (char) buffer[i];
     std::cout << std::endl;
    

    clob.closeStream (instream);

    return  buffer;

  }catch (SQLException &e) {
    throw(std::runtime_error(std::string("readClob():  ")+e.getMessage()));
  }

}

void IODConfig::setConfigTag ( std::string  x )

inline

Definition at line 31 of file IODConfig.h.

References x.

Referenced by EcalTPGParamBuilder::analyze(), popcon::EcalTPGWeightIdMapHandler::getNewObjects(), popcon::EcalTPGFineGrainEBIdMapHandler::getNewObjects(), popcon::EcalTPGLinConstHandler::getNewObjects(), popcon::EcalTPGLutIdMapHandler::getNewObjects(), popcon::EcalTPGPhysicsConstHandler::getNewObjects(), popcon::EcalTPGWeightGroupHandler::getNewObjects(), popcon::EcalTPGBadStripHandler::getNewObjects(), popcon::EcalTPGBadTTHandler::getNewObjects(), popcon::EcalTPGBadXTHandler::getNewObjects(), popcon::EcalTPGFineGrainTowerEEHandler::getNewObjects(), popcon::EcalTPGFineGrainEBGroupHandler::getNewObjects(), popcon::EcalTPGFineGrainStripEEHandler::getNewObjects(), popcon::EcalTPGPedestalsHandler::getNewObjects(), popcon::EcalTPGSlidingWindowHandler::getNewObjects(), popcon::EcalTPGLutGroupHandler::getNewObjects(), popcon::EcalTPGSpikeThresholdHandler::getNewObjects(), EcalTPGDBApp::writeToConfDB_Delay(), EcalTPGDBApp::writeToConfDB_Spike(), EcalTPGDBApp::writeToConfDB_TPGFgr(), EcalTPGDBApp::writeToConfDB_TPGLinearCoef(), EcalTPGDBApp::writeToConfDB_TPGLUT(), EcalTPGDBApp::writeToConfDB_TPGMain(), EcalTPGDBApp::writeToConfDB_TPGPedestals(), EcalTPGDBApp::writeToConfDB_TPGSliding(), EcalTPGDBApp::writeToConfDB_TPGWeight(), and EcalDccWeightBuilder::writeWeightToDB().

{m_config_tag=x;}

void IODConfig::setPrefetchRowCount ( int  ncount )

inlineprotectednoexcept

Definition at line 61 of file IODConfig.h.

  {
    m_readStmt->setPrefetchRowCount(ncount);
  }

void IODConfig::terminateReadStatement ( )

inlineprotectednoexcept

Definition at line 66 of file IODConfig.h.

References gather_cfg::cout, IDBObject::m_conn, noexcept, and prepareWrite().

  {
    if (m_readStmt != nullptr) {
      m_conn->terminateStatement(m_readStmt);
    } else {
      std::cout << "Warning from IDataItem: statement was aleady closed"<< std::endl;
    }
  }

void IODConfig::terminateWriteStatement ( )

inlineprotectednoexcept

Definition at line 46 of file IODConfig.h.

References gather_cfg::cout, and IDBObject::m_conn.

  {
    if (m_writeStmt != nullptr) {
      m_conn->terminateStatement(m_writeStmt);
    } else {
      std::cout << "Warning from IDataItem: statement was aleady closed"<< std::endl;
    }
  }

Member Data Documentation

std::string IODConfig::m_config_tag

Definition at line 27 of file IODConfig.h.

Referenced by getConfigTag().

Statement* IODConfig::m_readStmt

protected

Definition at line 37 of file IODConfig.h.

Statement* IODConfig::m_writeStmt

protected

Definition at line 36 of file IODConfig.h.