dataDML Namespace Reference

Functions
def	addHLTRunDataToBranch
def	addLumiRunDataToBranch
def	addNormToBranch
def	addTrgRunDataToBranch
def	beamInfoById
def	bulkInsertHltLSData
def	bulkInsertLumiLSSummary
def	bulkInsertTrgLSData
def	dataentryIdByRun
def	guessDataIdByRun
def	guessnormIdByContext
def	guessnormIdByName
def	hltLSById
def	hltRunById
def	hlttrgMappingByrun
def	insertRunSummaryData
def	insertTrgHltMap
def	latestdataIdByEntry
def	lumiBXByAlgo
def	lumiLSById
def	luminormById
def	lumiRunById
def	mostRecentLuminorms
def	runList
def	runsummary
def	trgLSById
def	trgRunById

Variables
tuple	branchinfo = (branchid,'DATA')
tuple	datainfo = revisionDML.createBranch(schema,'DATA','TRUNK',comment='hold data')
tuple	hltdata = generateDummyData.hlt(schema,20)
list	hltlsdata = hltdata[2]
list	hltrundata = [hltdata[0],hltdata[1]]
tuple	hlttrgmap = generateDummyData.hlttrgmap(schema)
tuple	latestNorms = revisionDML.latestDataRevisionOfEntry(schema,nameDealer.luminormTableName(),luminormentry_id,normrevlist)
tuple	latestrevision = revisionDML.latestDataRevisionOfEntry(schema,nameDealer.lumidataTableName(),lumientry_id,revlist)
tuple	lumidummydata = generateDummyData.lumiSummary(schema,20)
tuple	lumientry_id = revisionDML.entryInBranch(schema,nameDealer.lumidataTableName(),'1211','DATA')
list	lumilsdata = lumidummydata[1]
tuple	luminormentry_id = revisionDML.entryInBranch(schema,nameDealer.luminormTableName(),'pp7TeV','NORM')
list	lumirundata = [lumidummydata[0]]
string	myconstr = 'oracle://devdb10/cms_xiezhen_dev'
tuple	normbranchinfo = (normbranchid,'NORM')
tuple	norminfo = revisionDML.createBranch(schema,'NORM','TRUNK',comment='hold normalization factor')
tuple	normrevlist = revisionDML.revisionsInBranchName(schema,'NORM')
tuple	revlist = revisionDML.revisionsInBranchName(schema,'DATA')
tuple	runsummarydata = generateDummyData.runsummary(schema,'PROTPHYS',3500)
tuple	schema = session.nominalSchema()
tuple	session = svc.openSession(isReadOnly=False,cpp2sqltype=[('unsigned int','NUMBER(10)'),('unsigned long long','NUMBER(20)')])
tuple	svc = sessionManager.sessionManager(myconstr,authpath='/afs/cern.ch/user/x/xiezhen',debugON=False)
tuple	tables = lumidbDDL.createTables(schema)
tuple	trgdata = generateDummyData.trg(schema,20)
tuple	trgentry_id = revisionDML.entryInBranch(schema,nameDealer.trgdataTableName(),'1222','DATA')
list	trglsdata = trgdata[3]
list	trgrundata = [trgdata[0],trgdata[1],trgdata[2]]
tuple	trunkinfo = revisionDML.createBranch(schema,'TRUNK',None,comment='main')

Function Documentation

def dataDML.addHLTRunDataToBranch	(		schema,
			runnumber,
			hltrundata,
			branchinfo
	)

input:
    hltrundata [pathnameclob(0),datasource(1)]
output:
    (revision_id,entry_id,data_id)

Definition at line 958 of file dataDML.py.

References revisionDML.addEntry(), revisionDML.addRevision(), revisionDML.bookNewEntry(), revisionDML.bookNewRevision(), revisionDML.entryInBranch(), nameDealer.hltdataTableName(), and nameDealer.lumidataTableName().

def addHLTRunDataToBranch(schema,runnumber,hltrundata,branchinfo):
    '''
    input:
        hltrundata [pathnameclob(0),datasource(1)]
    output:
        (revision_id,entry_id,data_id)
    '''
    try:
         pathnames=hltrundata[0]
         datasource=hltrundata[1]
         npath=len(pathnames.split(','))
         entry_id=revisionDML.entryInBranch(schema,nameDealer.lumidataTableName(),str(runnumber),branchinfo[1])
         if entry_id is None:
             (revision_id,entry_id,data_id)=revisionDML.bookNewEntry(schema,nameDealer.hltdataTableName())
             entryinfo=(revision_id,entry_id,str(runnumber),data_id)
             revisionDML.addEntry(schema,nameDealer.hltdataTableName(),entryinfo,branchinfo)
         else:
             (revision_id,data_id)=revisionDML.bookNewRevision( schema,nameDealer.hltdataTableName() )
             revisionDML.addRevision(schema,nameDealer.hltdataTableName(),(revision_id,data_id),branchinfo)
         tabrowDefDict={'DATA_ID':'unsigned long long','ENTRY_ID':'unsigned long long','ENTRY_NAME':'string','RUNNUM':'unsigned int','SOURCE':'string','NPATH':'unsigned int','PATHNAMECLOB':'string'}
         tabrowValueDict={'DATA_ID':data_id,'ENTRY_ID':entry_id,'ENTRY_NAME':str(runnumber),'RUNNUM':int(runnumber),'SOURCE':datasource,'NPATH':npath,'PATHNAMECLOB':pathnames}
         db=dbUtil.dbUtil(schema)
         db.insertOneRow(nameDealer.hltdataTableName(),tabrowDefDict,tabrowValueDict)
         return (revision_id,entry_id,data_id)
    except :
        raise