sync: 193 file da Baida98/AI@a7016b3e (2026-08-27 20:07 UTC) [deploy-all]

api/database.py

@@ -113,9 +113,10 @@ async def _pg_query(db_url: str, sql: str, params: list):
         return {"ok": False, "error": "psycopg2 non installato. Aggiungi 'psycopg2-binary' a requirements.txt."}
 
     def _run():
-        conn = psycopg2.connect(db_url)
+        conn = psycopg2.connect(db_url, connect_timeout=5)
         try:
             cur = conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
+            cur.execute("SET statement_timeout = '5000ms'")
             cur.execute(sql, params or None)
             try:
                 rows  = [dict(r) for r in cur.fetchmany(_MAX_ROWS)]

api/performance_rum.py

@@ -124,9 +124,10 @@ def _execute(sql: str, params: dict[str, Any], *, fetch: bool = False) -> list[d
     import psycopg2
     import psycopg2.extras
 
-    conn = psycopg2.connect(_db_url())
+    conn = psycopg2.connect(_db_url(), connect_timeout=5)
     try:
         with conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor) as cur:
+            cur.execute("SET statement_timeout = '5000ms'")
             cur.execute(sql, params)
             rows = [dict(row) for row in cur.fetchall()] if fetch else []
         conn.commit()

main.py

@@ -103,6 +103,7 @@ async def _run_auto_migration():
             try:
                 conn = psycopg2.connect(f"postgresql://postgres:{db_pass}@{db_host}:{port}/postgres?sslmode=require", connect_timeout=5)
                 cur = conn.cursor()
+                cur.execute("SET statement_timeout = '5000ms'")
                 cur.execute(sql)
                 conn.commit()
                 cur.close()