LMFDat Class Reference

#include <LMFDat.h>

Inheritance diagram for LMFDat:

Public Member Functions
void	dump () const override
void	dump (int n) const override
virtual void	dump (int n, int max) const
void	fetch () noexcept(false)
void	fetch (int logic_id) noexcept(false)
void	fetch (int logic_id, const Tm &tm) noexcept(false)
void	fetch (int logic_id, const Tm *timestamp, int dir) noexcept(false)
void	fetch (const EcalLogicID &id, const Tm &tm) noexcept(false)
void	fetch (const EcalLogicID &id, const Tm &tm, int dir) noexcept(false)
void	fetch (const EcalLogicID &id) noexcept(false)
std::map< int, std::vector < float > >	fetchData () noexcept(false)
virtual std::string	foreignKeyName () const
std::vector< float >	getData (int id)
std::vector< float >	getData (const EcalLogicID &id)
bool	getData (int id, std::vector< float > &ret)
bool	getData (const EcalLogicID &id, std::vector< float > &ret)
std::map< int, std::vector < float > >	getData ()
float	getData (int id, unsigned int k)
float	getData (const EcalLogicID &id, unsigned int k)
float	getData (const EcalLogicID &id, const std::string &key)
float	getData (int id, const std::string &key)
bool	getData (int id, unsigned int k, float &ret)
bool	getData (const EcalLogicID &id, unsigned int k, float &ret)
bool	getData (int id, const std::string &key, float &ret)
bool	getData (const EcalLogicID &id, const std::string &key, float &ret)
virtual std::string	getIovIdFieldName () const
std::list< std::string >	getKeyList ()
std::map< std::string, unsigned int >	getKeys ()
LMFRunIOV	getLMFRunIOV () const
int	getLMFRunIOVID ()
std::list< int >	getLogicIds ()
void	getNext (LMFDat *dat) noexcept(false)
void	getPrevious (LMFDat *dat) noexcept(false)
std::map< unsigned int, std::string >	getReverseMap () const
Tm	getSubrunStart () const
virtual std::string	getTableName () const
bool	isValid () override
	LMFDat ()
	LMFDat (EcalDBConnection *c)
	LMFDat (oracle::occi::Environment *env, oracle::occi::Connection *conn)
std::vector< float >	operator[] (int id)
LMFDat &	setData (int logic_id, const std::vector< float > &data)
LMFDat &	setData (const EcalLogicID &logic_id, const std::vector< float > &data)
LMFDat &	setData (const EcalLogicID &logic_id, const std::string &key, float v)
LMFDat &	setLMFRunIOV (const LMFRunIOV &iov)
LMFDat &	setMaxDataToDump (int n)
void	setWhereClause (std::string w)
void	setWhereClause (std::string w, const std::vector< std::string > &p)
int	size () const
	~LMFDat () override
Public Member Functions inherited from LMFUnique
void	attach (std::string name, LMFUnique *u)
void	debug ()
virtual bool	exists ()
virtual std::list < std::unique_ptr< LMFUnique > >	fetchAll () const noexcept(false)
int	fetchID () noexcept(false) override
std::string	getClassName ()
std::string	getClassName () const
int	getID () const
int	getInt (std::string fieldname) const
std::string	getString (std::string fieldname) const
virtual bool	isValid () const
	LMFUnique ()
	LMFUnique (oracle::occi::Environment *env, oracle::occi::Connection *conn)
	LMFUnique (EcalDBConnection *c)
void	nodebug ()
virtual bool	operator< (const LMFUnique &r)
virtual bool	operator<= (const LMFUnique &r)
std::string	sequencePostfix (const Tm &t)
void	setByID (int id) noexcept(false) override
LMFUnique &	setInt (std::string key, int value)
LMFUnique &	setString (std::string key, std::string value)
void	startProfiling ()
void	stopProfiling ()
	~LMFUnique () override
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 ()

Protected Member Functions
void	adjustParameters (int n, std::string &sql, Statement *stmt)
std::string	buildInsertSql ()
std::string	buildSelectSql (int logic_id=0, int direction=0)
bool	check ()
void	getKeyTypes () noexcept(false)
void	getNeighbour (LMFDat *dat, int which) noexcept(false)
int	writeDB () noexcept(false) override
Protected Member Functions inherited from LMFUnique
virtual void	getParameters (ResultSet *rset)
virtual void	setClassName (std::string s)
virtual int	writeForeignKeys () noexcept(false)
Protected Member Functions inherited from IDBObject
void	checkConnection () const noexcept(false)

Protected Attributes
std::string	_where
std::vector< std::string >	_wherePars
std::map< int, std::vector < float > >	m_data
std::string	m_Error
std::map< std::string, unsigned int >	m_keys
int	m_max
std::string	m_tableName
std::vector< std::string >	m_type
Protected Attributes inherited from LMFUnique
bool	_profiling
std::string	m_className
char	m_debug
std::map< std::string, LMFUnique * >	m_foreignKeys
std::map< std::string, int >	m_intFields
std::map< std::string, std::string >	m_stringFields
Protected Attributes inherited from IUniqueDBObject
int	m_ID
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Friends
class	EcalCondDBInterface

Additional Inherited Members
Public Types inherited from LMFUnique
typedef oracle::occi::ResultSet	ResultSet
typedef oracle::occi::Statement	Statement
Static Public Attributes inherited from IDBObject
static int const	ECALDB_NROWS = 1024

Detailed Description

Data Tables for LMF Runs

Definition at line 18 of file LMFDat.h.

Constructor & Destructor Documentation

LMFDat::LMFDat

(

)

Definition at line 9 of file LMFDat.cc.

References _where, _wherePars, m_max, and m_tableName.

               : LMFUnique() {
  m_tableName = "";
  m_max = -1;
  _where = "";
  _wherePars.clear();
}

LMFDat::LMFDat

(

EcalDBConnection *

c

)

Definition at line 16 of file LMFDat.cc.

References _where, _wherePars, m_max, and m_tableName.

                                  : LMFUnique(c) {
  m_tableName = "";
  m_max = -1;
  _where = "";
  _wherePars.clear();
}

