X-Git-Url: http://git.veekun.com/zzz-pokedex.git/blobdiff_plain/2c0980e4dcadaa31d7ea7ebab174a6fd81723090..32fe4eedee350ddca0c66f2404967cc73f89d957:/pokedex/db/__init__.py?ds=sidebyside diff --git a/pokedex/db/__init__.py b/pokedex/db/__init__.py index ced519b..5230508 100644 --- a/pokedex/db/__init__.py +++ b/pokedex/db/__init__.py @@ -1,13 +1,22 @@ from sqlalchemy import MetaData, Table, create_engine, orm +from ..defaults import get_default_db_uri from .tables import metadata -def connect(uri, **kwargs): + +def connect(uri=None, session_args={}, engine_args={}): """Connects to the requested URI. Returns a session object. + With the URI omitted, attempts to connect to a default SQLite database + contained within the package directory. + Calling this function also binds the metadata object to the created engine. """ + # If we didn't get a uri, fall back to the default + if uri is None: + uri = get_default_db_uri() + ### Do some fixery for MySQL if uri[0:5] == 'mysql': # MySQL uses latin1 for connections by default even if the server is @@ -22,13 +31,13 @@ def connect(uri, **kwargs): table.kwargs['mysql_charset'] = 'utf8' ### Connect - engine = create_engine(uri) + engine = create_engine(uri, **engine_args) conn = engine.connect() metadata.bind = engine - session_args = dict(autoflush=True, autocommit=False, bind=engine) - session_args.update(kwargs) - sm = orm.sessionmaker(**session_args) + all_session_args = dict(autoflush=True, autocommit=False, bind=engine) + all_session_args.update(session_args) + sm = orm.sessionmaker(**all_session_args) session = orm.scoped_session(sm) return session