in athenareader/main.go [48:69]
func queryAthena(qad queryfx.QueryAndDBConnection, mc configfx.AthenaDriverConfig) {
for _, query := range qad.Query {
query = strings.Trim(query, " \n\t")
if query == "" {
continue
}
rows, err := qad.DB.Query(query)
if err != nil {
println("ERROR: " + err.Error())
if mc.OutputConfig.Fastfail {
return
}
continue
}
defer rows.Close()
if mc.OutputConfig.Rowonly {
drv.PrettyPrintSQLRows(rows, mc.OutputConfig.Style, mc.OutputConfig.Render, mc.OutputConfig.Page)
} else {
drv.PrettyPrintSQLColsRows(rows, mc.OutputConfig.Style, mc.OutputConfig.Render, mc.OutputConfig.Page)
}
}
}