LMFDat::LMFDat	(	oracle::occi::Environment *	env,
		oracle::occi::Connection *	conn
	)

Definition at line 23 of file LMFDat.cc.

References _where, _wherePars, m_max, and m_tableName.

                                                                     : LMFUnique(env, conn) {
  m_tableName = "";
  m_max = -1;
  _where = "";
  _wherePars.clear();
}

LMFDat::~LMFDat ( )

inlineoverride

Definition at line 25 of file LMFDat.h.

{}

Member Function Documentation

void LMFDat::adjustParameters ( int  n, std::string &  sql, Statement *  stmt  )

protected

Definition at line 207 of file LMFDat.cc.

References _wherePars, submitPVResolutionJobs::count, fileCollector::done, and dqmiodumpmetadata::n.

                                                                        {
  // adjust positional parameters and change them according to their
  // decalred type
  std::size_t nw = 0;
  std::size_t n = sql.find(':');
  for (int done = 1; done < count; done++) {
    // skip already bound variables
    n = sql.find(':', n + 1);
  }
  while (n != std::string::npos) {
    char type = sql.at(n + 1);
    if (type == 'S') {
      stmt->setString(nw + count, _wherePars[nw]);
      nw++;
    } else if (type == 'F') {
      stmt->setFloat(nw + count, atof(_wherePars[nw].c_str()));
      nw++;
    } else if (type == 'I') {
      stmt->setInt(nw + count, atoi(_wherePars[nw].c_str()));
      nw++;
    }
    n = sql.find(':', n + 1);
  }
}

std::string LMFDat::buildInsertSql ( )

protected

Definition at line 95 of file LMFDat.cc.

References gather_cfg::cout, getTableName(), mps_fire::i, LMFUnique::m_className, LMFUnique::m_debug, m_keys, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by writeDB().

                                 {
  // create the insert statement
  std::stringstream sql;
  sql << "INSERT INTO " + getTableName() + " VALUES (";
  unsigned int nParameters = m_keys.size() + 2;
  for (unsigned int i = 0; i < nParameters - 1; i++) {
    sql << ":" << i + 1 << ", ";
  }
  sql << ":" << nParameters << ")";
  std::string sqls = sql.str();
  if (m_debug) {
    cout << m_className << "::writeDB: " << sqls << endl;
  }
  return sqls;
}

std::string LMFDat::buildSelectSql ( int  logic_id = 0, int  direction = 0  )

protected

Definition at line 128 of file LMFDat.cc.

References _where, submitPVResolutionJobs::count, gather_cfg::cout, getIovIdFieldName(), getLMFRunIOVID(), getTableName(), LMFUnique::m_className, LMFUnique::m_debug, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                            {
  // create the insert statement
  // if logic_id = 0 select all channels for a given iov_id
  std::stringstream sql;
  int count = 1;
  if (getLMFRunIOVID() > 0) {
    if (_where.length() > 0) {
      // check if this is an expert query. If so, add a WHERE clause
      _where = " AND " + _where;
    }
    // in this case we are looking for all data collected during the same
    // IOV. There can be many logic_ids per IOV.
    sql << "SELECT * FROM CMS_ECAL_LASER_COND." << getTableName() << " WHERE " << getIovIdFieldName() << " = "
        << getLMFRunIOVID() << _where;
    // the expert query must be specified each time the expert makes the query
    // then empty it
    _where = "";
  } else {
    // in this case we are looking for a specific logic_id whose
    // data have been collected at a given time. There is only
    // one record in this case.
    std::string op = ">";
    std::string order = "ASC";
    if (direction < 0) {
      op = "<";
      order = "DESC";
    }
    sql << "SELECT * FROM (SELECT CMS_ECAL_LASER_COND." << getTableName() << ".* FROM CMS_ECAL_LASER_COND."
        << getTableName() << " JOIN LMF_RUN_IOV ON "
        << "LMF_RUN_IOV.LMF_IOV_ID = " << getTableName() << "." << getIovIdFieldName() << " "
        << "WHERE SUBRUN_START " << op << "= TO_DATE(:" << count;
    count++;
    sql << ", 'YYYY-MM-DD HH24:MI:SS') ORDER BY SUBRUN_START " << order << ") WHERE ROWNUM <= 1";
  }
  if (logic_id > 0) {
    sql << " AND LOGIC_ID = :" << count;
  }
  std::string sqls = sql.str();
  if (m_debug) {
    cout << m_className << "::buildSelectSqlDB: " << sqls << endl;
  }
  return sqls;
}

bool LMFDat::check ( void  )

protected

Definition at line 505 of file LMFDat.cc.

References relativeConstraints::empty, getKeyTypes(), getTableName(), LMFUnique::m_className, m_Error, m_keys, m_type, and runTheMatrix::ret.

Referenced by writeDB().

                   {
  // check that everything has been correctly setup
  bool ret = true;
  m_Error = "";
  // first of all we need to check that the class name has been set
  if (m_className == "LMFUnique") {
    m_Error = "class name not set ";
    ret = false;
  }
  //then check that the table name has been set
  if (getTableName().empty()) {
    m_Error += "table name not set ";
    ret = false;
  }
  // fill key types if not yet done
  if (m_type.size() != m_keys.size()) {
    getKeyTypes();
    if (m_type.size() != m_keys.size()) {
      m_Error += "key size does not correspond to table definition";
      ret = false;
    }
  }
  return ret;
}

void LMFDat::dump ( void  ) const

overridevirtual

Reimplemented from LMFUnique.

Definition at line 64 of file LMFDat.cc.

References m_max.

Referenced by dump(), LMFCorrCoefDat::fetch(), and writeDB().

{ dump(0, m_max); }

void LMFDat::dump ( int  n ) const

overridevirtual

Reimplemented from LMFUnique.

Definition at line 66 of file LMFDat.cc.

References dump(), and m_max.

{ dump(n, m_max); }

void LMFDat::dump ( int  n, int  max  ) const

virtual

