sessionManager.sessionManager Class Reference

Inheritance diagram for sessionManager.sessionManager:

Public Member Functions
def	__del__ (self)
def	__init__ (self, connectString, authpath=None, siteconfpath=None, debugON=False)
def	defaultfrontierConfigString ()
def	openSession (self, isReadOnly=True, cpp2sqltype=[], sql2cpptype=[])
def	realConnectString (self)
def	svcHandle (self)

Private Attributes
	__connectparser
	__connectString
	__svc

Detailed Description

Definition at line 5 of file sessionManager.py.

Constructor & Destructor Documentation

def sessionManager.sessionManager.__init__	(		self,
			connectString,
			authpath = None,
			siteconfpath = None,
			debugON = False
	)

Definition at line 9 of file sessionManager.py.

    def __init__(self,connectString,authpath=None,siteconfpath=None,debugON = False):
        self.__connectString=connectString
        self.__svc=None
        self.__connectparser=connectstrParser.connectstrParser(self.__connectString)
        usedefaultfrontierconfig = False
        cacheconfigpath = ''
        try:
            self.__connectparser.parse()
            if self.__connectparser.needsitelocalinfo():
                if not siteconfpath:
                    cacheconfigpath = os.environ['CMS_PATH']
                    if cacheconfigpath:
                        cacheconfigpath = os.path.join (cacheconfigpath, 'SITECONF', 'local', 'JobConfig', 'site-local-config.xml')
                    else:
                        usedefaultfrontierconfig = True
                else:
                    cacheconfigpath = siteconfpath
                    cacheconfigpath = os.path.join (cacheconfigpath, 'site-local-config.xml')
                ccp = cacheconfigParser.cacheconfigParser()
                if usedefaultfrontierconfig:
                    ccp.parseString ( self.defaultfrontierConfigString() )
                else:
                    ccp.parse (cacheconfigpath)
                self.__connectString = self.__connectparser.fullfrontierStr(self.__connectparser.schemaname(), ccp.parameterdict())
            if self.__connectparser.protocol()=='oracle':
                if authpath:
                    os.environ['CORAL_AUTH_PATH']=authpath
                else:
                    os.environ['CORAL_AUTH_PATH']='.'
            if debugON :
                msg = coral.MessageStream ('')
                msg.setMsgVerbosity (coral.message_Level_Debug)            
            self.__svc = coral.ConnectionService()
        except:
            if self.__svc: del self.__svc
            raise

def sessionManager.sessionManager.__del__

(

self

)

Definition at line 62 of file sessionManager.py.

References sessionManager.sessionManager.__svc.

    def __del__(self):
        del self.__svc

Member Function Documentation

def sessionManager.sessionManager.defaultfrontierConfigString

(

)

Definition at line 6 of file sessionManager.py.

    def defaultfrontierConfigString ():
        return '''<frontier-connect><proxy url = "http://cmst0frontier.cern.ch:3128"/><proxy url = "http://cmst0frontier.cern.ch:3128"/><proxy url = "http://cmst0frontier1.cern.ch:3128"/><proxy url = "http://cmst0frontier2.cern.ch:3128"/><server url = "http://cmsfrontier.cern.ch:8000/FrontierInt"/><server url = "http://cmsfrontier.cern.ch:8000/FrontierInt"/><server url = "http://cmsfrontier1.cern.ch:8000/FrontierInt"/><server url = "http://cmsfrontier2.cern.ch:8000/FrontierInt"/><server url = "http://cmsfrontier3.cern.ch:8000/FrontierInt"/><server url = "http://cmsfrontier4.cern.ch:8000/FrontierInt"/></frontier-connect>'''
    

def sessionManager.sessionManager.openSession	(		self,
			isReadOnly = True,
			cpp2sqltype = [],
			sql2cpptype = []
	)

Definition at line 45 of file sessionManager.py.

References sessionManager.sessionManager.__connectString.

    def openSession(self,isReadOnly=True,cpp2sqltype=[],sql2cpptype=[] ):
        try:
            session=None
            if self.__connectparser.protocol()=='frontier' or isReadOnly:
                session = self.__svc.connect(self.__connectString, accessMode = coral.access_ReadOnly)
            else:
                session = self.__svc.connect(self.__connectString, accessMode = coral.access_Update)
            for (cpptype,sqltype) in cpp2sqltype:
                session.typeConverter().setCppTypeForSqlType(cpptype,sqltype)
            for (sqltype,cpptype) in sql2cpptype:
                session.typeConverter().setSqlTypeForCppType(sqltype,cpptype)
            return session
        except:
            if session: del session
            raise

def sessionManager.sessionManager.realConnectString

(

self

)

Definition at line 60 of file sessionManager.py.

References sessionManager.sessionManager.__connectString.

    def realConnectString(self):
        return self.__connectString

def sessionManager.sessionManager.svcHandle

(

self

)

Definition at line 64 of file sessionManager.py.

References sessionManager.sessionManager.__svc.

    def svcHandle(self):
        return self.__svc

Member Data Documentation

sessionManager.sessionManager.__connectparser

private

Definition at line 12 of file sessionManager.py.

sessionManager.sessionManager.__connectString

private

Definition at line 10 of file sessionManager.py.

Referenced by sessionManager.sessionManager.openSession(), and sessionManager.sessionManager.realConnectString().

sessionManager.sessionManager.__svc

private

Definition at line 11 of file sessionManager.py.

Referenced by sessionManager.sessionManager.__del__(), and sessionManager.sessionManager.svcHandle().