python.AtlRunQueryCOMA.ARQ_COMA Class Reference

Collaboration diagram for python.AtlRunQueryCOMA.ARQ_COMA:

Public Member Functions
def	getUsedTables (cls, output, condition)
def	query (cls, output, condition, bindvars, verbose=False)
def	cursor (cls)
def	get_periods_for_run (cls, run)
def	get_periods (cls, year=0, level=0)
def	get_all_periods (cls)
def	get_runs (cls, period, year)

Static Public Attributes
	all_periods = None

Static Private Attributes
dictionary	__store = {}
	__cursor = None
string	__schema = "ATLAS_TAGS_METADATA"
dictionary	__tables

Detailed Description

Definition at line 17 of file AtlRunQueryCOMA.py.

Member Function Documentation

cursor()

def python.AtlRunQueryCOMA.ARQ_COMA.cursor

(

cls

)

get COMA connection
any connection to ATLR is fine, we use Trigger DB

Definition at line 55 of file AtlRunQueryCOMA.py.

    def cursor(cls):
        """get COMA connection
        any connection to ATLR is fine, we use Trigger DB
        """
        if not cls.__cursor:
 
            from CoolRunQuery.utils.AtlRunQueryTriggerUtils import interpretConnection
            connectionParameters = interpretConnection("TRIGGERDB")
            
            from cx_Oracle import connect
            connection = connect ( connectionParameters["user"],
                                   connectionParameters["passwd"],
                                   connectionParameters["server"], threaded=True)
            cls.__cursor = connection.cursor()
 
        return cls.__cursor
 
 
 
 
 

get_all_periods()

def python.AtlRunQueryCOMA.ARQ_COMA.get_all_periods

(

cls

)

Definition at line 111 of file AtlRunQueryCOMA.py.

    def get_all_periods(cls):
        if cls.all_periods is not None:
            return cls.all_periods
        cls.all_periods = []
        p = re.compile(r"(?P<periodletter>[A-Za-z]+)(?P<periodnumber>\d+)?$")
        try:
            result = cls.get_periods(0, 0)
            for period, projectName in result:
                year = int(projectName[4:6])
                m = p.match(period)
                if not m:
                    print ("Period '%s'does not match pattern  [A-Za-z]+\\d+" % period)
                    continue
 
                period_letter = m.group('periodletter')
                period_number = int(m.group('periodnumber')) if m.group('periodnumber') else 0
                if len(period_letter)!=1:
                    pc = 0
                else:
                    pc = 10000*year + 100*(ord(period_letter.upper())-65) + period_number
 
                cls.all_periods += [ ((year, period, pc, projectName), projectName+".period" + period) ]
 
            cls.all_periods.sort()
        except Exception:
            import traceback
            traceback.print_exc()
            pass
        return cls.all_periods
    
 

get_periods()

def python.AtlRunQueryCOMA.ARQ_COMA.get_periods	(		cls,
			year = 0,
			level = 0
	)

Definition at line 93 of file AtlRunQueryCOMA.py.

    def get_periods(cls, year=0, level=0):
        output = ['PR.P_PERIOD', 'PR.P_PROJECT' ]
        condition = []
        bindvars = {}
 
        if level>0:
            condition += [ "PR.P_LEVEL=:lvl" ]
            bindvars["lvl"] = level
 
        if year>2000:
            project = 'data%02i%%' % (year-2000)
            condition += [ "PR.P_PROJECT like :proj" ]
            bindvars["proj"] = project
 
        return sorted( cls.query(output, condition, bindvars) )
 
 

get_periods_for_run()

def python.AtlRunQueryCOMA.ARQ_COMA.get_periods_for_run	(		cls,
			run
	)

Definition at line 77 of file AtlRunQueryCOMA.py.

    def get_periods_for_run(cls, run):
        try:
            run = int(run)
        except ValueError:
            return []
        if run not in cls.__store:
            output = ['PR.P_LEVEL', 'PR.P_PERIOD', 'PR.P_PROJECT' ]
            condition = [ "PR.RUN_INDEX = :run" ]
            bindvars = { "run": run }
 
            cls.__store[run] = sorted( cls.query(output, condition, bindvars) )
 
        return [x[1] for x in cls.__store[run]]
 
 

get_runs()

def python.AtlRunQueryCOMA.ARQ_COMA.get_runs	(		cls,
			period,
			year
	)

Definition at line 143 of file AtlRunQueryCOMA.py.

    def get_runs(cls, period, year):
        output = ['PR.RUN_INDEX', 'PR.P_LEVEL', 'PR.P_PERIOD', 'PR.P_PROJECT' ]
 
        condition = [ "PR.P_PERIOD=:period" ]
        bindvars = { "period" : period }
        if year>2000:
            project = 'data%02i%%' % (year-2000)
            condition += [ "PR.P_PROJECT like :proj" ]
            bindvars["proj"] = project
        result = cls.query(output, condition, bindvars)
 
        tmpstore = {}
 
        for record in result:
            run = record[0]
            info = record[1:4]
            if run not in tmpstore:
                tmpstore[run] = []
            tmpstore[run] += [info]
 
        cls.__store.update(tmpstore)
        
        return sorted( [r[0] for r in result] )
 
 
 
# for testing purpose

getUsedTables()

def python.AtlRunQueryCOMA.ARQ_COMA.getUsedTables	(		cls,
			output,
			condition
	)

Definition at line 30 of file AtlRunQueryCOMA.py.

    def getUsedTables(cls, output, condition):
        usedtables = set( [o.split('.')[0] for o in output] ) # all tables specified in output fields
 
        for c in condition:
            for p in c.split():
                if '.' in p and '\'' not in p:
                    usedtables.add(p.split('.')[0].lstrip('(')) # all tables specified in conditions
 
        return ["%s.%s %s" % (cls.__schema,cls.__tables[t],t) for t in usedtables] # prefix schema name to table name
 
 

query()

def python.AtlRunQueryCOMA.ARQ_COMA.query	(		cls,
			output,
			condition,
			bindvars,
			verbose = False
	)

Definition at line 42 of file AtlRunQueryCOMA.py.

    def query(cls, output, condition, bindvars, verbose=False):
        query = 'select distinct %s from %s' % (', '.join(output),
                                                ', '.join(cls.getUsedTables(output, condition)))
        if condition:
            query += ' where ' + ' and '.join(condition)
        if verbose:
            print ("="*80,"\n",query)
        c = cls.cursor()
        c.execute(str(query),bindvars)
        return c.fetchall()
 
 

Member Data Documentation

__cursor

python.AtlRunQueryCOMA.ARQ_COMA.__cursor = None

staticprivate

Definition at line 22 of file AtlRunQueryCOMA.py.

__schema

string python.AtlRunQueryCOMA.ARQ_COMA.__schema = "ATLAS_TAGS_METADATA"

staticprivate

Definition at line 23 of file AtlRunQueryCOMA.py.

__store

dictionary python.AtlRunQueryCOMA.ARQ_COMA.__store = {}

staticprivate

Definition at line 19 of file AtlRunQueryCOMA.py.

__tables

dictionary python.AtlRunQueryCOMA.ARQ_COMA.__tables

staticprivate

Initial value:

=  {
        'PR'  : 'COMA_V_PERIOD_RUNS',
        }

Definition at line 25 of file AtlRunQueryCOMA.py.

all_periods

python.AtlRunQueryCOMA.ARQ_COMA.all_periods = None

static

Definition at line 20 of file AtlRunQueryCOMA.py.

---

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

• AtlRunQueryCOMA.py