python::CommonUtils Namespace Reference

Functions
def	commentTableName
def	dropAllTreeTables
def	inventoryIDTableName
def	inventoryTableName
def	tagInTrees
def	treeIDTableName
def	treeTableName
Variables
tuple	hello = tagInTrees(session,'Tracker_Geometry_CRUZ3')
tuple	intrees = tagInTrees(session,'Tracker_Geometry_CRUZET3')
tuple	kitty = tagInTrees(session,'Tracker_Geometry_CRUZET3','pfnme')
tuple	mikey = tagInTrees(session,'Tracker_Geometry_CRUZET3','frontier://(proxyurl=http://localhost:3128)(serverurl=http://frontier1.cms:8000/FrontierOnProd)(serverurl=http://frontier2.cms:8000/FrontierOnProd)(retrieve-ziplevel=0)/CMS_COND_20X_ALIGNMENT')
tuple	session
tuple	svc = coral.ConnectionService()

---

Function Documentation

def python::CommonUtils::commentTableName

(

)

Definition at line 10 of file CommonUtils.py.

                      :
        return 'ENTRYCOMMENT_TABLE'

def python::CommonUtils::dropAllTreeTables

(

dbsession

)

drop all tagtree related tables

Definition at line 14 of file CommonUtils.py.

00015                                 :
00016     """drop all tagtree related tables
00017     """
00018     try:
00019         dbsession.transaction().start(False)
00020         tablelist = dbsession.nominalSchema().listTables()
00021         for tname in tablelist:
00022            if tname.find('TAGTREE_') != -1:
00023               dbsession.nominalSchema().dropTable(tname)
00024         dbsession.transaction().commit()
00025     except Exception, e:
00026         raise Exception, str(e)
            

def python::CommonUtils::inventoryIDTableName

(

)

Definition at line 4 of file CommonUtils.py.

00005                           :
        return 'TAGINVENTORY_IDS'

def python::CommonUtils::inventoryTableName

(

)

Definition at line 2 of file CommonUtils.py.

00003                         :
        return 'TAGINVENTORY_TABLE'

def python::CommonUtils::tagInTrees	(		dbsession,
			tagname,
			pfn = ''
	)

returns the tree names which contain the given tag
   select tagid from taginventory_table where tagname=tagname
   select count(*) from tablename where tablename.tagid=tagid

Definition at line 27 of file CommonUtils.py.

                                        :
    """returns the tree names which contain the given tag
       select tagid from taginventory_table where tagname=tagname
       select count(*) from tablename where tablename.tagid=tagid
    """
    try:
        dbsession.transaction().start(True)    
        invquery = dbsession.nominalSchema().tableHandle(inventoryTableName()).newQuery()
        conditionbindDict=coral.AttributeList()
        conditionbindDict.extend('tagname','string')
        conditionbindDict['tagname'].setData(tagname)
        condition='tagname = :tagname'
        if len(pfn) !=0 :
           condition+=' AND pfn = :pfn'
           conditionbindDict.extend('pfn','string')
           conditionbindDict['pfn'].setData(pfn)
        invquery.setCondition(condition,conditionbindDict)
        invquery.addToOutputList('tagid')
        invquery.addToOutputList('pfn')
        cursor = invquery.execute()
        tagidmap={}
        while ( cursor.next() ):
            tagid=cursor.currentRow()['tagid'].data()
            pfn=cursor.currentRow()['pfn'].data()
            tagidmap[pfn]=tagid
        cursor.close()
        dbsession.transaction().commit()
        del invquery
        if len(tagidmap)==0:
           return tagidmap
   
        result={}
        treetablelist=[]
        dbsession.transaction().start(True)    
        tablelist = dbsession.nominalSchema().listTables()
        for t in tablelist:
           if t.find('TAGTREE_TABLE_')!= -1:
                   treetablelist.append(t)
        for (pfn,tagid) in tagidmap.items():
           result[pfn]=[]
           condition='tagid = :tagid'
           for t in treetablelist:
              conditionBind=coral.AttributeList()
              conditionBind.extend('tagid','unsigned long')
              conditionBind['tagid'].setData(tagid)
              q=dbsession.nominalSchema().tableHandle(t).newQuery()
              q.addToOutputList('count(*)','count')
              myresult=coral.AttributeList() 
              myresult.extend('count','unsigned long')
              q.defineOutput(myresult)
              q.setCondition(condition,conditionBind)
              cr=q.execute()
              while (cr.next()):
                if cr.currentRow()['count'].data()!=0:
                  result[pfn].append(t[len('TAGTREE_TABLE_'):])
              cr.close()
              del q
        dbsession.transaction().commit()        
        return result    
    except Exception, e:
        raise Exception, str(e)