Definition at line 68 of file LMFDat.cc.

References c, gather_cfg::cout, LMFUnique::dump(), dataset::end, getReverseMap(), dqmiolumiharvest::j, m_data, AlCaHLTBitMon_ParallelJobs::p, eostools::rm(), alignCSCRings::s, and x.

                                      {
  LMFUnique::dump(n);
  int s = m_data.size();
  cout << "Stored data: " << s << endl;
  if (max >= 0) {
    std::map<int, std::vector<float> >::const_iterator p = m_data.begin();
    std::map<int, std::vector<float> >::const_iterator end = m_data.end();
    int c = 0;
    std::map<unsigned int, std::string> rm = getReverseMap();
    while ((p != end) && (c < max)) {
      int id = p->first;
      std::vector<float> x = p->second;
      cout << c << " -------------------------------------------" << endl;
      cout << "   ID: " << id << endl;
      for (unsigned int j = 0; j < x.size(); j++) {
        if (j % 4 == 0) {
          cout << endl << "   ";
        }
        cout << rm[j] << ":" << x[j] << "\t";
      }
      cout << endl;
      p++;
      c++;
    }
  }
}

void LMFDat::fetch ( )

noexcept

Definition at line 201 of file LMFDat.cc.

Referenced by LMFCorrCoefDat::fetch().

{ fetch(0); }

void LMFDat::fetch ( int  logic_id )

noexcept

Definition at line 203 of file LMFDat.cc.

References cond::persistency::fetch().

{ fetch(logic_id, nullptr, 0); }

void LMFDat::fetch ( int  logic_id, const Tm &  tm  )

noexcept

Definition at line 205 of file LMFDat.cc.

References cond::persistency::fetch().

{ fetch(logic_id, &tm, 1); }

void LMFDat::fetch ( int  logic_id, const Tm *  timestamp, int  dir  )

noexcept

Definition at line 232 of file LMFDat.cc.

References trackerTree::check(), submitPVResolutionJobs::count, gather_cfg::cout, alignCSCRings::e, mps_fire::i, sistrip::SpyUtilities::isValid(), convertSQLiteXML::ok, AlCaHLTBitMon_QueryRunRegistry::string, cond::timestamp, and gpuClustering::x.

                                                                                   {
  bool ok = check();
  if ((timestamp == nullptr) && (getLMFRunIOVID() == 0)) {
    throw(std::runtime_error(m_className + "::fetch: Cannot fetch data with "
                                           "timestamp = 0 and LMFRunIOV = 0"));
  }
  if (ok && isValid()) {
    if (m_debug) {
      std::cout << "[LMFDat] This object is valid..." << std::endl;
    }
    try {
      Statement *stmt = m_conn->createStatement();
      std::string sql = buildSelectSql(logic_id, direction);
      if (m_debug) {
        std::cout << "[LMFDat] Executing query " << std::endl;
        std::cout << "         " << sql << std::endl << std::flush;
      }
      if (logic_id == 0) {
        // get data for all crystals with a given timestamp
        stmt->setPrefetchRowCount(10000);
      }
      stmt->setSQL(sql);
      int count = 1;
      if (logic_id > 0) {
        if (timestamp != nullptr) {
          stmt->setString(count, timestamp->str());
          count++;
        }
        stmt->setInt(count++, logic_id);
      }
      adjustParameters(count, sql, stmt);
      ResultSet *rset = stmt->executeQuery();
      std::vector<float> x;
      int nData = m_keys.size();
      x.reserve(nData);
      while (rset->next() != 0) {
        for (int i = 0; i < nData; i++) {
          x.push_back(rset->getFloat(i + 3));
        }
        int id = rset->getInt(2);
        if (timestamp != nullptr) {
          setInt(foreignKeyName(), rset->getInt(1));
        }
        this->setData(id, x);
        x.clear();
      }
      stmt->setPrefetchRowCount(0);
      m_conn->terminateStatement(stmt);
    } catch (oracle::occi::SQLException &e) {
      throw(std::runtime_error(m_className + "::fetch: " + e.getMessage()));
    }
    m_ID = m_data.size();
  }
}

void LMFDat::fetch ( const EcalLogicID &  id, const Tm &  tm  )

noexcept

Definition at line 194 of file LMFDat.cc.

References cond::persistency::fetch().

{ fetch(id.getLogicID(), &tm, 1); }

void LMFDat::fetch ( const EcalLogicID &  id, const Tm &  tm, int  dir  )

noexcept

Definition at line 196 of file LMFDat.cc.

References cond::persistency::fetch().

                                                                                     {
  setInt(foreignKeyName(), 0); /* set the LMF_IOV_ID to undefined */
  fetch(id.getLogicID(), &tm, direction);
}

void LMFDat::fetch ( const EcalLogicID &  id )

noexcept

Definition at line 192 of file LMFDat.cc.

References cond::persistency::fetch().

{ fetch(id.getLogicID()); }

std::map< int, std::vector< float > > LMFDat::fetchData ( )

noexcept

Definition at line 299 of file LMFDat.cc.

References gather_cfg::cout, alignCSCRings::e, getIovIdFieldName(), getLMFRunIOVID(), getTableName(), mps_fire::i, LMFUnique::m_className, IDBObject::m_conn, m_data, LMFUnique::m_debug, alignCSCRings::s, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by writeDB().

                                                                 {
  // see if any of the data is already in the database
  std::map<int, std::vector<float> > s = m_data;
  std::string sql =
      "SELECT LOGIC_ID FROM CMS_ECAL_LASER_COND." + getTableName() + " WHERE " + getIovIdFieldName() + " = :1";
  if (m_debug) {
    cout << m_className << ":: candidate data items to be written = " << s.size() << endl;
    cout << m_className << "   Executing " << sql;
    cout << " where " << getIovIdFieldName() << " = " << getLMFRunIOVID() << endl;
  }
  try {
    Statement *stmt = m_conn->createStatement();
    stmt->setSQL(sql);
    stmt->setInt(1, getLMFRunIOVID());
    stmt->setPrefetchRowCount(10000);
    ResultSet *rset = stmt->executeQuery();
    std::map<int, std::vector<float> >::iterator i = s.end();
    std::map<int, std::vector<float> >::iterator e = s.end();
    while (rset->next() != 0) {
      if (m_debug) {
        cout << m_className << ":: checking " << rset->getInt(1) << endl << std::flush;
      }
      i = s.find(rset->getInt(1));
      if (i != e) {
        s.erase(i);
      }
    }
    stmt->setPrefetchRowCount(0);
    m_conn->terminateStatement(stmt);
  } catch (oracle::occi::SQLException &e) {
    throw(std::runtime_error(m_className + "::fetchData:  " + e.getMessage()));
  }
  if (m_debug) {
    cout << m_className << ":: data items to write = " << s.size() << endl;
  }
  return s;
}

