pg8000_native_postgresql_connection_query_and_fetch.py

1import pg8000.native
2
3# Create a connection to the database
4con = pg8000.native.Connection(
5    user="config_user",
6    password="config_password",
7    host="localhost",
8    database="config_db"
9)
10
11# Run a query and fetch all results
12rows = con.run("SELECT * FROM my_table")
13
14# Print the results
15for row in rows:
16    print(row)
17
18# Close the connection
19con.close()