conddblib.Connection Class Reference

Inheritance diagram for conddblib.Connection:

Public Member Functions
def	__init__ (self, url)
def	get_dbtype (self, theType)
def	init (self, drop=False)
def	is_frontier (self)
def	is_official (self)
def	is_oracle (self)
def	is_read_only (self)
def	is_sqlite (self)
def	is_valid (self)
def	metadata (self)
def	session (self)

Public Attributes
	engine

Private Attributes
	_backendName
	_is_frontier
	_is_official
	_is_oracle
	_is_read_only
	_is_sqlite
	_is_valid
	_schemaName
	_session
	_url

Detailed Description

Definition at line 321 of file conddblib.py.

Constructor & Destructor Documentation

__init__()

def conddblib.Connection.__init__	(		self,
			url
	)

Definition at line 323 of file conddblib.py.

    def __init__(self, url):
        # Workaround to avoid creating files if not present.
        # Python's sqlite3 module does not use sqlite3_open_v2(),
        # and therefore we cannot disable SQLITE_OPEN_CREATE.
        # Only in the case of creating a new database we skip the check.
        if url.drivername == 'sqlite':

            self.engine = sqlalchemy.create_engine(url)

            enabled_foreign_keys = self.engine.execute('pragma foreign_keys').scalar()
            supports_foreign_keys = enabled_foreign_keys is not None
            if not supports_foreign_keys:
                logger.warning('Your SQLite database does not support foreign keys, so constraints will not be checked. Please upgrade.')
            elif not enabled_foreign_keys:
                self.engine.execute('pragma foreign_keys = on')

        else:
            self.engine = sqlalchemy.create_engine(url, max_identifier_length=30)

        self._session = sqlalchemy.orm.scoped_session(sqlalchemy.orm.sessionmaker(bind=self.engine))

        self._is_frontier = url.drivername == 'oracle+frontier'
        self._is_oracle = url.drivername == 'oracle'
        self._is_sqlite = url.drivername == 'sqlite'

        self._is_read_only = self._is_frontier or url.host in {
            'cms_orcon_adg',
            'cmsarc_lb',
        }

        self._is_official = self._is_frontier or url.host in {
            'cms_orcon_adg',
            'cmsarc_lb',
            'cms_orcoff_int',
            'cms_orcoff_prep',
            'cms_orcon_prod',
            'cmsintr_lb',
        }
        self._url = url
        self._backendName = ('sqlite' if self._is_sqlite else 'oracle' ) 
        self._schemaName = ( None if self._is_sqlite else schema_name )
        logging.debug('Loading db types...')
        self.get_dbtype(Tag).__name__
        self.get_dbtype(Payload)
        self.get_dbtype(IOV)
        self.get_dbtype(TagLog)
        self.get_dbtype(GlobalTag)
        self.get_dbtype(GlobalTagMap)
        self.get_dbtype(RunInfo)
        if not self._is_sqlite:
            self.get_dbtype(TagMetadata)
            self.get_dbtype(TagAuthorization)
            self.get_dbtype(BoostRunMap)
        self._is_valid = self.is_valid()

Member Function Documentation

get_dbtype()

def conddblib.Connection.get_dbtype	(		self,
			theType
	)

Definition at line 378 of file conddblib.py.

References conddblib.Connection._backendName, conddblib.Connection._schemaName, relativeConstraints.keys, and conddblib.make_dbtype().

Referenced by conddblib.Connection.init(), conddblib.Connection.is_valid(), and conddblib.Connection.session().

    def get_dbtype(self,theType):
        basename = theType.__name__
        if self._backendName not in db_models.keys() or basename not in db_models[self._backendName].keys():
            return make_dbtype( self._backendName, self._schemaName, theType )
        else:
            return db_models[self._backendName][basename]

init()

def conddblib.Connection.init	(		self,
			drop = False
	)

Initializes a database.

Definition at line 429 of file conddblib.py.

References conddblib.Connection._is_valid, querying.connection.engine, conddblib.Connection.engine, conddblib.Connection.get_dbtype(), and conddblib.Connection.metadata().

    def init(self, drop=False):
        '''Initializes a database.
        '''
        logging.info('Initializing database...')
        if drop:
            logging.debug('Dropping tables...')
            self.metadata.drop_all(self.engine)
            self._is_valid = False
        else:
            if not self._is_valid:
                logging.debug('Creating tables...')
                self.get_dbtype(Tag).__table__.create(bind = self.engine)
                self.get_dbtype(Payload).__table__.create(bind = self.engine)
                self.get_dbtype(IOV).__table__.create(bind = self.engine)
                self.get_dbtype(TagLog).__table__.create(bind = self.engine)
                self.get_dbtype(GlobalTag).__table__.create(bind = self.engine)
                self.get_dbtype(GlobalTagMap).__table__.create(bind = self.engine)
                self._is_valid = True

