python.utils.AtlRunQueryUtils.DBConnectionController Class Reference

Collaboration diagram for python.utils.AtlRunQueryUtils.DBConnectionController:

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

Public Attributes
	openConn
	pw

Detailed Description

Definition at line 108 of file AtlRunQueryUtils.py.

Constructor & Destructor Documentation

__init__()

def 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()

def 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()

def 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()

def 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()

def 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()

def 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()

def 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()

def 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

python.utils.AtlRunQueryUtils.DBConnectionController.openConn

Definition at line 110 of file AtlRunQueryUtils.py.

pw

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