std::string LMFDat::foreignKeyName ( ) const

virtual

Reimplemented in LMFCorrCoefDatComponent.

Definition at line 30 of file LMFDat.cc.

Referenced by getLMFRunIOV(), getLMFRunIOVID(), isValid(), setLMFRunIOV(), and writeDB().

{ return "lmfRunIOV"; }

std::vector< float > LMFDat::getData

(

int

id

)

Definition at line 532 of file LMFDat.cc.

References gpuClustering::id, m_data, and runTheMatrix::ret.

                                       {
  std::vector<float> ret;
  if (m_data.find(id) != m_data.end()) {
    ret = m_data[id];
  }
  return ret;
}

std::vector< float > LMFDat::getData

(

const EcalLogicID &

id

)

Definition at line 542 of file LMFDat.cc.

References getData().

{ return getData(id.getLogicID()); }

bool LMFDat::getData	(	int	id,
		std::vector< float > &	ret
	)

Definition at line 546 of file LMFDat.cc.

References gpuClustering::id, and m_data.

                                                  {
  bool retval = false;
  if (m_data.find(id) != m_data.end()) {
    ret = m_data[id];
    retval = true;
  }
  return retval;
}

bool LMFDat::getData	(	const EcalLogicID &	id,
		std::vector< float > &	ret
	)

Definition at line 555 of file LMFDat.cc.

References getData().

{ return getData(id.getLogicID(), ret); }

std::map< int, std::vector< float > > LMFDat::getData

(

void

)

Definition at line 559 of file LMFDat.cc.

References m_data.

Referenced by LMFPrimDat::getAlpha(), LMFPrimDat::getAPDoverAM3(), LMFPrimDat::getAPDoverAMean(), LMFPrimDat::getAPDoverARMS(), LMFPrimDat::getAPDoverBM3(), LMFPrimDat::getAPDoverBMean(), LMFPrimDat::getAPDoverBRMS(), LMFPrimDat::getAPDoverPnM3(), LMFPrimDat::getAPDoverPnMean(), LMFPrimDat::getAPDoverPnRMS(), LMFPrimDat::getBeta(), LMFTestPulseConfigDat::getDACMGPA(), getData(), LMFClsDat::getENorm(), LMFRunDat::getEvents(), LMFLaserPulseDat::getFitMethod(), LMFCorrCoefDatComponent::getFlag(), LMFClsDat::getFlag(), LMFPrimDat::getFlag(), LMFPnPrimDat::getFlag(), LMFClsDat::getFlagNorm(), LMFClsDat::getLMFRefRunIOVID(), LMFLaserConfigDat::getLSRAttenuator(), LMFLaserConfigDat::getLSRCurrent(), LMFLaserConfigDat::getLSRDelay1(), LMFLaserConfigDat::getLSRDelay2(), LMFLaserConfigDat::getLSRPower(), LMFPrimDat::getM3(), LMFPnPrimDat::getM3(), LMFClsDat::getMean(), LMFPrimDat::getMean(), LMFPnPrimDat::getMean(), LMFLaserPulseDat::getMTQAmplification(), LMFLaserPulseDat::getMTQFW20(), LMFLaserPulseDat::getMTQFW80(), LMFLaserPulseDat::getMTQFWHM(), LMFLaserPulseDat::getMTQRise(), LMFLaserPulseDat::getMTQSliding(), LMFLaserPulseDat::getMTQTime(), LMFClsDat::getNevt(), LMFClsDat::getNorm(), LMFCorrCoefDatComponent::getParameterErrors(), LMFCorrCoefDatComponent::getParameters(), LMFPnPrimDat::getPNAoverBM3(), LMFPnPrimDat::getPNAoverBMean(), LMFPnPrimDat::getPNAoverBRMS(), LMFTestPulseConfigDat::getPNGain(), LMFLaserConfigDat::getPNGain(), LMFTestPulseConfigDat::getPNVinj(), LMFRunDat::getQualityFlag(), LMFClsDat::getRMS(), LMFPrimDat::getRMS(), LMFPnPrimDat::getRMS(), LMFCorrCoefDatComponent::getSeqID(), LMFCorrCoefDatComponent::getSequence(), LMFPnPrimDat::getShapeCor(), LMFPrimDat::getShapeCorr(), LMFTestPulseConfigDat::getVFEGain(), LMFLaserConfigDat::getVFEGain(), LMFColoredTable::getVmax(), LMFColoredTable::getVmin(), LMFLaserConfigDat::getWavelength(), and operator[]().

{ return m_data; }

float LMFDat::getData	(	int	id,
		unsigned int	k
	)

Definition at line 563 of file LMFDat.cc.

References gpuClustering::id, isotrackApplyRegressor::k, and m_data.

{ return m_data[id][k]; }

float LMFDat::getData	(	const EcalLogicID &	id,
		unsigned int	k
	)

Definition at line 565 of file LMFDat.cc.

References getData().

{ return getData(id.getLogicID(), k); }

float LMFDat::getData	(	const EcalLogicID &	id,
		const std::string &	key
	)

Definition at line 567 of file LMFDat.cc.

References getData(), and m_keys.

{ return getData(id.getLogicID(), m_keys[key]); }

float LMFDat::getData	(	int	id,
		const std::string &	key
	)

Definition at line 569 of file LMFDat.cc.

References getData(), and m_keys.

{ return getData(id, m_keys[key]); }

bool LMFDat::getData	(	int	id,
		unsigned int	k,
		float &	ret
	)

Definition at line 573 of file LMFDat.cc.

References getData(), isotrackApplyRegressor::k, and findQualityFiles::v.

                                                       {
  bool retval = false;
  std::vector<float> v;
  retval = getData(id, v);
  if ((retval) && (v.size() > k)) {
    ret = v[k];
    retval = true;
  } else {
    retval = false;
  }
  return retval;
}

bool LMFDat::getData	(	const EcalLogicID &	id,
		unsigned int	k,
		float &	ret
	)

Definition at line 586 of file LMFDat.cc.

References getData().

{ return getData(id.getLogicID(), k, ret); }

bool LMFDat::getData	(	int	id,
		const std::string &	key,
		float &	ret
	)

Definition at line 588 of file LMFDat.cc.

References getData(), and m_keys.

                                                             {
  bool retval = false;
  if (m_keys.find(key) != m_keys.end()) {
    retval = getData(id, m_keys[key], ret);
  }
  return retval;
}

bool LMFDat::getData	(	const EcalLogicID &	id,
		const std::string &	key,
		float &	ret
	)

Definition at line 596 of file LMFDat.cc.

References getData().

                                                                            {
  return getData(id.getLogicID(), key, ret);
}

std::string LMFDat::getIovIdFieldName ( ) const

virtual

Reimplemented in LMFCorrCoefDatComponent.

Definition at line 111 of file LMFDat.cc.

Referenced by buildSelectSql(), fetchData(), and getKeyTypes().

{ return "LMF_IOV_ID"; }

std::list<std::string> LMFDat::getKeyList ( )

inline

Definition at line 103 of file LMFDat.h.

References alignCSCRings::e, mps_fire::i, cmsLHEtoEOSManager::l, and m_keys.

                                  {
    std::list<std::string> l;
    std::map<std::string, unsigned int>::const_iterator i = m_keys.begin();
    std::map<std::string, unsigned int>::const_iterator e = m_keys.end();
    while (i != e) {
      l.push_back(i->first);
      i++;
    }
    return l;
  }

std::map<std::string, unsigned int> LMFDat::getKeys ( )

inline

Definition at line 102 of file LMFDat.h.

References m_keys.

{ return m_keys; }

void LMFDat::getKeyTypes ( )

protectednoexcept

Definition at line 474 of file LMFDat.cc.

References alignCSCRings::e, getIovIdFieldName(), getTableName(), mps_fire::i, LMFUnique::m_className, IDBObject::m_conn, m_keys, m_type, mergeVDriftHistosByStation::name, AlCaHLTBitMon_QueryRunRegistry::string, and submitPVValidationJobs::t.

Referenced by check().

                                         {
  m_type.reserve(m_keys.size());
  for (unsigned int i = 0; i < m_keys.size(); i++) {
    m_type.push_back("");
  }
  // get the description of the table
  std::string sql = "";
  try {
    Statement *stmt = m_conn->createStatement();
    sql = "SELECT * FROM TABLE(CMS_ECAL_LASER_COND.LMF_TAB_COLS(:1, :2))";
    /*
    sql = "SELECT COLUMN_NAME, DATA_TYPE FROM " 
      "USER_TAB_COLS WHERE TABLE_NAME = '" + getTableName() + "' " 
      "AND COLUMN_NAME != '" + getIovIdFieldName() +  "' AND COLUMN_NAME != " 
      "'LOGIC_ID'";
    */
    stmt->setSQL(sql);
    stmt->setString(1, getTableName());
    stmt->setString(2, getIovIdFieldName());
    ResultSet *rset = stmt->executeQuery();
    while (rset->next() != 0) {
      std::string name = rset->getString(1);
      std::string t = rset->getString(2);
      m_type[m_keys[name]] = t;
    }
    m_conn->terminateStatement(stmt);
  } catch (oracle::occi::SQLException &e) {
    throw(std::runtime_error(m_className + "::getKeyTypes: " + e.getMessage() + " [" + sql + "]"));
  }
}

LMFRunIOV LMFDat::getLMFRunIOV ( ) const

inline

Definition at line 34 of file LMFDat.h.

References foreignKeyName(), LMFUnique::getInt(), IDBObject::m_conn, IDBObject::m_env, and LMFUnique::setByID().

Referenced by getSubrunStart().

                                 {
    LMFRunIOV runiov(m_env, m_conn);
    runiov.setByID(getInt(foreignKeyName()));
    return runiov;
  }

int LMFDat::getLMFRunIOVID

(

)

Definition at line 32 of file LMFDat.cc.

References LMFUnique::fetchID(), foreignKeyName(), LMFUnique::getInt(), mps_fire::i, gpuClustering::id, LMFUnique::m_foreignKeys, and LMFUnique::setInt().

Referenced by buildSelectSql(), and fetchData().

                           {
  int id = getInt(foreignKeyName());
  if (id == 0) {
    // try to get it from the list of foreign keys
    std::map<std::string, LMFUnique *>::iterator i = m_foreignKeys.find(foreignKeyName());
    if (i != m_foreignKeys.end()) {
      LMFRunIOV *iov = (LMFRunIOV *)(i->second);
      if (iov != nullptr) {
        id = iov->fetchID();
        setInt(foreignKeyName(), id);
      }
    }
  }
  return id;
}

std::list<int> LMFDat::getLogicIds ( )

inline

Definition at line 91 of file LMFDat.h.

References alignCSCRings::e, mps_fire::i, cmsLHEtoEOSManager::l, and m_data.

                             {
    std::list<int> l;
    std::map<int, std::vector<float> >::const_iterator i = m_data.begin();
    std::map<int, std::vector<float> >::const_iterator e = m_data.end();
    while (i != e) {
      l.push_back(i->first);
      i++;
    }
    return l;
  }

void LMFDat::getNeighbour ( LMFDat *  dat, int  which  )

protectednoexcept