def python::CommonUtils::treeIDTableName

(

treename

)

Definition at line 8 of file CommonUtils.py.

00009                              :
        return 'TAGTREE_'+str.upper(treename)+'_IDS'

def python::CommonUtils::treeTableName

(

treename

)

Definition at line 6 of file CommonUtils.py.

00007                            :
        return 'TAGTREE_TABLE_'+str.upper(treename)

---

Variable Documentation

tuple python::CommonUtils::hello = tagInTrees(session,'Tracker_Geometry_CRUZ3')

Definition at line 100 of file CommonUtils.py.

tuple python::CommonUtils::intrees = tagInTrees(session,'Tracker_Geometry_CRUZET3')

Definition at line 97 of file CommonUtils.py.

tuple python::CommonUtils::kitty = tagInTrees(session,'Tracker_Geometry_CRUZET3','pfnme')

Definition at line 103 of file CommonUtils.py.

tuple python::CommonUtils::mikey = tagInTrees(session,'Tracker_Geometry_CRUZET3','frontier://(proxyurl=http://localhost:3128)(serverurl=http://frontier1.cms:8000/FrontierOnProd)(serverurl=http://frontier2.cms:8000/FrontierOnProd)(retrieve-ziplevel=0)/CMS_COND_20X_ALIGNMENT')

Definition at line 106 of file CommonUtils.py.

tuple python::CommonUtils::session

Initial value:

svc.connect( 'sqlite_file:testInventory.db',
                           accessMode = coral.access_Update )

Definition at line 93 of file CommonUtils.py.

Referenced by ora::SchemaUtils::cleanUp(), ora::ConnectionPool::connect(), TestBase::connect(), RPCDBCom::connect(), popcon::L1RPCHwConfigSourceHandler::ConnectOnlineDB(), popcon::RPCEMapSourceHandler::ConnectOnlineDB(), RPCFw::createFEB(), RPCFw::createGAS(), RPCFw::createIDMAP(), RPCFw::createIMON(), RPCFw::createMix(), RPCFw::createSTATUS(), RPCFw::createT(), RPCFw::createUXC(), RPCFw::createVMON(), lumi::service::DBService::disconnect(), popcon::RPCEMapSourceHandler::DisconnectOnlineDB(), popcon::L1RPCHwConfigSourceHandler::DisconnectOnlineDB(), L1TriggerScalerRead::dropTable(), LumiProducer::fillLSCache(), LumiProducer::fillRunCache(), CondDBESSource::fillTagCollectionFromDB(), HcalO2OManager::getListOfPoolIovs(), HcalO2OManager::getListOfPoolTags(), cond::RDBMS::globalTag(), cond::Utilities::openDbSession(), l1t::DataWriter::payloadToken(), RunSummaryRead::readData(), RunInfoRead::readData(), L1TriggerScalerRead::readData(), DQMSummaryReader::readData(), popcon::RPCEMapSourceHandler::readEMap1(), popcon::L1RPCHwConfigSourceHandler::readHwConfig1(), l1t::DataWriter::readObject(), lumi::TRGDummy2DB::retrieveData(), lumi::LumiDummy2DB::retrieveData(), lumi::CMSRunSummaryDummy2DB::retrieveData(), lumi::Lumi2DB::retrieveData(), lumi::HLTDummy2DB::retrieveData(), lumi::HLTConfDummy2DB::retrieveData(), l1t::WriterProxyT< Record, Type >::save(), and l1t::DataWriter::writeKeyList().

tuple python::CommonUtils::svc = coral.ConnectionService()

Definition at line 92 of file CommonUtils.py.

Referenced by lumi::HLT2DB::retrieveData(), lumi::TRGDummy2DB::retrieveData(), lumi::CMSRunSummary2DB::retrieveData(), lumi::TRGWBM2DB::retrieveData(), lumi::LumiDummy2DB::retrieveData(), lumi::CMSRunSummaryDummy2DB::retrieveData(), lumi::TRG2DB::retrieveData(), lumi::Lumi2DB::retrieveData(), lumi::HLTConf2DB::retrieveData(), lumi::HLTDummy2DB::retrieveData(), and lumi::HLTConfDummy2DB::retrieveData().