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 18 of file IODConfig.h.

Member Typedef Documentation

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

Definition at line 23 of file IODConfig.h.

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

Definition at line 20 of file IODConfig.h.

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

Definition at line 21 of file IODConfig.h.

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

Definition at line 22 of file IODConfig.h.

Member Function Documentation

void IODConfig::checkPrepare ( )

inlineprotectednoexcept

Definition at line 36 of file IODConfig.h.

References m_writeStmt.

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

void IODConfig::createReadStatement ( )

inlineprotectednoexcept

Definition at line 50 of file IODConfig.h.

References IDBObject::m_conn, and m_readStmt.

{ m_readStmt = m_conn->createStatement(); }

std::string IODConfig::getConfigTag ( )

inline

Definition at line 30 of file IODConfig.h.

References m_config_tag.

{ return m_config_tag; }

virtual std::string IODConfig::getTable ( )

pure virtual

Implemented in ODSRPConfig, ODDCCConfig, ODDCUConfig, ODLaserConfig, ODLTCConfig, ODRunConfigSeqInfo, ODTCCConfig, ODTCCEEConfig, ODTTCciConfig, ODTTCFConfig, FEConfigMainInfo, ODRunConfigCycleInfo, FEConfigCokeInfo, FEConfigFgrInfo, FEConfigLinInfo, FEConfigLUTInfo, FEConfigOddWeightInfo, FEConfigPedInfo, FEConfigSlidingInfo, FEConfigSpikeInfo, FEConfigTimingInfo, FEConfigWeightInfo, ODCond2ConfInfo, ODWeightsDat, ODWeightsSamplesDat, ODGolBiasCurrentDat, ODPedestalOffsetsDat, ODRunConfigInfo, ODTowersToByPassDat, ODVfeToRejectDat, FEConfigBadStripDat, FEConfigBadTTDat, FEConfigBadXTDat, ODBadTTDat, ODBadXTDat, ODCCSCycle, ODDCCCycle, ODDCUCycle, ODDelaysDat, ODEcalCycle, ODJBH4Cycle, ODLaserCycle, ODLTCCycle, ODLTSCycle, ODScanCycle, ODSRPCycle, ODTCCCycle, ODTCCEECycle, ODTTCciCycle, ODTTCFCycle, 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 67 of file IODConfig.h.

References visDQMUpload::buf, edmScanValgrind::buffer, gather_cfg::cout, alignCSCRings::e, dataset::end, mergeVDriftHistosByStation::file, 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, ODSRPConfig, ODWeightsDat, ODTCCEEConfig, FEConfigFgrInfo, FEConfigLinInfo, FEConfigLUTInfo, FEConfigOddWeightInfo, FEConfigPedInfo, FEConfigSlidingInfo, FEConfigWeightInfo, ODRunConfigCycleInfo, FEConfigSpikeInfo, ODCond2ConfInfo, ODDCCConfig, ODTCCConfig, FEConfigCokeInfo, FEConfigTimingInfo, ODFEDAQConfig, ODTTCciConfig, ODJBH4Config, ODPedestalOffsetsDat, ODTTCFConfig, ODGolBiasCurrentDat, ODLTCConfig, ODTowersToByPassDat, ODVfeToRejectDat, FEConfigBadStripDat, FEConfigBadXTDat, ODBadTTDat, ODBadXTDat, ODScanConfig, ODLTSConfig, FEConfigBadTTDat, ODCCSCycle, ODDCCCycle, ODDCUCycle, ODDelaysDat, ODJBH4Cycle, ODLaserCycle, ODLTCCycle, ODLTSCycle, ODScanCycle, ODSRPCycle, ODTCCCycle, ODTCCEECycle, ODTTCciCycle, ODTTCFCycle, ODWeightsSamplesDat, FEConfigBadStripInfo, FEConfigBadTTInfo, FEConfigBadXTInfo, ODBadTTInfo, ODBadXTInfo, ODFEDelaysInfo, ODFEPedestalOffsetInfo, ODFEWeightsInfo, ODGolBiasCurrentInfo, ODTowersToByPassInfo, ODVfeToRejectInfo, and ODDCUConfig.

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

inlineprotectednoexcept

Definition at line 124 of file IODConfig.h.

References visDQMUpload::buf, edmScanValgrind::buffer, gather_cfg::cout, alignCSCRings::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 29 of file IODConfig.h.

References m_config_tag, and x.

Referenced by EcalTPGParamBuilder::analyze(), popcon::EcalTPGFineGrainEBIdMapHandler::getNewObjects(), popcon::EcalTPGLinConstHandler::getNewObjects(), popcon::EcalTPGLutIdMapHandler::getNewObjects(), popcon::EcalTPGBadStripHandler::getNewObjects(), popcon::EcalTPGOddWeightIdMapHandler::getNewObjects(), popcon::EcalTPGPhysicsConstHandler::getNewObjects(), popcon::EcalTPGBadTTHandler::getNewObjects(), popcon::EcalTPGTPModeHandler::getNewObjects(), popcon::EcalTPGWeightIdMapHandler::getNewObjects(), popcon::EcalTPGBadXTHandler::getNewObjects(), popcon::EcalTPGFineGrainEBGroupHandler::getNewObjects(), popcon::EcalTPGFineGrainTowerEEHandler::getNewObjects(), popcon::EcalTPGWeightGroupHandler::getNewObjects(), popcon::EcalTPGOddWeightGroupHandler::getNewObjects(), popcon::EcalTPGSlidingWindowHandler::getNewObjects(), popcon::EcalTPGFineGrainStripEEHandler::getNewObjects(), popcon::EcalTPGPedestalsHandler::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(), EcalTPGDBApp::writeToConfDB_TPGWeight_doubleWeights(), and EcalDccWeightBuilder::writeWeightToDB().

{ m_config_tag = x; }

void IODConfig::setPrefetchRowCount ( int  ncount )

inlineprotectednoexcept

Definition at line 52 of file IODConfig.h.

References m_readStmt.

{ m_readStmt->setPrefetchRowCount(ncount); }

void IODConfig::terminateReadStatement ( )

inlineprotectednoexcept

Definition at line 54 of file IODConfig.h.

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

                                                       {
    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 42 of file IODConfig.h.

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

                                                        {
    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 25 of file IODConfig.h.

Referenced by getConfigTag(), and setConfigTag().

Statement* IODConfig::m_readStmt

protected

Definition at line 34 of file IODConfig.h.

Referenced by createReadStatement(), setPrefetchRowCount(), and terminateReadStatement().

Statement* IODConfig::m_writeStmt

protected

Definition at line 33 of file IODConfig.h.

Referenced by checkPrepare(), and terminateWriteStatement().