return
dsn = self.config.get_database_params()
+ pool_size = self.config.get_int('API_POOL_SIZE')
query = {k: v for k, v in dsn.items()
if k not in ('user', 'password', 'dbname', 'host', 'port')}
- if PGCORE_LIB == 'asyncpg':
- query['prepared_statement_cache_size'] = '0'
dburl = sa.engine.URL.create(
f'postgresql+{PGCORE_LIB}',
username=dsn.get('user'), password=dsn.get('password'),
host=dsn.get('host'), port=int(dsn['port']) if 'port' in dsn else None,
query=query)
- engine = sa_asyncio.create_async_engine(dburl, future=True)
+ engine = sa_asyncio.create_async_engine(dburl, future=True,
+ max_overflow=0, pool_size=pool_size,
+ echo=self.config.get_bool('DEBUG_SQL'))
try:
async with engine.begin() as conn: