lumi::idDealer Class Reference

#include <idDealer.h>

Public Member Functions
unsigned long long	generateNextIDForTable (const std::string &tableName, unsigned int interval=1)
unsigned long long	getIDforTable (const std::string &tableName)
	idDealer (coral::ISchema &schema)

Private Attributes
std::string	m_idtablecolumnName
std::string	m_idtablecolumnType
coral::ISchema &	m_schema

Detailed Description

Definition at line 8 of file idDealer.h.

Constructor & Destructor Documentation

lumi::idDealer::idDealer ( coral::ISchema &  schema )

explicit

Definition at line 14 of file idDealer.cc.

    : m_schema(schema),
      m_idtablecolumnName(lumi::LumiNames::idTableColumnName()),
      m_idtablecolumnType(lumi::LumiNames::idTableColumnType()) {}

Member Function Documentation

unsigned long long lumi::idDealer::generateNextIDForTable	(	const std::string &	tableName,
		unsigned int	interval = 1
	)

Definition at line 33 of file idDealer.cc.

References lumi::LumiNames::idTableName(), MergeJob_cfg::interval, submitPVResolutionJobs::q, alignCSCRings::r, contentValuesCheck::ss, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by lumi::RevisionDML::bookNewEntry(), lumi::RevisionDML::bookNewRevision(), lumi::HLTDummy2DB::retrieveData(), lumi::TRGDummy2DB::retrieveData(), lumi::LumiDummy2DB::retrieveData(), lumi::TRGWBM2DB::retrieveData(), lumi::Lumi2DB::writeAllLumiData(), lumi::HLTV32DB::writeHltData(), and lumi::TRGScalers2DB::writeTrgData().

                                                                                                         {
  std::string idtableName = lumi::LumiNames::idTableName(tableName);
  coral::IQuery* q = m_schema.tableHandle(idtableName).newQuery();
  q->addToOutputList(m_idtablecolumnName);
  unsigned long long r = 0;
  coral::AttributeList myresult;
  myresult.extend(m_idtablecolumnName, typeid(unsigned long long));
  q->defineOutput(myresult);
  q->setForUpdate();  //lock it
  coral::ICursor& cursor = q->execute();
  while (cursor.next()) {
    const coral::AttributeList& row = cursor.currentRow();
    r = row[m_idtablecolumnName].data<unsigned long long>();
  }
  coral::ITableDataEditor& dataEditor = m_schema.tableHandle(idtableName).dataEditor();
  coral::AttributeList inputData;
  //inputData.extend("interval",typeid(unsigned int));
  //inputData["interval"].data<unsigned int>()=interval;
  //dataEditor.updateRows(m_idtablecolumnName+"="+m_idtablecolumnName+"+1","",inputData);
  std::stringstream ss;
  ss << interval;
  dataEditor.updateRows(m_idtablecolumnName + "=" + m_idtablecolumnName + "+" + ss.str(), "", inputData);
  delete q;
  return r + interval;
}

unsigned long long lumi::idDealer::getIDforTable

(

const std::string &

tableName

)

Definition at line 18 of file idDealer.cc.

References lumi::LumiNames::idTableName(), submitPVResolutionJobs::q, mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                         {
  std::string idtableName = lumi::LumiNames::idTableName(tableName);
  coral::IQuery* q = m_schema.tableHandle(idtableName).newQuery();
  q->addToOutputList(m_idtablecolumnName);
  q->setForUpdate();  //lock it
  coral::ICursor& cursor = q->execute();
  unsigned long long result = 0;
  while (cursor.next()) {
    const coral::AttributeList& row = cursor.currentRow();
    result = row[m_idtablecolumnName].data<unsigned long long>();
  }
  cursor.close();
  delete q;
  return result;
}

Member Data Documentation

std::string lumi::idDealer::m_idtablecolumnName

private

Definition at line 16 of file idDealer.h.

std::string lumi::idDealer::m_idtablecolumnType

private

Definition at line 17 of file idDealer.h.

coral::ISchema& lumi::idDealer::m_schema

private

Definition at line 15 of file idDealer.h.