FEConfigLUTGroupDat Class Reference

#include <FEConfigLUTGroupDat.h>

Inheritance diagram for FEConfigLUTGroupDat:

Public Member Functions
	FEConfigLUTGroupDat ()
int	getLUTGroupId () const
int	getLUTValue (int i) const
std::string	getTable () override
void	setLUTGroupId (int x)
void	setLUTValue (int i, int x)
	~FEConfigLUTGroupDat () 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, FEConfigLUTGroupDat > *fillMap, FEConfigLUTInfo *iconf) noexcept(false)
void	prepareWrite () noexcept(false) override
void	writeArrayDB (const std::map< EcalLogicID, FEConfigLUTGroupDat > *data, FEConfigLUTInfo *iconf) noexcept(false)
void	writeDB (const EcalLogicID *ecid, const FEConfigLUTGroupDat *item, FEConfigLUTInfo *iconf) noexcept(false)

Private Attributes
int	m_group_id
int	m_lut [1024]

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 11 of file FEConfigLUTGroupDat.h.

Constructor & Destructor Documentation

FEConfigLUTGroupDat::FEConfigLUTGroupDat

(

)

Definition at line 11 of file FEConfigLUTGroupDat.cc.

References mps_fire::i.

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

  m_group_id = 0;
  for (int i = 0; i < 1024; i++) {
    m_lut[i] = 0;
  }
}

FEConfigLUTGroupDat::~FEConfigLUTGroupDat ( )

override

Definition at line 23 of file FEConfigLUTGroupDat.cc.

{}

Member Function Documentation

void FEConfigLUTGroupDat::fetchData ( std::map< EcalLogicID, FEConfigLUTGroupDat > *  fillMap, FEConfigLUTInfo *  iconf  )

privatenoexcept

Definition at line 105 of file FEConfigLUTGroupDat.cc.

References dat, alignCSCRings::e, AlCaHLTBitMon_ParallelJobs::p, setLUTGroupId(), setLUTValue(), and AlCaHLTBitMon_QueryRunRegistry::string.

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

  iconf->setConnection(m_env, m_conn);
  int iconfID = iconf->fetchID();
  if (!iconfID) {
    throw(std::runtime_error("FEConfigLUTGroupDat::fetchData:  ICONF not in DB"));
    return;
  }

  try {
    m_readStmt->setSQL(
        "SELECT d.group_id, d.lut_id, d.lut_value "
        "FROM fe_lut_per_group_dat d "
        "WHERE lut_conf_id = :lut_conf_id order by d.group_id, d.lut_id ");
    m_readStmt->setInt(1, iconfID);
    ResultSet* rset = m_readStmt->executeQuery();

    FEConfigLUTGroupDat dat;
    std::pair<EcalLogicID, FEConfigLUTGroupDat> p;

    int nrows = 1024;

    int igold = -1;
    int ig = igold;

    while (rset->next()) {
      ig = rset->getInt(1);
      int il = rset->getInt(2);
      int ival = rset->getInt(3);
      if (il == 0) {
        p.first = EcalLogicID("Group_id", ig);  // a dummy logic_id
        dat = FEConfigLUTGroupDat();
        dat.setLUTGroupId(ig);
        dat.setLUTValue(il, ival);
      } else {
        dat.setLUTValue(il, ival);
      }

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

int FEConfigLUTGroupDat::getLUTGroupId ( ) const

inline

Definition at line 21 of file FEConfigLUTGroupDat.h.

References m_group_id.

Referenced by popcon::EcalTPGLutIdMapHandler::getNewObjects(), and writeArrayDB().

{ return m_group_id; }

int FEConfigLUTGroupDat::getLUTValue ( int  i ) const

inline

Definition at line 24 of file FEConfigLUTGroupDat.h.

References mps_fire::i, and m_lut.

Referenced by popcon::EcalTPGLutIdMapHandler::getNewObjects(), and writeArrayDB().

{ return m_lut[i]; }

std::string FEConfigLUTGroupDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 18 of file FEConfigLUTGroupDat.h.

{ return "FE_CONFIG_LUT_PER_GROUP_DAT"; }

void FEConfigLUTGroupDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 25 of file FEConfigLUTGroupDat.cc.

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

                                                       {
  this->checkConnection();

  try {
    m_writeStmt = m_conn->createStatement();
    m_writeStmt->setSQL(
        "INSERT INTO fe_lut_per_group_dat (lut_conf_id, group_id, "
        " lut_id, lut_value ) "
        "VALUES (:lut_conf_id, :group_id, "
        ":lut_id, :lut_value )");
  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("FEConfigLUTGroupDat::prepareWrite():  ") + e.getMessage()));
  }
}

void FEConfigLUTGroupDat::setLUTGroupId ( int  x )

inline

Definition at line 20 of file FEConfigLUTGroupDat.h.

References m_group_id, and x.

Referenced by EcalTPGParamBuilder::analyze(), and fetchData().

{ m_group_id = x; }

void FEConfigLUTGroupDat::setLUTValue ( int  i, int  x  )

inline

Definition at line 23 of file FEConfigLUTGroupDat.h.

References mps_fire::i, m_lut, and x.

Referenced by EcalTPGParamBuilder::analyze(), and fetchData().

{ m_lut[i] = x; }

void FEConfigLUTGroupDat::writeArrayDB ( const std::map< EcalLogicID, FEConfigLUTGroupDat > *  data, FEConfigLUTInfo *  iconf  )

privatenoexcept

Definition at line 156 of file FEConfigLUTGroupDat.cc.

