Use default pool for Sqlite, refs #283, #163.

Browse Source
This commit is contained in:
Friedrich Lindenberg 2020-01-11 16:47:01 +01:00
parent 354a51bf98
commit b362f25816
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dataset/database.py
View File

@ -5,7 +5,6 @@ from urllib.parse import parse_qs, urlparse
from sqlalchemy import create_engine from sqlalchemy import create_engine
from sqlalchemy.sql import text from sqlalchemy.sql import text
from sqlalchemy.schema import MetaData from sqlalchemy.schema import MetaData
from sqlalchemy.pool import StaticPool
from sqlalchemy.util import safe_reraise from sqlalchemy.util import safe_reraise
from sqlalchemy.engine.reflection import Inspector from sqlalchemy.engine.reflection import Inspector
@ -31,10 +30,10 @@ class Database(object):
engine_kwargs = {} engine_kwargs = {}
parsed_url = urlparse(url) parsed_url = urlparse(url)
if parsed_url.scheme.lower() in 'sqlite': # if parsed_url.scheme.lower() in 'sqlite':
# ref: https://github.com/pudo/dataset/issues/163 # # ref: https://github.com/pudo/dataset/issues/163
if 'poolclass' not in engine_kwargs: # if 'poolclass' not in engine_kwargs:
engine_kwargs['poolclass'] = StaticPool # engine_kwargs['poolclass'] = StaticPool
self.lock = threading.RLock() self.lock = threading.RLock()
self.local = threading.local() self.local = threading.local()