sqlalchemy_trino_sync_query_execution_quickstart.py

1from sqlalchemy import create_engine
2from sqlalchemy.schema import Table, MetaData
3from sqlalchemy.sql import select
4
5# Connection string format: trino://<user>@<host>:<port>/<catalog>/<schema>
6engine = create_engine("trino://user@localhost:8080/system/runtime")
7connection = engine.connect()
8
9# Reflect an existing table or use textual SQL
10rows = connection.execute(select("SELECT * FROM nodes")).fetchall()
11
12for row in rows:
13    print(row)