i@ ddlZddlmZddlmZddlmZmZddlm Z m Z m Z ddl m Z ejeZe jZes ede eddd d d d d Ze ee d d ZedZdefdZdZdS)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} |WVnJ#t$r=}|d{Vtd|d}~wwxYw |d{VdS#|d{VwxYw)zm Async DB session (non-blocking) Usage: async with get_async_db() as db: ... Nz"DB session rollback due to error: )AsyncSessionLocal Exceptionrollbackloggererrorclosesessiones 6/var/www/html/ls-ibe-bot-apis/app/models/connection.py get_async_dbr#3s.//G           =!==>>>   mmoogmmoos%A? A8AAA??BreturncjK t4d{V}|tdd{Vdddd{Vn#1d{VswxYwYtddS#t $r(}td|Yd}~dSd}~wwxYw)z Verify DB connection NzSELECT 1u✅ Database connection OKTu ❌ Database connection failed: F)r#executerrinforrrs r"check_database_connectionr(IsL>> 4 4 4 4 4 4 4W//$z"2"233 3 3 3 3 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 0111t  ;;;<<<uuuuus:B)AB AB A!B B2 B--B2cK td{VtddS#t$r(}td|Yd}~dSd}~wwxYw)z9 Close all DB connections (call on app shutdown) Nu 🧹 Database connections closedzError closing DB connections: ) async_enginedisposerr'rr)r!s r"cleanup_connectionsr,Zs;""$$$$$$$$$ 677777 ;;; 9a99:::::::::;s9? A1 A,,A1)logging contextlibrsqlalchemy.ormr sqlalchemyrrsqlalchemy.ext.asynciorrr app.configs.settingsr getLogger__name__rDB_URL DATABASE_URL ValueErrorr*rr#boolr(r,r"r;sl******++++++%%%%%%%% *)))))  8 $ $  H *F G GG #"      '&   *     ";;;;;r: