pinotdb_connect_and_execute_sql_query_quickstart.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
7cursor = conn.cursor()
8
9# Execute a standard SQL query
10cursor.execute("""
11    SELECT count(*) 
12    FROM airlineStats 
13    LIMIT 10
14""")
15
16# Fetch and print results
17for row in cursor:
18    print(row)
19
20# Close the connection
21cursor.close()
22conn.close()