{j* 6UdZddlZddlZddlZddlmZddlmZmZm Z m Z ddl m Z ddl mZmZddlmZej$dZdae eed <ej,Zd Zd efd Zd efd Zd-dZej8dZej8dej<Zej8dej<Z ej8dej<Z!ej8dej<Z"ej8dej<Z#iZ$e%e&e&fed<de&d e&fdZ'Gdde%Z(GddZ)GddZ*d e*fdZ+ed.de&d e,fd!Z-d"e*d#e&d e.e&fd$Z/d"e*d#e&d e0fd%Z1d"e*d#e&d&e&d'e&d df d(Z2d"e*d#e&de&d)e&d df d*Z3d-d+Z4d-d,Z5y)/u Accès MySQL partagé par tous les modules (même pile que hec-photo-app : SQLAlchemy 2.0 + PyMySQL, utf8mb4 / InnoDB, variables MYSQL_*). Pourquoi un moteur SYNCHRONE derrière `get_db()` : le nettoyage RGPD, l'organizer, l'élection du leader et le rate limiting tournent dans des threads (`asyncio.to_thread`) et appelaient déjà `get_db()`. Le pool de SQLAlchemy fournit les connexions réutilisables ; l'interface (`conn.execute(sql, params)`, lignes accessibles par nom, `with get_db() as conn`) ne change pas pour les ~220 requêtes existantes. Dialecte : le code garde ses placeholders `?` ; ils sont traduits ici (avec `%` échappé). `INSERT OR REPLACE` → `REPLACE`, `INSERT OR IGNORE` → `INSERT IGNORE`, `BEGIN IMMEDIATE` → `START TRANSACTION`, la colonne `key` (mot réservé MySQL) est citée automatiquement et `COLLATE NOCASE` est ignoré (la collation par défaut utf8mb4_unicode_ci est déjà insensible à la casse, comme LIKE sous SQLite). N)contextmanager)AnyIteratorOptionalSequence) create_engine)URLEngine)configz meeconic.db_enginez@ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_cireturnc ,tjdtjtjxsdtj tj tjddi}t|tjtjdddS) Nz mysql+pymysqlcharsetutf8mb4)usernamepasswordhostportdatabasequeryiTzREAD COMMITTED) pool_size max_overflow pool_recycle pool_pre_pingisolation_level) r creater MYSQL_USERMYSQL_PASSWORD MYSQL_HOST MYSQL_PORTMYSQL_DBrMYSQL_POOL_SIZE)urls "/var/www/photos/backend/core/db.py _build_enginer%"ss **&"3"3f>S>S>[W[   V%6%6)$ &C  v--F>"d+D{{7D1<<T*223=DE!H ggen 6{Ts Jr&c&eZdZdZdZfdZxZS)Rowzz+Connection.executescript..s:1QWWY:s;)r>r)rXrstmts r$ executescriptzConnection.executescripts.: S(9: #D T" #r&c8|jjyr()rzcommitris r$rzConnection.commits r&c8|jjyr()rzrollbackris r$rzConnection.rollbacks r&cX |jjy#t$rYywxYwr()rzclose Exceptionris r$rzConnection.closes'  IIOO    s  ))c|Sr(r*ris r$ __enter__zConnection.__enter__s r&c ||jjn|jj|jy#|jwxYw)NF)rzrrr)rXexc_typeexctbs r$__exit__zConnection.__exit__sF    " ""$ JJL JJLs 7A A)r*r N)r rw)r[r\r]r^rfstrrrrbrrrrrrrboolrr*r&r$rwrwsY" 3 v AsA(3-)@ATA#C#D#  Tr&rwcDttjSr()rwr+raw_connectionr*r&r$get_dbrs fh--/ 00r&nametimeoutc#Kd|}t|dkDr4ddl}d|j|jj z}t } |j d||fjd}|dk7rtd|d |d  d|j d |f |jy#|j d |fwxYw#|jwxYww) uVerrou applicatif inter-processus (GET_LOCK). Remplace `BEGIN IMMEDIATE` de SQLite pour les lecture-puis-écriture qui doivent être atomiques (rate limiting, cooldown d'alertes).z meeconic:@rNzSELECT GET_LOCK(?, ?) AS okokzlock z not acquired in rzSELECT RELEASE_LOCK(?)) rGhashlibsha1encode hexdigestrrrm TimeoutErrorr)rrlockrconngots r$ named_lockrstf D 4y2~W\\$++-8BBDD 8D ll84/JSSUVZ[ !8th.?yJK K <  LL1D7 ;  LL1D7 ; s6AC(%$B2 B>!C2B;7B>>CC D %DD c tt5}|jdtdtdtd|j dddy#1swYyxYw)Nz CREATE TABLE IF NOT EXISTS app_kv ( `key` VARCHAR(191) NOT NULL PRIMARY KEY, value MEDIUMTEXT ) z; CREATE TABLE IF NOT EXISTS rate_hits ( `key` VARCHAR(191) NOT NULL, ts DOUBLE NOT NULL, KEY idx_rate_hits_key (`key`, ts) ) z; CREATE TABLE IF NOT EXISTS leader_locks ( name VARCHAR(64) NOT NULL PRIMARY KEY, owner VARCHAR(64) NOT NULL, expires_at DOUBLE NOT NULL ) z )rrr TABLE_OPTIONSr)rs r$init_core_tablesrsk T   / / /   #s 8AAr))6r^loggingre threading contextlibrtypingrrrr sqlalchemyrsqlalchemy.enginer r corer getLoggerrr __annotations__Lockr)rr%r+r.compiler= IGNORECASErErArCrDr9r/dictrrNrPrbrwrrSrrTrrrrrrrr*r&r$rs  %44$)g & &  y~~ R *v*RZZ+ , "**/ ??O =r}}M RZZ0"-- @ BJJEr}} U S#X33>&$&0..b1 1S3,% %3%49%z#$ G G3GG#G$G DzD#DSD3D4D{&r&