Definition at line 176 of file LMFDat.cc.

References dat, remoteMonitoring_LASER_era2018_cfg::dump, and eostools::which().

                                                                {
  // there should be just one record in this case
  if (m_data.size() == 1) {
    dat->setConnection(this->getEnv(), this->getConn());
    int logic_id = m_data.begin()->first;
    Tm lastMeasuredOn = getSubrunStart();
    lastMeasuredOn += which;
    dat->fetch(logic_id, &lastMeasuredOn, which);
    dat->setMaxDataToDump(m_max);
  } else {
    dump();
    throw(std::runtime_error(m_className + "::getPrevious: Too many LOGIC_IDs in "
                                           "this object"));
  }
}

void LMFDat::getNext ( LMFDat *  dat )

noexcept

Definition at line 174 of file LMFDat.cc.

References dat.

{ getNeighbour(dat, +1); }

void LMFDat::getPrevious ( LMFDat *  dat )

noexcept

Definition at line 172 of file LMFDat.cc.

References dat.

{ getNeighbour(dat, -1); }

std::map< unsigned int, std::string > LMFDat::getReverseMap

(

)

const

Definition at line 53 of file LMFDat.cc.

References alignCSCRings::e, mps_fire::i, visualization-live-secondInstance_cfg::m, and m_keys.

Referenced by dump().

                                                            {
  std::map<unsigned int, std::string> m;
  std::map<std::string, unsigned int>::const_iterator i = m_keys.begin();
  std::map<std::string, unsigned int>::const_iterator e = m_keys.end();
  while (i != e) {
    m[i->second] = i->first;
    i++;
  }
  return m;
}

Tm LMFDat::getSubrunStart ( ) const

inline

Definition at line 40 of file LMFDat.h.

References getLMFRunIOV(), and LMFRunIOV::getSubRunStart().

{ return getLMFRunIOV().getSubRunStart(); }

virtual std::string LMFDat::getTableName ( ) const

inlinevirtual

Reimplemented in LMFCorrCoefDatComponent, LMFClsDat, LMFPnPrimDat, LMFLaserPulseDat, LMFPrimDat, and LMFColoredTable.

Definition at line 45 of file LMFDat.h.

References m_tableName.

Referenced by buildInsertSql(), buildSelectSql(), check(), fetchData(), and getKeyTypes().

{ return m_tableName; }

bool LMFDat::isValid ( void  )

overridevirtual

Reimplemented from LMFUnique.

Reimplemented in LMFPrimDat, LMFPnPrimDat, and LMFLaserPulseDat.

Definition at line 287 of file LMFDat.cc.

References gather_cfg::cout, foreignKeyName(), LMFUnique::m_className, LMFUnique::m_debug, m_Error, LMFUnique::m_foreignKeys, and runTheMatrix::ret.

Referenced by ntupleDataFormat._Object::_checkIsValid(), LMFLaserPulseDat::isValid(), core.AutoHandle.AutoHandle::ReallyLoad(), and writeDB().

                     {
  bool ret = true;
  if (m_foreignKeys.find(foreignKeyName()) == m_foreignKeys.end()) {
    ret = false;
    m_Error += " Can't find lmfRunIOV within foreign keys.";
    if (m_debug) {
      cout << m_className << ": Foreign keys map size: " << m_foreignKeys.size() << endl;
    }
  }
  return ret;
}

std::vector< float > LMFDat::operator[]

(

int

id

)

Definition at line 540 of file LMFDat.cc.

References getData().

{ return getData(id); }

LMFDat& LMFDat::setData ( int  logic_id, const std::vector< float > &  data  )

inline

Definition at line 49 of file LMFDat.h.

References data, and m_data.

Referenced by LMFRunDat::Data(), LMFPrimDat::setAlpha(), LMFPrimDat::setAPDoverAM3(), LMFPrimDat::setAPDoverAMean(), LMFPrimDat::setAPDoverARMS(), LMFPrimDat::setAPDoverBM3(), LMFPrimDat::setAPDoverBMean(), LMFPrimDat::setAPDoverBRMS(), LMFPrimDat::setAPDoverPnM3(), LMFPrimDat::setAPDoverPnMean(), LMFPrimDat::setAPDoverPnRMS(), LMFPrimDat::setBeta(), LMFTestPulseConfigDat::setDACMGPA(), LMFRunDat::setData(), LMFTestPulseConfigDat::setData(), LMFLaserConfigDat::setData(), LMFClsDat::setENorm(), LMFRunDat::setEvents(), LMFLaserPulseDat::setFitMethod(), LMFCorrCoefDatComponent::setFlag(), LMFPrimDat::setFlag(), LMFPnPrimDat::setFlag(), LMFClsDat::setFlag(), LMFClsDat::setFlagNorm(), LMFClsDat::setLMFRefRunIOVID(), LMFLaserConfigDat::setLSRAttenuator(), LMFLaserConfigDat::setLSRCurrent(), LMFLaserConfigDat::setLSRDelay1(), LMFLaserConfigDat::setLSRDelay2(), LMFLaserConfigDat::setLSRPower(), LMFPnPrimDat::setM3(), LMFPrimDat::setM3(), LMFPnPrimDat::setMean(), LMFPrimDat::setMean(), LMFClsDat::setMean(), LMFLaserPulseDat::setMTQAmplification(), LMFLaserPulseDat::setMTQFW20(), LMFLaserPulseDat::setMTQFW80(), LMFLaserPulseDat::setMTQFWHM(), LMFLaserPulseDat::setMTQRise(), LMFLaserPulseDat::setMTQSliding(), LMFLaserPulseDat::setMTQTime(), LMFClsDat::setNevt(), LMFClsDat::setNorm(), LMFCorrCoefDatComponent::setP123(), LMFCorrCoefDatComponent::setP123Errors(), LMFPnPrimDat::setPNAoverBM3(), LMFPnPrimDat::setPNAoverBMean(), LMFPnPrimDat::setPNAoverBRMS(), LMFTestPulseConfigDat::setPNGain(), LMFLaserConfigDat::setPNGain(), LMFTestPulseConfigDat::setPNVinj(), LMFRunDat::setQualityFlag(), LMFPrimDat::setRMS(), LMFPnPrimDat::setRMS(), LMFClsDat::setRMS(), LMFCorrCoefDatComponent::setSequence(), LMFPnPrimDat::setShapeCorr(), LMFPrimDat::setShapeCorr(), LMFColoredTable::setVersions(), LMFTestPulseConfigDat::setVFEGain(), LMFLaserConfigDat::setVFEGain(), LMFColoredTable::setVmax(), LMFColoredTable::setVmin(), and LMFLaserConfigDat::setWavelength().

                                                              {
    m_data[logic_id] = data;
    return *this;
  }

