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 16 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 27 of file MODCCSHFDat.cc.

{}

Member Function Documentation

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

privatenoexcept

Definition at line 125 of file MODCCSHFDat.cc.

References dat, alignCSCRings::e, AlCaHLTBitMon_ParallelJobs::p, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                     {
  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(rset->getString(1),   // name
                            rset->getInt(2),      // logic_id
                            rset->getInt(3),      // id1
                            rset->getInt(4),      // id2
                            rset->getInt(5),      // id3
                            rset->getString(6));  // maps_to
      // to be corrected
      //      dat.setClob( rset->getString(7) );

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

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 m_file.

{ 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 testing.

{ return testing; }

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

privatenoexcept

Definition at line 234 of file MODCCSHFDat.cc.

References visDQMUpload::buf, edmScanValgrind::buffer, gather_cfg::cout, alignCSCRings::e, dataset::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():  ") + e.getMessage()));
  }

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

void MODCCSHFDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 52 of file MODCCSHFDat.cc.

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

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

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

privatenoexcept

Definition at line 292 of file MODCCSHFDat.cc.

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

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 29 of file MODCCSHFDat.cc.

References gather_cfg::cout, dataset::end, and x.

                                     {
  m_file = x;
  //try {
  std::cout << "file is " << m_file << endl;
  // }catch (Exception &e) {
  //throw(std::runtime_error(std::string("MODCCSHFDat::setFile():  ")+e.getMessage()));
  //}
  // 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 gpuClustering::id, and m_size.

{ m_size = id; }

void MODCCSHFDat::setTest ( int  id )

inline

Definition at line 35 of file MODCCSHFDat.h.

References gpuClustering::id, and testing.

{ testing = id; }

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

privatenoexcept

Definition at line 166 of file MODCCSHFDat.cc.

References submitPVResolutionJobs::count, data, alignCSCRings::e, EcalLogicID::getLogicID(), AlCaHLTBitMon_ParallelJobs::p, AlCaHLTBitMon_QueryRunRegistry::string, and x.

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

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

privatenoexcept

Definition at line 68 of file MODCCSHFDat.cc.

References gather_cfg::cout, alignCSCRings::e, alignmentValidation::fname, B2GTnPMonitor_cfi::item, and AlCaHLTBitMon_QueryRunRegistry::string.

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

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 51 of file MODCCSHFDat.h.

Referenced by getClob(), and setClob().

std::string MODCCSHFDat::m_file

private

Definition at line 53 of file MODCCSHFDat.h.

Referenced by getFile().

unsigned int MODCCSHFDat::m_size

private

Definition at line 52 of file MODCCSHFDat.h.

Referenced by getSize(), and setSize().

int MODCCSHFDat::testing

private

Definition at line 54 of file MODCCSHFDat.h.

Referenced by getTest(), and setTest().