pinotdb_connect_and_execute_sql_query_example.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 * FROM baseballStats 
12    LIMIT 10
13""")
14
15# Fetch and print results
16for row in curs:
17    print(row)