trino_dbapi_connect_execute_query_and_fetch_results.py

1import trino
2
3# Establish a connection to the Trino coordinator
4conn = trino.dbapi.connect(
5    host='localhost',
6    port=8080,
7    user='the-user',
8    catalog='tpch',
9    schema='sf1',
10)
11
12# Create a cursor object to execute queries
13cur = conn.cursor()
14
15# Execute a SQL query
16cur.execute('SELECT * FROM nation')
17
18# Fetch and print the results
19rows = cur.fetchall()
20for row in rows:
21    print(row)