adbc_postgresql_query_fetch_to_arrow_table.py

1import adbc_driver_postgresql.dbapi
2import pyarrow
3
4uri = "postgresql://localhost:5432/postgres"
5with adbc_driver_postgresql.dbapi.connect(uri) as conn:
6    with conn.cursor() as cur:
7        cur.execute("SELECT 1")
8        table = cur.fetch_arrow_table()
9        print(table)