i@ ddlZddlmZddlmZddlmZmZddlm Z m Z m Z ddl m Z ejeZe j"Zesede eddd d d d d Ze ee d d ZedZdefdZdZy)N)asynccontextmanager)declarative_base)MetaDatatext)create_async_engine AsyncSessionasync_sessionmaker)settingsz/Database URL not configured. Please set DB_URL. iTF) pool_size max_overflow pool_timeout pool_recycle pool_pre_pingechofuture)bindclass_expire_on_commit autoflushc$Kt} | |j d{y#t$r7}|jd{7tj d|d}~wwxYw7H#|j d{7wxYww)zm Async DB session (non-blocking) Usage: async with get_async_db() as db: ... Nz"DB session rollback due to error: )AsyncSessionLocal Exceptionrollbackloggererrorclosesessiones >/var/www/html/ls-ibe-bot-apis-staging/app/models/connection.py get_async_dbr#3sz./G mmo     9!=>  gmmosX B-BA0B A-A( A  A((A--A20B2B B B  BreturncTK t4d{}|jtdd{dddd{tj dy7L7,7#1d{7swY.xYw#t $r"}tj d|Yd}~yd}~wwxYww)z Verify DB connection NzSELECT 1u✅ Database connection OKTu ❌ Database connection failed: F)r#executerrinforrrs r"check_database_connectionr(Is>>W//$z"23 3 3"> 01" 3">>>  7s;<sB(A:AA:A%A!A% A:A#A:B(A:!A%#A:%A7+A. ,A73A:: B%B B( B%%B(cK tjd{tjdy7#t$r"}tj d|Yd}~yd}~wwxYww)z9 Close all DB connections (call on app shutdown) Nu 🧹 Database connections closedzError closing DB connections: ) async_enginedisposerr'rr)r!s r"cleanup_connectionsr,ZsU;""$$$ 67 % ; 5aS9::;s7A&868A&8 A#AA&A##A&)logging contextlibrsqlalchemy.ormr sqlalchemyrrsqlalchemy.ext.asynciorrr app.configs.settingsr getLogger__name__rDB_URL DATABASE_URL ValueErrorr*rr#boolr(r,r"r;s*+% *   8 $   F GG #    '   *  ";r: