j UdZddlmZddlmZddlmZddlmZddl m Z ddl m Z d a e d zed <d e fd Zdd Zd eefdZddededeezd zd ed zfdZddededeezd zd eefdZgdZy )zIPostgres access: a psycopg3 connection pool and raw SQL (no ORM queries).)Iterator) Connection)dict_row)Jsonb)ConnectionPool) get_settingsN_poolreturncjt(ttjdddtidatS)Nr row_factoryT)min_sizemax_sizekwargsopen)r rr database_urlr#/var/www/avy-guidance/api/app/db.pypoolrs4 } N ' '!8,   Lrc>ttjdayyN)r closerrr close_poolrs  rc#nKtj5}|dddy#1swYyxYww)zEFastAPI dependency: one transaction per request (commits on success).N)r connection)conns rget_connr#s/     s5) 525rsqlparamscB|j||jSr)executefetchonerr r!s rr$r$) <<V $ - - //rcB|j||jSr)r#fetchallr%s rr(r(-r&r)rrr(r$rr)r Nr)__doc__collections.abcrpsycopgr psycopg.rowsrpsycopg.types.jsonr psycopg_poolrsettingsr r __annotations__rrrstrdicttupler$listr(__all__rrrr6sO$!$'"#~# n (:& 0:0C01D0PTW[P[00:0C01D0PTUYPZ0 Nr