LMFDat& LMFDat::setData ( const EcalLogicID &  logic_id, const std::vector< float > &  data  )

inline

Definition at line 53 of file LMFDat.h.

References data, EcalLogicID::getLogicID(), and m_data.

                                                                             {
    m_data[logic_id.getLogicID()] = data;
    return *this;
  }

LMFDat& LMFDat::setData ( const EcalLogicID &  logic_id, const std::string &  key, float  v  )

inline

Definition at line 57 of file LMFDat.h.

References EcalLogicID::getLogicID(), gpuClustering::id, submitPVResolutionJobs::key, m_data, m_keys, and findQualityFiles::v.

                                                                              {
    int id = logic_id.getLogicID();
    m_data[id].resize(m_keys.size());
    m_data[id][m_keys[key]] = v;
    return *this;
  }

LMFDat& LMFDat::setLMFRunIOV ( const LMFRunIOV &  iov )

inline

Definition at line 29 of file LMFDat.h.

References LMFUnique::attach(), foreignKeyName(), LMFUnique::getID(), and LMFUnique::setInt().

                                             {
    setInt(foreignKeyName(), iov.getID());
    attach(foreignKeyName(), (LMFUnique *)&iov);
    return *this;
  }

LMFDat & LMFDat::setMaxDataToDump

(

int

n

)

Definition at line 48 of file LMFDat.cc.

References m_max, and dqmiodumpmetadata::n.

Referenced by writeDB().

                                      {
  m_max = n;
  return *this;
}

void LMFDat::setWhereClause

(

std::string

w

)

Definition at line 113 of file LMFDat.cc.

References _where.

                                           {
  // to be used by experts to restrict the results of a query
  _where = where;
}

void LMFDat::setWhereClause	(	std::string	w,
		const std::vector< std::string > &	p
	)

Definition at line 118 of file LMFDat.cc.

References _where, and _wherePars.

                                                                                   {
  // to be used by experts to restrict the results of a query
  // in this case the where clause can contains positional parameter,
  // identified as :/I, :/S, :/F for, respectively, integer, string or
  // float parameters. The parameters are all passed as strings
  // in parameters
  _wherePars = parameters;
  _where = where;
}

int LMFDat::size ( void  ) const

inline

Definition at line 63 of file LMFDat.h.

References m_data.

Referenced by ntupleDataFormat._Collection::__iter__(), ntupleDataFormat._Collection::__len__(), and writeDB().

{ return m_data.size(); }

int LMFDat::writeDB ( )

overrideprotectedvirtualnoexcept

Reimplemented from LMFUnique.

Definition at line 337 of file LMFDat.cc.

References b, cms::cuda::be, edmScanValgrind::buffer, buildInsertSql(), c, check(), IDBObject::checkConnection(), gather_cfg::cout, LMFUnique::debug(), dump(), alignCSCRings::e, fetchData(), foreignKeyName(), LMFUnique::getID(), mps_fire::i, gpuClustering::id, isValid(), isotrackApplyRegressor::k, LMFUnique::m_className, IDBObject::m_conn, LMFUnique::m_debug, m_Error, LMFUnique::m_foreignKeys, m_keys, m_max, m_type, convertSQLiteXML::ok, runTheMatrix::ret, setMaxDataToDump(), size(), AlCaHLTBitMon_QueryRunRegistry::string, LMFUnique::writeForeignKeys(), and x.

