sim_check_batch.DataBase Class Reference

Inheritance diagram for sim_check_batch.DataBase:

Collaboration diagram for sim_check_batch.DataBase:

Public Member Functions
def	__init__ (self, fname)
def	openConnection (self)
def	insert (self, tname='t_run', hargs=[], args=[])
def	dummyHostInfo (self)
def	addRun (self)
def	addFile (self, fl)
def	addFunction (self, fn)
def	addFunctions (self, parser)
def	addCountAndLinks (self, rid, parser=None)

Public Attributes
	fname
	cnx
	cur
	rid
	parser

Private Member Functions
def	_execute (self, cmd, args=())
def	_dumpTable (self, t)

Detailed Description

Definition at line 26 of file sim_check_batch.py.

Constructor & Destructor Documentation

__init__()

def sim_check_batch.DataBase.__init__	(		self,
			fname
	)

Definition at line 27 of file sim_check_batch.py.

    def __init__(self,fname):
        self.fname=fname
        self.cnx=None
        self.cur=None
 

Member Function Documentation

_dumpTable()

def sim_check_batch.DataBase._dumpTable (   self,   t  )

private

Definition at line 41 of file sim_check_batch.py.

    def _dumpTable(self,t):
        #t = (symbol,)
        #cur.execute('select * from stocks where symbol=?', t)
        self._execute('select * from %s'%t)
        header= [ s[0] for s in self.cur.description ]
        format= ' '.join([ '%25s' for s in self.cur.description])
        print format%tuple(header)
        for res in self.cur.fetchall():
            print format%res
 
 

_execute()

def sim_check_batch.DataBase._execute (   self,   cmd,   args = ()  )

private

Definition at line 37 of file sim_check_batch.py.

    def _execute(self,cmd,args=()):
        print 'SQL:',cmd,args
        self.cur.execute(cmd,args)
 

addCountAndLinks()

def sim_check_batch.DataBase.addCountAndLinks	(		self,
			rid,
			parser = None
	)

Definition at line 141 of file sim_check_batch.py.

    def addCountAndLinks(self,rid,parser=None):
        if parser!=None:
            self.parser=parser
 
        success=True
        for fn in parser.functions.values():
            if fn.dbid is None:
                print 'ERROR fn=',fn.fn,'not in db yet'
                self.addFunction(fn)
 
            hargs=['rid','fid','selfcounts','totalcounts']
            args=[rid,fn.dbid,fn.selfcost,fn.totalcost]
            # add counts to db
            try:
                self.insert('t_counts',hargs,args)
            except IntegrityError as detail:
                print 'IntegrityError',detail
                success=False
                print 'fn=',fn
                continue
 
            # add sub call links to db
            for i,counts in fn.calls.iteritems():
                if i!=0:
                    cfn=self.parser.functions[i]
                    if cfn.dbid is None:
                        print 'ERROR cfn=',cfn.fn,'not in db yet'
                        self.addFunction(cfn)
                    hargs=['rid','fid','cfunid','counts']
                    args=[rid,fn.dbid,cfn.dbid,counts]
                    try:
                        self.insert('t_links',hargs,args)
                    except IntegrityError as detail:
                        print 'IntegrityError',detail
                        success=False
                        print 'fn=',fn
                        print 'cfn=',cfn
                        
        if success:
            self.cnx.commit()
        else:
            print 'some ERROR occured rolling back'
            self.cnx.rollback()
 
 

addFile()

def sim_check_batch.DataBase.addFile	(		self,
			fl
	)

Definition at line 97 of file sim_check_batch.py.

    def addFile(self,fl):
        "add file entry to db and return id"
        # check if already registered
        if fl.dbid is not None:
            return fl.dbid
 
        # check if database
        cmd='select id from t_files where fl_name=?'
        self._execute(cmd,(fl.fl,))
        res=self.cur.fetchone()
        if res is None:
            print 'WARNING',fl.fl,'not found'
            # adding it
            id=self.insert('t_files',['fl_name'],[fl.fl])
        else:
            # receive existing entry
            id=res[0]
        fl.dbid=id
        return id
 

addFunction()

def sim_check_batch.DataBase.addFunction	(		self,
			fn
	)

