\j UddlmZddlmZddlmZmZddlmZddl m Z m Z m Z ddl mZe ZiZeeefed<iZeee e fed<eZeeed <d Zd ed eeeffd Zded ed dfdZdd edzd efdZdd edzd efdZdd edzd e e fdZdd edzd ee ddffdZedd edzd ee ddffdZy)) Generator)contextmanager) create_engineevent)Engine)Sessiondeclarative_base sessionmaker) get_settings _engine_cache_session_factory_cache_prepared_urlsi0u database_urlreturnc@|jdr dtdz dSiS)NsqliteFi)check_same_threadtimeout) startswithSQLITE_BUSY_TIMEOUT_MS)rs (apps/ordini/backend/app/core/database.py _connect_argsrs'x(%*7MPT7TUU IengineNcb|jdsytj|ddd}y)Nrconnectc|j} |jdtd|jd|jd|jd|jy#|jwxYw)NzPRAGMA busy_timeout = ;zPRAGMA foreign_keys = ON;zPRAGMA journal_mode = WAL;zPRAGMA synchronous = NORMAL;)cursorexecuterclose)dbapi_connection_connection_recordrs r_set_sqlite_pragmasz5_configure_sqlite_engine.._set_sqlite_pragmassg!((*  NN34J3K1M N NN6 7 NN7 8 NN9 : LLNFLLNs A A//B)rN)rr listens_for)rrr$s r_configure_sqlite_enginer&s2  " "8 , vy)*rc|xstj}tj|}|=t |d|j d t |}t|||t|<|S)NTr)future pool_pre_ping connect_args)r rr getrrrr&r target_urlrs r get_enginer.)sm<!s rdb_session_contextrCTs4*<8O  B   rAr<) collections.abcr contextlibr sqlalchemyrrsqlalchemy.enginersqlalchemy.ormrr r app.core.configr r1r dictstr__annotations__r setrrobjectrr&r.r5r:r@rCrrrPs>%%+$BB(#% tCK %;=S,w"778=5C S&[(9 V 3 4  S4Z 6  3:sTz\'=R#* '4QUBU8VS4Z9WdTXEX;Yr