o ՂiS @sdZddlmZmZddlmZmZddlmZddl m Z ddl m Z ddl Z e eZee jdd d d d d dddZeedddZed d edZdaddZe ddZddZddZe ddZdS)z7 Database session management with multi-tenant support ) create_engineevent) sessionmakerSession)Pool)contextmanager)settingsNTiFutf8z-c client_encoding=utf8)client_encodingoptions) pool_size max_overflow pool_pre_ping pool_recycleecho connect_argsconnectc Cst|dr"t|jtr|jnt|j}d|vr"tddS|jj}d|vr3tddSz| }| d| tdWdSt yc}zt d|WYd}~dSd}~ww) z Reset search_path to public on new connections This ensures a clean state for each connection Note: SQLite doesn't support search_path, so we skip it for SQLite connections driversqlitez*Skipping search_path for SQLite connectionNzDSkipping search_path for SQLite connection (detected via class name)zSET search_path TO publicz3Set search_path to public for PostgreSQL connectionzFailed to set search_path: )hasattr isinstancerstrlowerloggerdebug __class____name__cursorexecuteclose Exceptionwarning) dbapi_connconnection_record driver_name conn_classrer)6/lsinfo/ai/hellotax_ai/base_platform/app/db/session.pyset_search_paths$ $    r+) autocommit autoflushbindcCs,tdurttdd}|rt|ddddatS)NDATA_CENTER_DATABASE_URLT)rrr) _dc_enginegetattrrr)dc_urlr)r)r*_get_dc_engineBs  r4ccsBt}|s dVdSt|d}z |VW|dS|w)N)r.)r4rr!)enginesessionr)r)r*get_data_center_dbJs r7ccs ddlm}ddlm}t}zL|}|r%|||td|n ||dtd|VWz||dWntyV}zt d|WYd}~nd}~ww| dSz||dWnty}zt d|WYd}~nd}~ww| w)z Database session dependency for FastAPI with tenant isolation support Automatically sets PostgreSQL search_path based on tenant context. rget_current_tenant_idTenantSchemaManagerz'Database session created for tenant_id=Nz*Database session created for public schemaError resetting search_path: ) app.core.tenant_contextr9app.db.tenant_schemar; SessionLocalr+rrr"r#r!)r9r;db tenant_idr(r)r)r*get_dbXs4       rBccs@t}zddlm}||d|VW|dS|w)z Get database session without tenant isolation Use this for operations that need to access public schema only, such as tenant management, user authentication, etc. rr:N)r?r>r;r+r!)r@r;r)r)r*get_db_without_tenantys  rCccsPddlm}ddlm}ddlm}t}ziz|}|r$|||n||d|V|Wn#t yU}z| t dt ||dt |d}~wwWz||dWnt yy}zt d|WYd}~nd}~ww|dSz||dWnt y}zt d|WYd}~nd}~ww|w) uy 事务感知的数据库会话上下文管理器 自动处理事务提交和回滚，确保数据一致性 rr8r:) DatabaseErrorNz"Transaction failed, rolling back: zDatabase transaction failed: r<)r=r9r>r;app.core.exceptionsrDr?r+commitr"rollbackrerrorrr#r!)r9r;rDr@rAr(r)r)r*get_db_with_transactionsB       rI)__doc__ sqlalchemyrrsqlalchemy.ormrrsqlalchemy.poolr contextlibr app.configrlogging getLoggerrr DATABASE_URLr5 listens_forr+r?r1r4r7rBrCrIr)r)r)r*s<        !