MODCCSHFDat Class Reference

#include <MODCCSHFDat.h>

Inheritance diagram for MODCCSHFDat:

Public Types
typedef oracle::occi::Clob	Clob

Public Member Functions
unsigned char *	getClob () const
std::string	getFile () const
unsigned int	getSize () const
std::string	getTable () override
int	getTest () const
	MODCCSHFDat ()
void	setClob (unsigned char *x)
void	setFile (std::string x)
void	setSize (unsigned int id)
void	setTest (int id)
	~MODCCSHFDat () override
Public Member Functions inherited from IDataItem
	IDataItem ()
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	fetchData (std::map< EcalLogicID, MODCCSHFDat > *fillMap, MODRunIOV *iov) noexcept(false)
void	populateClob (Clob &clob, std::string fname, unsigned int clob_size) noexcept(false)
void	prepareWrite () noexcept(false) override
unsigned char *	readClob (Clob &clob, int size) noexcept(false)
void	writeArrayDB (const std::map< EcalLogicID, MODCCSHFDat > *data, MODRunIOV *iov) noexcept(false)
void	writeDB (const EcalLogicID *ecid, const MODCCSHFDat *item, MODRunIOV *iov) noexcept(false)

Private Attributes
unsigned char *	m_clob
std::string	m_file
unsigned int	m_size
int	testing

Friends
class	EcalCondDBInterface

Additional Inherited Members
Static Public Attributes inherited from IDBObject
static int const	ECALDB_NROWS =1024
Protected Member Functions inherited from IDataItem
void	checkPrepare () noexcept(false)
void	createReadStatement () 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 IDataItem
oracle::occi::Statement *	m_readStmt
oracle::occi::Statement *	m_writeStmt
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Detailed Description

Definition at line 19 of file MODCCSHFDat.h.

Member Typedef Documentation

typedef oracle::occi::Clob MODCCSHFDat::Clob

Definition at line 21 of file MODCCSHFDat.h.

Constructor & Destructor Documentation

MODCCSHFDat::MODCCSHFDat

(

)

Definition at line 17 of file MODCCSHFDat.cc.

{
  m_env = nullptr;
  m_conn = nullptr;
  m_writeStmt = nullptr;
  m_readStmt = nullptr;

  //  m_clob = 0;
  m_size=0;
  m_file="";

}

MODCCSHFDat::~MODCCSHFDat ( )

override

Definition at line 32 of file MODCCSHFDat.cc.

{
}

Member Function Documentation

void MODCCSHFDat::fetchData ( std::map< EcalLogicID, MODCCSHFDat > *  fillMap, MODRunIOV *  iov  )

privatenoexcept

Definition at line 142 of file MODCCSHFDat.cc.

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

Referenced by getFile().

{
  this->checkConnection();
  fillMap->clear();

  iov->setConnection(m_env, m_conn);
  int iovID = iov->fetchID();
  if (!iovID) { 
    //  throw(std::runtime_error("MODCCSHFDat::writeDB:  IOV not in DB")); 
    return;
  }

  try {

    m_readStmt->setSQL("SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
         " d.ccs_log " 
         "FROM channelview cv JOIN OD_CCS_HF_dat d "
         "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
         "WHERE d.iov_id = :iov_id");
    m_readStmt->setInt(1, iovID);
    ResultSet* rset = m_readStmt->executeQuery();
    
    std::pair< EcalLogicID, MODCCSHFDat > p;
    MODCCSHFDat dat;
    while(rset->next()) {
      p.first = EcalLogicID( getOraString(rset,1),     // name
                 rset->getInt(2),        // logic_id
                 rset->getInt(3),        // id1
                 rset->getInt(4),        // id2
                 rset->getInt(5),        // id3
                 getOraString(rset,6));    // maps_to
      // to be corrected 
      //      dat.setClob( getOraString(rset,7) );

      p.second = dat;
      fillMap->insert(p);
    }
  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("MODCCSHFDat::fetchData():  ")+getOraMessage(&e)));
  }
}

unsigned char* MODCCSHFDat::getClob ( ) const

inline

Definition at line 30 of file MODCCSHFDat.h.

References m_clob.

{ return m_clob; }

std::string MODCCSHFDat::getFile ( ) const

inline

Definition at line 39 of file MODCCSHFDat.h.

References data, fetchData(), m_file, noexcept, prepareWrite(), writeArrayDB(), and writeDB().

{ return m_file; }

unsigned int MODCCSHFDat::getSize ( ) const

inline

Definition at line 33 of file MODCCSHFDat.h.

References m_size.

{ return m_size; }

std::string MODCCSHFDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 27 of file MODCCSHFDat.h.

{ return "OD_CCS_HF_DAT"; }

int MODCCSHFDat::getTest ( ) const

inline

Definition at line 36 of file MODCCSHFDat.h.

References setFile(), AlCaHLTBitMon_QueryRunRegistry::string, testing, and x.

{ return testing; }

void MODCCSHFDat::populateClob ( Clob &  clob, std::string  fname, unsigned int  clob_size  )

privatenoexcept

Definition at line 258 of file MODCCSHFDat.cc.

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

{

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

      std::cout<<"we are here0.5 file is:"<<fname<<std::endl; 

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

      std::string fname2="/u1/fra/null_file.txt";
      inFile.open(fname2.c_str(),ios::in);
      

          
    }
      if(clob_size==0){


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

      char *buffer = new char[clob_size + 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, clob_size + 1);
      inFile.read(buffer,clob_size);
      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():  ")+getOraMessage(&e)));
  }

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

void MODCCSHFDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 61 of file MODCCSHFDat.cc.

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

Referenced by getFile().

{
  this->checkConnection();

  try {
    m_writeStmt = m_conn->createStatement();
    m_writeStmt->setSQL("INSERT INTO OD_CCS_HF_dat (iov_id, logic_id, "
            "ccs_log) "
            "VALUES (:iov_id, :logic_id, "
            ":ccs_log )");


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

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

privatenoexcept

Definition at line 329 of file MODCCSHFDat.cc.

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);
    cout << "remember to delete the char* at the end of the program ";
       for (int i = 0; i < size; ++i)
       cout << (char) buffer[i];
     cout << endl;
    

    clob.closeStream (instream);

    return  buffer;

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

}

void MODCCSHFDat::setClob ( unsigned char *  x )

inline

Definition at line 29 of file MODCCSHFDat.h.

References m_clob, and x.

{ m_clob = x; }

void MODCCSHFDat::setFile

(

std::string

x

)

Definition at line 37 of file MODCCSHFDat.cc.

References gather_cfg::cout, end, and x.

Referenced by getTest().

                                     {
  m_file=x;
  //try {
  std::cout<< "file is "<< m_file<<endl;
  // }catch (Exception &e) {
  //throw(std::runtime_error(std::string("MODCCSHFDat::setFile():  ")+getOraMessage(&e)));
  //} 
    // here we must open the file and read the CCS Clob
    std::cout << "Going to read CCS file: " << m_file << endl;
    ifstream inpFile;
    inpFile.open(m_file.c_str());
    // tell me size of file
    int bufsize = 0;
    inpFile.seekg( 0,ios::end );
    bufsize = inpFile.tellg();
    std::cout <<" bufsize ="<<bufsize<< std::endl;
    // set file pointer to start again
    inpFile.seekg( 0,ios::beg );
    m_size=bufsize;
    inpFile.close();
    std::cout << "Going to read CCS file: " << m_file << endl;

}

void MODCCSHFDat::setSize ( unsigned int  id )

inline

Definition at line 32 of file MODCCSHFDat.h.

References triggerObjects_cff::id, and m_size.

{ m_size = id; }

void MODCCSHFDat::setTest ( int  id )

inline

Definition at line 35 of file MODCCSHFDat.h.

References triggerObjects_cff::id, and testing.

{ testing = id; }

void MODCCSHFDat::writeArrayDB ( const std::map< EcalLogicID, MODCCSHFDat > *  data, MODRunIOV *  iov  )

privatenoexcept

Definition at line 185 of file MODCCSHFDat.cc.

References KineDebug3::count(), data, MillePedeFileConverter_cfg::e, EcalLogicID::getLogicID(), electrons_cff::ids, AlCaHLTBitMon_ParallelJobs::p, AlCaHLTBitMon_QueryRunRegistry::string, x, and geometryCSVtoXML::xx.

Referenced by getFile().

{
  this->checkConnection();
  this->checkPrepare();

  int iovID = iov->fetchID();
  if (!iovID) { throw(std::runtime_error("MODCCSHFDat::writeArrayDB:  IOV not in DB")); }


  int nrows=data->size(); 
  int* ids= new int[nrows];
  int* iovid_vec= new int[nrows];
  int* xx= new int[nrows];

  ub2* ids_len= new ub2[nrows];
  ub2* iov_len= new ub2[nrows];
  ub2* x_len= new ub2[nrows];

  const EcalLogicID* channel;
  //const MODCCSHFDat* dataitem;
  int count=0;
  typedef map< EcalLogicID, MODCCSHFDat >::const_iterator CI;
  for (CI p = data->begin(); p != data->end(); ++p) {
        channel = &(p->first);
    int logicID = channel->getLogicID();
    if (!logicID) { throw(std::runtime_error("MODCCSHFDat::writeArrayDB:  Bad EcalLogicID")); }
    ids[count]=logicID;
    iovid_vec[count]=iovID;

    // dataitem = &(p->second);
    // dataIface.writeDB( channel, dataitem, iov);
    // to be corrected 

    int x=0;
    //=dataitem->getWord();

    xx[count]=x;

    ids_len[count]=sizeof(ids[count]);
    iov_len[count]=sizeof(iovid_vec[count]);
    
    x_len[count]=sizeof(xx[count]);

    count++;
     }


  try {
    m_writeStmt->setDataBuffer(1, (dvoid*)iovid_vec, OCCIINT, sizeof(iovid_vec[0]),iov_len);
    m_writeStmt->setDataBuffer(2, (dvoid*)ids, OCCIINT, sizeof(ids[0]), ids_len );
    m_writeStmt->setDataBuffer(3, (dvoid*)xx, OCCIINT , sizeof(xx[0]), x_len );

    m_writeStmt->executeArrayUpdate(nrows);

    delete [] ids;
    delete [] iovid_vec;
    delete [] xx;


    delete [] ids_len;
    delete [] iov_len;
    delete [] x_len;



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

void MODCCSHFDat::writeDB ( const EcalLogicID *  ecid, const MODCCSHFDat *  item, MODRunIOV *  iov  )

privatenoexcept

Definition at line 81 of file MODCCSHFDat.cc.

References gather_cfg::cout, MillePedeFileConverter_cfg::e, alignmentValidation::fname, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getFile().

{



  this->checkConnection();
  this->checkPrepare();

  int iovID = iov->fetchID();
  if (!iovID) { throw(std::runtime_error("MODCCSHFDat::writeDB:  IOV not in DB")); }

  int logicID = ecid->getLogicID();
  if (!logicID) { throw(std::runtime_error("MODCCSHFDat::writeDB:  Bad EcalLogicID")); }
  
  std::string fname=item->getFile();
  std::cout << "Going to read CCS file: " << fname << endl;


  try {

    m_writeStmt->setInt(1, iovID);
    m_writeStmt->setInt(2, logicID);

    // and now the clob
    oracle::occi::Clob clob(m_conn);
    clob.setEmpty();
    m_writeStmt->setClob(3,clob);
    m_writeStmt->executeUpdate ();

    m_conn->terminateStatement(m_writeStmt);
    std::cout<<"empty CCS Clob inserted into DB" <<std::endl;

    // now we read and update it
    m_writeStmt = m_conn->createStatement();
    m_writeStmt->setSQL ("SELECT CCS_LOG FROM OD_CCS_HF_DAT WHERE"
                         " iov_ID=:1 and logic_ID=:2 FOR UPDATE");
    m_writeStmt->setInt(1, iovID);
    m_writeStmt->setInt(2, logicID);
    ResultSet* rset = m_writeStmt->executeQuery();
    rset->next ();
    oracle::occi::Clob clob2 = rset->getClob (1);
    cout << "Opening the clob in read write mode" << endl;

    unsigned int clob_size=item->getSize();

    populateClob (clob2 , fname, clob_size);

    int clobLength=clob2.length ();
    cout << "Length of the clob is: " << clobLength << endl;

    m_writeStmt->executeUpdate();
    m_writeStmt->closeResultSet (rset);

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

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 22 of file MODCCSHFDat.h.

Member Data Documentation

unsigned char* MODCCSHFDat::m_clob

private

Definition at line 55 of file MODCCSHFDat.h.

Referenced by getClob(), and setClob().

std::string MODCCSHFDat::m_file

private

Definition at line 57 of file MODCCSHFDat.h.

Referenced by getFile().

unsigned int MODCCSHFDat::m_size

private

Definition at line 56 of file MODCCSHFDat.h.

Referenced by getSize(), and setSize().

int MODCCSHFDat::testing

private

Definition at line 58 of file MODCCSHFDat.h.

Referenced by getTest(), and setTest().