diff --git a/conn.go b/conn.go
index 907001a..abffba8 100644
--- a/conn.go
+++ b/conn.go
@@ -51,7 +51,7 @@ func (c *conn) runQuery(ctx context.Context, query string) (driver.Rows, error)
 	return newRows(rowsConfig{
 		Athena:     c.athena,
 		QueryID:    queryID,
-		SkipHeader: isDDLQuery(query),
+		SkipHeader: !isDDLQuery(query),
 	})
 }