adbc_postgresql_query_fetch_arrow_table_quickstart.py

1import adbc_driver_postgresql.dbapi
2import pyarrow
3
4# Update the URI with your actual PostgreSQL credentials and host
5uri = "postgresql://localhost:5432/postgres?user=postgres&password=password"
6
7with adbc_driver_postgresql.dbapi.connect(uri) as conn:
8    with conn.cursor() as cur:
9        cur.execute("SELECT 1")
10        table = cur.fetch_arrow_table()
11        print(table)