python.utils.AtlRunQueryUtils.DBConnectionController Class Reference

Collaboration diagram for python.utils.AtlRunQueryUtils.DBConnectionController:

Public Member Functions
	__init__ (self)
	GetDBConn (self, schema, db)
	get_auth (self, key)
	GetAtlasRunDBConnection (self)
	GetSFODBConnection (self)
	GetTier0DBConnection (self)
	GetPVSSDBConnection (self)
	CloseAll (self)

Public Attributes
dict	openConn = {}
dict	pw = {}

Detailed Description

Definition at line 108 of file AtlRunQueryUtils.py.

Constructor & Destructor Documentation

__init__()

python.utils.AtlRunQueryUtils.DBConnectionController.__init__

(

self

)

Definition at line 109 of file AtlRunQueryUtils.py.

    def __init__(self):
        self.openConn = {}
        self.pw = {}
 

Member Function Documentation

CloseAll()

python.utils.AtlRunQueryUtils.DBConnectionController.CloseAll

(

self

)

Definition at line 179 of file AtlRunQueryUtils.py.

    def CloseAll(self):
        for (dbname,dbconn) in self.openConn.items():
            if isinstance(dbconn,cx_Oracle.Connection):
                dbconn.close()
            else:
                dbconn.closeDatabase()
 
 

get_auth()

python.utils.AtlRunQueryUtils.DBConnectionController.get_auth	(		self,
			key )

Definition at line 134 of file AtlRunQueryUtils.py.

    def get_auth(self,key):
        if key not in self.pw:
            from os import environ as env
            #lookup = XMLReader(env['CORAL_DBLOOKUP_PATH']+"/dblookup.xml")
            #for s in lookup.servicelist.logicalservices:
            #    print ("Service",s['name'])
            #    for p in s.services:
            #        print ("   name",p['name'])
            auth = XMLReader(env['CORAL_AUTH_PATH']+"/authentication.xml")
            for c in auth.connectionlist.connections:
                if key!=c['name']:
                    continue
                self.pw[key] = dict([(p['name'],p['value']) for p in c.parameters])
                break
            if key not in self.pw:
                print ("Can not authenticate DB",key)
                sys.exit(0)
        return self.pw[key]
 
 

GetAtlasRunDBConnection()

python.utils.AtlRunQueryUtils.DBConnectionController.GetAtlasRunDBConnection

(

self

)

Definition at line 154 of file AtlRunQueryUtils.py.

    def GetAtlasRunDBConnection(self):
        if 'run' not in self.openConn:
            auth = self.get_auth('oracle://ATLAS_COOLPROD/ATLAS_COOLOFL_TRIGGER')
            self.openConn['run'] = cx_Oracle.connect("%s/%s@ATLAS_COOLPROD" % (auth['user'],auth['password']))
        return self.openConn['run']
 

GetDBConn()

python.utils.AtlRunQueryUtils.DBConnectionController.GetDBConn	(		self,
			schema,
			db )

for example schema=COOLONL_TRIGGER', db='CONDBR2

Definition at line 113 of file AtlRunQueryUtils.py.

    def GetDBConn(self, schema, db):
        """for example schema=COOLONL_TRIGGER', db='CONDBR2"""
        if (schema,db) in self.openConn:
            return self.openConn[(schema,db)]
        try:
            if schema=="DEFECTS":
                #from AthenaCommon.Logging import logging # this is needed because of some problem in DQUtils logger
                # the logger there, if called first makes the athena logger crash
                defdb = DQDefects.DefectsDB("COOLOFL_GLOBAL/CONDBR2",tag=db)
                defdb.closeDatabase = lambda: None
                self.openConn[(schema,db)] = defdb
            else:
                logging=False
                from CoolConvUtilities.AtlCoolLib  import indirectOpen
                self.openConn[(schema,db)] = indirectOpen("%s/%s"%(schema,db),True, logging)
        except Exception:
            import traceback
            traceback.print_exc()
            sys.exit(-1)
        return self.openConn[(schema,db)]
 

GetPVSSDBConnection()

python.utils.AtlRunQueryUtils.DBConnectionController.GetPVSSDBConnection

(

self

)

Definition at line 173 of file AtlRunQueryUtils.py.

    def GetPVSSDBConnection(self):
        if 'pvss' not in self.openConn:
            auth = self.get_auth('oracle://ATLAS_PVSSPROD/ATLAS_PVSS_READER')
            self.openConn['pvss'] = cx_Oracle.connect("%s/%s@ATLAS_PVSSPROD" % (auth['user'],auth['password']))
        return self.openConn['pvss']
 

GetSFODBConnection()

python.utils.AtlRunQueryUtils.DBConnectionController.GetSFODBConnection

(

self

)

Definition at line 160 of file AtlRunQueryUtils.py.

    def GetSFODBConnection(self):
        if 'sfo' not in self.openConn:
            auth = self.get_auth('oracle://ATLAS_CONFIG/ATLAS_SFO_T0_R')
            with timer("Opening Connection to ATLAS_SFO_T0_R @ ATLAS_CONFIG"):
                self.openConn['sfo'] = cx_Oracle.connect("%s/%s@ATLAS_CONFIG" % (auth['user'],auth['password']))
        return self.openConn['sfo']
 

GetTier0DBConnection()

python.utils.AtlRunQueryUtils.DBConnectionController.GetTier0DBConnection

(

self

)

Definition at line 167 of file AtlRunQueryUtils.py.

    def GetTier0DBConnection(self):
        if 'tier0' not in self.openConn:
            auth = self.get_auth('oracle://ATLAS_T0/ATLAS_T0')
            self.openConn['tier0'] = cx_Oracle.connect("%s/%s@ATLAS_T0" % (auth['user'],auth['password']))
        return self.openConn['tier0']
 

Member Data Documentation

openConn

dict python.utils.AtlRunQueryUtils.DBConnectionController.openConn = {}

Definition at line 110 of file AtlRunQueryUtils.py.

pw

dict python.utils.AtlRunQueryUtils.DBConnectionController.pw = {}

Definition at line 111 of file AtlRunQueryUtils.py.

---

The documentation for this class was generated from the following file:

• AtlRunQueryUtils.py