2025-06-09 13:32:46 +00:00
|
|
|
from app.config import Config
|
2025-06-09 11:13:05 +00:00
|
|
|
from sqlalchemy import create_engine
|
|
|
|
|
from urllib.parse import quote_plus
|
|
|
|
|
|
2025-06-09 13:32:46 +00:00
|
|
|
def get_engine_for_company(company_id: str):
|
|
|
|
|
schema = f"hitpbx_{company_id}"
|
|
|
|
|
db_url = f"mysql+pymysql://{Config.MYSQL_USER}:{quote_plus(Config.MYSQL_PASS)}@{Config.MYSQL_HOST}:{Config.MYSQL_PORT}/{schema}?charset=utf8mb4"
|
|
|
|
|
return create_engine(db_url, pool_pre_ping=True)
|
