diff --git a/app/db_sql.py b/app/db_sql.py index 5c41f75..8e080de 100644 --- a/app/db_sql.py +++ b/app/db_sql.py @@ -11,7 +11,7 @@ from sqlalchemy.exc import IntegrityError, OperationalError db_uri = settings.SQLALCHEMY_DB_URI connection_string = db_uri -engine = create_engine(url=connection_string, pool_size=25, pool_recycle=600, pool_pre_ping=True, echo=False, echo_pool=True, isolation_level='READ COMMITTED', connect_args={'connect_timeout': 30}) +engine = create_engine(url=connection_string, pool_size=5, max_overflow=10, pool_recycle=3600, pool_pre_ping=True, echo=False, echo_pool=True, isolation_level='READ COMMITTED', connect_args={'connect_timeout': 30}) # NOTE: The default isolation_level is 'REPEATABLE READ'. This can sometimes not show updated data. # NOTE: The "echo" set to True option shows the SQL queries. @@ -55,7 +55,7 @@ def sql_connect( settings.SQLALCHEMY_DB_URI = 'mysql://'+DB['username']+':'+DB['password']+'@'+DB['server']+'/'+DB['name'] log.debug(settings.DB) - new_engine = create_engine(url=settings.SQLALCHEMY_DB_URI, pool_size=25, pool_recycle=3660, pool_pre_ping=True, echo=False, echo_pool=True, isolation_level='READ COMMITTED', connect_args={'connect_timeout': 30}) + new_engine = create_engine(url=settings.SQLALCHEMY_DB_URI, pool_size=5, max_overflow=10, pool_recycle=3600, pool_pre_ping=True, echo=False, echo_pool=True, isolation_level='READ COMMITTED', connect_args={'connect_timeout': 30}) current_db.engine = new_engine log.info(f'Created and connected to database: {settings.SQLALCHEMY_DB_URI}') diff --git a/app/main.py b/app/main.py index 14d0e31..858e0de 100644 --- a/app/main.py +++ b/app/main.py @@ -10,8 +10,8 @@ from functools import lru_cache from pydantic import BaseModel, EmailStr, Field from typing import Dict, List, Optional, Set, Union -from sqlalchemy import create_engine, text -from sqlalchemy.exc import IntegrityError, OperationalError +# from sqlalchemy import create_engine, text +# from sqlalchemy.exc import IntegrityError, OperationalError from . import config # from app.lib_general import common_route_params, Common_Route_Params