func queryAthena()

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)
		}
	}
}