is_frontier()

def conddblib.Connection.is_frontier

(

self

)

Definition at line 398 of file conddblib.py.

References conddblib.Connection._is_frontier.

    def is_frontier(self):
        return self._is_frontier

is_official()

def conddblib.Connection.is_official

(

self

)

Definition at line 414 of file conddblib.py.

References conddblib.Connection._is_official.

    def is_official(self):
        return self._is_official

is_oracle()

def conddblib.Connection.is_oracle

(

self

)

Definition at line 402 of file conddblib.py.

References conddblib.Connection._is_oracle.

Referenced by conddblib.Connection.session().

    def is_oracle(self):
        return self._is_oracle

is_read_only()

def conddblib.Connection.is_read_only

(

self

)

Definition at line 410 of file conddblib.py.

References conddblib.Connection._is_read_only.

    def is_read_only(self):
        return self._is_read_only

is_sqlite()

def conddblib.Connection.is_sqlite

(

self

)

Definition at line 406 of file conddblib.py.

References conddblib.Connection._is_sqlite.

    def is_sqlite(self):
        return self._is_sqlite

is_valid()

def conddblib.Connection.is_valid

(

self

)

Tests whether the current DB looks like a valid CMS Conditions one.

Definition at line 417 of file conddblib.py.

References python.cmstools.all(), conddblib.connect(), querying.connection.engine, conddblib.Connection.engine, conddblib.Connection.get_dbtype(), and conddblib.getSchema().

    def is_valid(self):
        '''Tests whether the current DB looks like a valid CMS Conditions one.
        '''
        engine_connection = self.engine.connect()
        # temporarely avoid the check on the GT tables - there are releases in use where C++ does not create these tables.
        _Tag = self.get_dbtype(Tag)
        _IOV = self.get_dbtype(IOV)
        _Payload = self.get_dbtype(Payload) 
        ret = all([self.engine.dialect.has_table(engine_connection, table.__tablename__,getSchema(table)) for table in [_Tag, _IOV, _Payload]])
        engine_connection.close()
        return ret

metadata()

def conddblib.Connection.metadata

(

self

)

Definition at line 394 of file conddblib.py.

Referenced by conddblib.Connection.init().

    def metadata(self):
        return _Base.metadata

session()

def conddblib.Connection.session

(

self

)

Definition at line 385 of file conddblib.py.

References conddblib.Connection._is_sqlite, conddblib.Connection._session, url_query.url_query._url, conddblib.Connection._url, conddblib.Connection.get_dbtype(), and conddblib.Connection.is_oracle().

    def session(self):
        s = self._session()
        s.get_dbtype = self.get_dbtype
        s._is_sqlite = self._is_sqlite
        s.is_oracle = self.is_oracle
        s._url = self._url
        return s

Member Data Documentation

_backendName

conddblib.Connection._backendName

private

Definition at line 362 of file conddblib.py.

Referenced by conddblib.Connection.get_dbtype().

_is_frontier

conddblib.Connection._is_frontier

private

Definition at line 344 of file conddblib.py.

Referenced by conddblib.Connection.is_frontier().

_is_official

conddblib.Connection._is_official

private

Definition at line 353 of file conddblib.py.

Referenced by conddblib.Connection.is_official().

_is_oracle

conddblib.Connection._is_oracle

private

Definition at line 345 of file conddblib.py.

Referenced by conddblib.Connection.is_oracle().

_is_read_only

conddblib.Connection._is_read_only

private

Definition at line 348 of file conddblib.py.

Referenced by conddblib.Connection.is_read_only().

_is_sqlite

conddblib.Connection._is_sqlite

private

Definition at line 346 of file conddblib.py.

Referenced by conddblib.Connection.is_sqlite(), and conddblib.Connection.session().

_is_valid

conddblib.Connection._is_valid

private

Definition at line 376 of file conddblib.py.

Referenced by conddblib.Connection.init().

_schemaName

conddblib.Connection._schemaName

private

Definition at line 363 of file conddblib.py.

Referenced by conddblib.Connection.get_dbtype().

_session

conddblib.Connection._session

private

Definition at line 342 of file conddblib.py.

Referenced by conddblib.Connection.session().

_url

conddblib.Connection._url

private

Definition at line 361 of file conddblib.py.

Referenced by conddblib.Connection.session().

engine

conddblib.Connection.engine

Definition at line 330 of file conddblib.py.

Referenced by o2o_db_manager.DbManager.connect(), conddblib.Connection.init(), and conddblib.Connection.is_valid().