Definition at line 117 of file sim_check_batch.py.

    def addFunction(self,fn):
        if self.parser.filelist.has_key(fn.fl_id):
            fl=self.parser.filelist[fn.fl_id]
            fid=self.addFile(fl)
        else:
            fid=0
        cmd='select id from t_functions where fn_name=? and fid=? and issue=?'
        self._execute(cmd,(fn.fn,fid,fn.issue))
        res=self.cur.fetchone()
        if res is None:
            # adding it
            hargs=['fn_name','fid','issue','lib']
            args=[fn.fn,fid,fn.issue,fn.lib]
            id = self.insert('t_functions',hargs,args)
        else:
            id = res[0]
        fn.dbid=id
    

addFunctions()

def sim_check_batch.DataBase.addFunctions	(		self,
			parser
	)

Definition at line 135 of file sim_check_batch.py.

    def addFunctions(self,parser):
        self.parser=parser
        for fn in parser.functions.values():
            self.addFunction(fn)
        self.cnx.commit()
 

addRun()

def sim_check_batch.DataBase.addRun

(

self

)

Definition at line 74 of file sim_check_batch.py.

    def addRun(self):
 
        #AtlasArea=/afs/cern.ch/atlas/software/builds/nightlies/devval/AtlasProduction/rel_2
        atlasArea=os.getenv('AtlasArea')
        dummy,branch,proj,rel=atlasArea.rsplit('/',3)
 
        #LS_SUBCWD=/afs/cern.ch/atlas/project/RTT/prod/Results/rtt/rel_2/devval/build/x86_64-slc5-gcc43-opt/offline/SimCoreTests/AtlasG4_muons
        subcwd=os.getenv('LS_SUBCWD')
        dummy1,cmt,dummy2,package,job=subcwd.rsplit('/',4)
 
        rdate,rtime=dt.datetime.now().strftime('%Y-%m-%d %H:%M:%S').split()
 
        hostInfo=getHost()
        hostInfo=dict(zip(*hostInfo))
 
        machine=hostInfo['HOST_NAME']
        KSI2K_fac=float(hostInfo['cpuf'])
        hargs=['branch', 'rel', 'cmt', 'rdate', 'rtime', 'machine', 'KSI2K_fac', 'package', 'job']
        args=[locals()[x] for x in hargs]
        id=self.insert('t_run',hargs,args)
        self.cnx.commit()
        return id
 

dummyHostInfo()

def sim_check_batch.DataBase.dummyHostInfo

(

self

)

Definition at line 62 of file sim_check_batch.py.

    def dummyHostInfo(self):
        hostInfo={'HOST_NAME': 'lxplus443',
                  'RESOURCES': '(intel plus quadcore wan)',
                  'cpuf': '1.9',
                  'maxmem': '48161M',
                  'maxswp': '51207M',
                  'model': 'vi_10_24',
                  'ncpus': '8',
                  'server': 'Yes',
                  'type': 'SLC5_64'}
        return hostInfo
 

insert()

def sim_check_batch.DataBase.insert	(		self,
			tname = 't_run',
			hargs = [],
			args = []
	)

Definition at line 52 of file sim_check_batch.py.

    def insert(self,tname='t_run',hargs=[],args=[]):
        "create prepared statement and execute"
        keys=','.join(hargs)
        vals=','.join(('?',)*len(args))
        cmd="insert into %s (%s) values (%s)"%(tname,keys,vals)
        print cmd,args
        self.cur.execute(cmd,args)
        self.rid=self.cur.lastrowid
        return self.rid
 

openConnection()

def sim_check_batch.DataBase.openConnection

(

self

)

Definition at line 32 of file sim_check_batch.py.

    def openConnection(self):
        import sqlite3
        self.cnx = sqlite3.connect(self.fname)
        self.cur = self.cnx.cursor()
 

Member Data Documentation

cnx

sim_check_batch.DataBase.cnx

Definition at line 29 of file sim_check_batch.py.

cur

sim_check_batch.DataBase.cur

Definition at line 30 of file sim_check_batch.py.

fname

sim_check_batch.DataBase.fname

Definition at line 28 of file sim_check_batch.py.

parser

sim_check_batch.DataBase.parser

Definition at line 136 of file sim_check_batch.py.

rid

sim_check_batch.DataBase.rid

Definition at line 59 of file sim_check_batch.py.

---

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

• sim_check_batch.py