References submitPVResolutionJobs::count, gather_cfg::cout, data, alignCSCRings::e, getLUTGroupId(), getLUTValue(), mps_fire::i, AlCaHLTBitMon_ParallelJobs::p, AlCaHLTBitMon_QueryRunRegistry::string, x, y, and z.

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

  int iconfID = iconf->fetchID();
  if (!iconfID) {
    throw(std::runtime_error("FEConfigLUTGroupDat::writeArrayDB:  ICONF not in DB"));
  }

  int nrows = data->size() * 1024;

  int* iconfid_vec = new int[nrows];
  int* xx = new int[nrows];
  int* yy = new int[nrows];
  int* zz = new int[nrows];

  ub2* iconf_len = new ub2[nrows];
  ub2* x_len = new ub2[nrows];
  ub2* y_len = new ub2[nrows];
  ub2* z_len = new ub2[nrows];

  const FEConfigLUTGroupDat* dataitem;
  int count = 0;
  typedef map<EcalLogicID, FEConfigLUTGroupDat>::const_iterator CI;
  for (CI p = data->begin(); p != data->end(); ++p) {
    dataitem = &(p->second);
    int x = dataitem->getLUTGroupId();

    for (int i = 0; i < 1024; i++) {
      iconfid_vec[count] = iconfID;
      int y = i;
      int z = dataitem->getLUTValue(i);

      xx[count] = x;
      yy[count] = y;
      zz[count] = z;

      iconf_len[count] = sizeof(iconfid_vec[count]);

      x_len[count] = sizeof(xx[count]);
      y_len[count] = sizeof(yy[count]);
      z_len[count] = sizeof(zz[count]);

      count++;
    }
  }

  try {
    //    for (int i=0; i<nrows; i++){

    int i = 0;
    cout << "about to insert " << iconfid_vec[i] << " " << xx[i] << " " << yy[i] << " " << zz[i] << endl;
    i = nrows - 1;
    cout << "about to insert " << iconfid_vec[i] << " " << xx[i] << " " << yy[i] << " " << zz[i] << endl;
    // }
    m_writeStmt->setDataBuffer(1, (dvoid*)iconfid_vec, OCCIINT, sizeof(iconfid_vec[0]), iconf_len);
    m_writeStmt->setDataBuffer(2, (dvoid*)xx, OCCIINT, sizeof(xx[0]), x_len);
    m_writeStmt->setDataBuffer(3, (dvoid*)yy, OCCIINT, sizeof(yy[0]), y_len);
    m_writeStmt->setDataBuffer(4, (dvoid*)zz, OCCIINT, sizeof(zz[0]), z_len);

    m_writeStmt->executeArrayUpdate(nrows);

    delete[] iconfid_vec;
    delete[] xx;
    delete[] yy;
    delete[] zz;

    delete[] iconf_len;
    delete[] x_len;
    delete[] y_len;
    delete[] z_len;

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

void FEConfigLUTGroupDat::writeDB ( const EcalLogicID *  ecid, const FEConfigLUTGroupDat *  item, FEConfigLUTInfo *  iconf  )

privatenoexcept

Definition at line 40 of file FEConfigLUTGroupDat.cc.

References submitPVResolutionJobs::count, gather_cfg::cout, alignCSCRings::e, B2GTnPMonitor_cfi::item, AlCaHLTBitMon_QueryRunRegistry::string, x, y, and z.

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

  int iconfID = iconf->fetchID();

  cout << "iconf=" << iconfID << endl;

  if (!iconfID) {
    throw(std::runtime_error("FEConfigLUTGroupDat::writeArrayDB:  ICONF not in DB"));
  }

  int nrows = 1024;
  int* iconfid_vec = new int[nrows];
  int* xx = new int[nrows];
  int* yy = new int[nrows];
  int* zz = new int[nrows];

  ub2* iconf_len = new ub2[nrows];
  ub2* x_len = new ub2[nrows];
  ub2* y_len = new ub2[nrows];
  ub2* z_len = new ub2[nrows];

  for (int count = 0; count < nrows; count++) {
    iconfid_vec[count] = iconfID;
    int x = item->getLUTGroupId();
    int y = count;
    int z = m_lut[count];

    xx[count] = x;
    yy[count] = y;
    zz[count] = z;

    iconf_len[count] = sizeof(iconfid_vec[count]);

    x_len[count] = sizeof(xx[count]);
    y_len[count] = sizeof(yy[count]);
    z_len[count] = sizeof(zz[count]);
  }

  try {
    m_writeStmt->setDataBuffer(1, (dvoid*)iconfid_vec, OCCIINT, sizeof(iconfid_vec[0]), iconf_len);
    m_writeStmt->setDataBuffer(2, (dvoid*)xx, OCCIINT, sizeof(xx[0]), x_len);
    m_writeStmt->setDataBuffer(3, (dvoid*)yy, OCCIINT, sizeof(yy[0]), y_len);
    m_writeStmt->setDataBuffer(4, (dvoid*)zz, OCCIINT, sizeof(zz[0]), z_len);

    m_writeStmt->executeArrayUpdate(nrows);

    delete[] iconfid_vec;
    delete[] xx;
    delete[] yy;
    delete[] zz;

    delete[] iconf_len;
    delete[] x_len;
    delete[] y_len;
    delete[] z_len;

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

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 13 of file FEConfigLUTGroupDat.h.

Member Data Documentation

int FEConfigLUTGroupDat::m_group_id

private

Definition at line 36 of file FEConfigLUTGroupDat.h.

Referenced by getLUTGroupId(), and setLUTGroupId().

int FEConfigLUTGroupDat::m_lut[1024]

private

Definition at line 37 of file FEConfigLUTGroupDat.h.

Referenced by getLUTValue(), and setLUTValue().