revisionDML Namespace Reference

Functions
def	addEntry
def	addRevision
def	addRunToCurrentDataTag
def	alldataTags
def	bookNewEntry
def	bookNewRevision
def	branchInfoByName
def	branchType
def	createBranch
def	createDataTag
	Data Tagging API. More...
def	currentDataTag
def	dataIdsByCurrentTag
def	dataIdsByTagId
def	dataIdsByTagName
def	dataRevisionsOfEntry
def	dataTagInfo
def	entryInBranch
def	getDataTagId
def	latestDataRevisionOfEntry
def	revisionsInBranch
def	revisionsInBranchName
def	revisionsInTag

Variables
tuple	databranchinfo = (branchid,'DATA')
tuple	datainfo = createBranch(schema,'DATA','TRUNK',comment='hold data')
tuple	entryinfo = (revision_id,entry_id,str(runnum),data_id)
tuple	hltentryid = entryInBranch(schema,nameDealer.hltdataTableName(),str(runnum),'DATA')
tuple	latestrevision = latestDataRevisionOfEntry(schema,nameDealer.lumidataTableName(),lumientry_id,revlist)
tuple	lumientry_id = entryInBranch(schema,nameDealer.lumidataTableName(),'1211','DATA')
tuple	lumientryid = entryInBranch(schema,nameDealer.lumidataTableName(),str(runnum),'DATA')
string	myconstr = 'sqlite_file:test.db'
tuple	norminfo = createBranch(schema,'NORM','TRUNK',comment='hold normalization factor')
tuple	revisioninfo = bookNewRevision( schema,nameDealer.lumidataTableName() )
tuple	revlist = revisionsInBranchName(schema,'DATA')
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,debugON=False)
tuple	tables = lumidbDDL.createTables(schema)
tuple	trgentryid = entryInBranch(schema,nameDealer.trgdataTableName(),str(runnum),'DATA')
tuple	trunkinfo = createBranch(schema,'TRUNK',None,comment='main')

Function Documentation

def revisionDML.addEntry	(		schema,
			datatableName,
			entryinfo,
			branchinfo
	)

input:
    entryinfo (revision_id(0),entry_id(1),entry_name(2),data_id(3))
    branchinfo (branch_id,branch_name)
1.allocate and insert a new revision into the revisions table
2.allocate and insert a new entry into the entry table with the new revision
3.inset into data_rev table with new data_id ,revision)id mapping

insert into revisions(revision_id,branch_id,branch_name,comment,ctime) values()
insert into datatablename_entries (entry_id,revision_id) values()
insert into datatablename_rev(data_id,revision_id) values()

Definition at line 342 of file revisionDML.py.

References nameDealer.entryTableName(), nameDealer.revisionTableName(), and nameDealer.revmapTableName().

Referenced by CalibrationInterface< CategoryT, CalibDataT >.addCategoryDefinition(), dataDML.addCorrToBranch(), TAPD.addEntry(), TMom.addEntry(), dataDML.addHLTRunDataToBranch(), dataDML.addLumiRunDataToBranch(), dataDML.addNormToBranch(), dataDML.addTrgRunDataToBranch(), normDML.createNorm(), EcalMatacqAnalyzer.endJob(), and AlgorithmCalibration< T, CO >.readCategories().

def addEntry(schema,datatableName,entryinfo,branchinfo):
    '''
    input:
        entryinfo (revision_id(0),entry_id(1),entry_name(2),data_id(3))
        branchinfo (branch_id,branch_name)
    1.allocate and insert a new revision into the revisions table
    2.allocate and insert a new entry into the entry table with the new revision
    3.inset into data_rev table with new data_id ,revision)id mapping
    
    insert into revisions(revision_id,branch_id,branch_name,comment,ctime) values()
    insert into datatablename_entries (entry_id,revision_id) values()
    insert into datatablename_rev(data_id,revision_id) values()
    '''
    try:
        revisiontableName=nameDealer.revisionTableName()
        entrytableName=nameDealer.entryTableName(datatableName)
        revtableName=nameDealer.revmapTableName(datatableName)
        
        db=dbUtil.dbUtil(schema)
        tabrowDefDict={}
        tabrowDefDict['REVISION_ID']='unsigned long long'
        tabrowDefDict['BRANCH_ID']='unsigned long long'
        tabrowDefDict['BRANCH_NAME']='string'
        tabrowDefDict['CTIME']='time stamp'
        tabrowValueDict={}
        tabrowValueDict['REVISION_ID']=entryinfo[0]
        tabrowValueDict['BRANCH_ID']=branchinfo[0]
        tabrowValueDict['BRANCH_NAME']=branchinfo[1]
        tabrowValueDict['CTIME']=coral.TimeStamp()
        db.insertOneRow(revisiontableName,tabrowDefDict,tabrowValueDict)
        
        tabrowDefDict={}
        tabrowDefDict['REVISION_ID']='unsigned long long'
        tabrowDefDict['ENTRY_ID']='unsigned long long'    
        tabrowDefDict['NAME']='string'
        
        tabrowValueDict={}
        tabrowValueDict['REVISION_ID']=entryinfo[0]
        tabrowValueDict['ENTRY_ID']=entryinfo[1]
        tabrowValueDict['NAME']=entryinfo[2]
        db.insertOneRow(entrytableName,tabrowDefDict,tabrowValueDict)
    
        tabrowDefDict={}
        tabrowDefDict['REVISION_ID']='unsigned long long'
        tabrowDefDict['DATA_ID']='unsigned long long'
        tabrowValueDict={}
        tabrowValueDict['REVISION_ID']=entryinfo[0]
        tabrowValueDict['DATA_ID']=entryinfo[3]
        db.insertOneRow(revtableName,tabrowDefDict,tabrowValueDict)
    except:
        raise