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 * FROM baseballStats 
12    LIMIT 10
13""")
14
15# Fetch and print the results
16for row in cursor:
17    print(row)
18
19# Close the connection
20cursor.close()
21conn.close()