Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DisplayResult ¶
func DisplayResult(result *QueryResult)
DisplayResult prints the QueryResult in a simple table format.
func ExportArrow ¶
func ExportArrow(result *QueryResult) ([]byte, error)
ExportArrow converts QueryResult into Arrow IPC format.
func ExportCSV ¶
func ExportCSV(result *QueryResult) (string, error)
ExportCSV converts QueryResult into CSV format.
func ExportJSON ¶
func ExportJSON(result *QueryResult) (string, error)
ExportJSON converts QueryResult into JSON format.
func ExportParquet ¶
func ExportParquet(result *QueryResult) ([]byte, error)
ExportParquet converts QueryResult into Parquet format.
Types ¶
type QueryResult ¶
type QueryResult struct {
Columns []string `json:"columns"`
Rows [][]interface{} `json:"rows"`
}
QueryResult represents the structure of query results.
func ExecuteQuery ¶
func ExecuteQuery(query string, profile string) (*QueryResult, error)
ExecuteQuery connects to Trino and executes the SQL query. It handles connection pooling, session management, and includes automatic retry logic for transient failures.
Source Files
Click to show internal directories.
Click to hide internal directories.