71c74cd658
* Async chalice.core.tenants:tenants_exists, and propagate * rework after review * typofix * fix(chalice): small fixes * fix(api): use a global variable to store singletong... ... that will not work if several POSIX threads are serving from the same POSIX processus. * fix(api): pass database argument as dictionary. ref: https://www.postgresql.org/docs/current/libpq-connect.html#LIBPQ-CONNSTRING * chore(api): ease debugging with simple return statement. * NOTES++ --------- Co-authored-by: Taha Yassine Kraiem <tahayk2@gmail.com>
824 B
824 B
psycopg3 API
I mis-remember the psycopg v2 vs. v3 API.
For the record, the expected psycopg3's async api looks like the following pseudo code:
async with orpy.get().database.connection() as cnx:
async with cnx.transaction():
row = await cnx.execute("SELECT EXISTS(SELECT 1 FROM public.tenants)")
row = await row.fetchone()
return row["exists"]
Minding the following:
- Where
orpy.get().databaseis the postgresql connection pooler. - Wrap explicit transaction with
async with cnx.transaction(): foobar() - Most of the time the transaction object is not used;
- Do execute await operation against
cnx; await cnx.executereturns a cursor object;- Do the
await cursor.fetchqux...calls against the object return by a call to execute.