pinotdb_connect_execute_sql_query_iterate_results.py

1from pinotdb import connect
2
3# Connect to the Pinot Broker
4conn = connect(host='localhost', port=8099, path='/query/sql', scheme='http')
5
6# Create a cursor object
7curs = conn.cursor()
8
9# Execute a SQL query
10curs.execute("""
11    SELECT count(*)
12    FROM airlineStats
13    LIMIT 10
14""")
15
16# Fetch and print results
17for row in curs:
18    print(row)
19
20# Close the connection
21curs.close()
22conn.close()