Referenced by LMFCorrCoefDatComponent::writeDB(), and LMFColoredTable::writeDB().

                                    {
  // first of all check if data already present
  if (m_debug) {
    cout << m_className << ": Writing foreign keys" << endl;
  }
  LMFUnique::writeForeignKeys();
  if (m_debug) {
    cout << m_className << ": Foreign keys written" << endl;
  }
  // write data on the database
  int ret = 0;
  std::map<int, std::vector<float> > data2write = fetchData();
  if (!data2write.empty()) {
    this->checkConnection();
    bool ok = check();
    // write
    if (ok && isValid()) {
      std::list<dvoid *> bufPointers;
      int nParameters = m_keys.size();
      int nData = data2write.size();
      if (m_debug) {
        cout << m_className << ": # data items = " << nData << endl;
        cout << m_className << ": # parameters = " << nParameters << endl;
      }
      int *iovid_vec = new int[nData];
      int *logicid_vec = new int[nData];
      int *intArray = new int[nData];
      float *floatArray = new float[nData];
      ub2 *intSize = new ub2[nData];
      ub2 *floatSize = new ub2[nData];
      size_t intTotalSize = sizeof(int) * nData;
      size_t floatTotalSize = sizeof(float) * nData;
      try {
        Statement *stmt = m_conn->createStatement();
        std::string sql = buildInsertSql();
        stmt->setSQL(sql);
        // build the array of the size of each column
        for (int i = 0; i < nData; i++) {
          intSize[i] = sizeof(int);
          floatSize[i] = sizeof(int);
        }
        // build the data array for first column: the same run iov id
        LMFRunIOV *runiov = (LMFRunIOV *)m_foreignKeys[foreignKeyName()];
        int iov_id = runiov->getID();
        std::map<int, std::vector<float> >::const_iterator b = data2write.begin();
        std::map<int, std::vector<float> >::const_iterator e = data2write.end();
        for (int i = 0; i < nData; i++) {
          iovid_vec[i] = iov_id;
        }
        stmt->setDataBuffer(1, (dvoid *)iovid_vec, oracle::occi::OCCIINT, sizeof(iovid_vec[0]), intSize);
        // build the data array for second column: the logic ids
        int c = 0;
        while (b != e) {
          int id = b->first;
          logicid_vec[c++] = id;
          b++;
        }
        stmt->setDataBuffer(2, (dvoid *)logicid_vec, oracle::occi::OCCIINT, sizeof(logicid_vec[0]), intSize);
        // for each column build the data array
        oracle::occi::Type type = oracle::occi::OCCIFLOAT;
        for (int i = 0; i < nParameters; i++) {
          b = data2write.begin();
          // loop on all logic ids
          c = 0;
          while (b != e) {
            std::vector<float> x = b->second;
            if (m_type[i] == "INT") {
              intArray[c] = (int)rint(x[i]);
            } else if ((m_type[i] == "FLOAT") || (m_type[i] == "NUMBER")) {
              floatArray[c] = x[i];
            } else {
              throw(std::runtime_error("ERROR: LMFDat::writeDB: unsupported type"));
            }
            c++;
            b++;
          }
          // copy data into a "permanent" buffer
          dvoid *buffer;
          type = oracle::occi::OCCIINT;
          ub2 *sizeArray = intSize;
          int size = sizeof(intArray[0]);
          if ((m_type[i] == "FLOAT") || (m_type[i] == "NUMBER")) {
            buffer = (dvoid *)malloc(sizeof(float) * nData);
            memcpy(buffer, floatArray, floatTotalSize);
            type = oracle::occi::OCCIFLOAT;
            sizeArray = floatSize;
            size = sizeof(floatArray[0]);
          } else {
            buffer = (dvoid *)malloc(sizeof(int) * nData);
            memcpy(buffer, intArray, intTotalSize);
          }
          bufPointers.push_back(buffer);
          if (m_debug) {
            for (int k = 0; ((k < nData) && (k < m_max)); k++) {
              cout << m_className << ": === Index=== " << k << endl;
              cout << m_className << ": RUN_IOV_ID = " << iovid_vec[k] << endl;
              cout << m_className << ": LOGIC_ID = " << logicid_vec[k] << endl;
              cout << m_className << ": FIELD " << i << ": " << ((float *)(buffer))[k] << endl;
            }
          }
          stmt->setDataBuffer(i + 3, buffer, type, size, sizeArray);
        }
        stmt->executeArrayUpdate(nData);
        delete[] intArray;
        delete[] floatArray;
        delete[] intSize;
        delete[] floatSize;
        delete[] logicid_vec;
        delete[] iovid_vec;
        std::list<dvoid *>::const_iterator bi = bufPointers.begin();
        std::list<dvoid *>::const_iterator be = bufPointers.end();
        while (bi != be) {
          free(*bi);
          bi++;
        }
        m_conn->commit();
        m_conn->terminateStatement(stmt);
        ret = nData;
      } catch (oracle::occi::SQLException &e) {
        debug();
        setMaxDataToDump(nData);
        // get the Foreign Key
        LMFRunIOV *runiov = (LMFRunIOV *)m_foreignKeys[foreignKeyName()];
        int iov_id = runiov->getID();
        std::cout << "==== This object refers to IOV " << iov_id << std::endl;
        dump();
        m_conn->rollback();
        throw(std::runtime_error(m_className + "::writeDB: " + e.getMessage()));
      }
    } else {
      cout << m_className << "::writeDB: Cannot write because " << m_Error << endl;
      dump();
    }
  }
  return ret;
}

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 20 of file LMFDat.h.

Member Data Documentation

std::string LMFDat::_where

protected

Definition at line 149 of file LMFDat.h.

Referenced by buildSelectSql(), LMFDat(), and setWhereClause().

std::vector<std::string> LMFDat::_wherePars

protected

Definition at line 150 of file LMFDat.h.

Referenced by adjustParameters(), LMFDat(), and setWhereClause().

std::map<int, std::vector<float> > LMFDat::m_data

protected

Definition at line 143 of file LMFDat.h.

Referenced by dump(), fetchData(), getData(), getLogicIds(), setData(), LMFPnPrimDat::setSystem(), size(), and LMFColoredTable::writeDB().

std::string LMFDat::m_Error

protected

Definition at line 147 of file LMFDat.h.

Referenced by check(), LMFClsDat::isValid(), LMFLaserPulseDat::isValid(), LMFPnPrimDat::isValid(), LMFPrimDat::isValid(), isValid(), and writeDB().

std::map<std::string, unsigned int> LMFDat::m_keys

protected

Definition at line 145 of file LMFDat.h.

Referenced by buildInsertSql(), check(), getData(), getKeyList(), getKeys(), getKeyTypes(), getReverseMap(), LMFCorrCoefDatComponent::init(), LMFClsDat::init(), LMFLaserPulseDat::init(), LMFPnPrimDat::init(), LMFPrimDat::init(), LMFLaserConfigDat::LMFLaserConfigDat(), LMFRunDat::LMFRunDat(), LMFTestPulseConfigDat::LMFTestPulseConfigDat(), setData(), LMFPnPrimDat::setSystem(), and writeDB().

int LMFDat::m_max

protected

Definition at line 139 of file LMFDat.h.

Referenced by dump(), LMFDat(), setMaxDataToDump(), and writeDB().

std::string LMFDat::m_tableName

protected

Definition at line 146 of file LMFDat.h.

Referenced by getTableName(), LMFDat(), LMFLaserConfigDat::LMFLaserConfigDat(), LMFRunDat::LMFRunDat(), and LMFTestPulseConfigDat::LMFTestPulseConfigDat().

std::vector<std::string> LMFDat::m_type

protected

Definition at line 140 of file LMFDat.h.

Referenced by check(), getKeyTypes(), LMFCorrCoefDatComponent::init(), LMFClsDat::init(), LMFLaserPulseDat::init(), LMFPnPrimDat::init(), LMFPrimDat::init(), LMFPnPrimDat::setSystem(), and writeDB().